endpoint

Documentation

Index

• Constants
• type Endpoint
  • func NewEndpoint(participantId string) *Endpoint
  • func (e *Endpoint) AcceptSDPOfferAnswer(sdpOfferAnswer string) error
  • func (e *Endpoint) DoSignaling(endpointManager *EndpointManager) (*SignalingResult, error)
• type EndpointManager
  • func NewEndpointManager(dockerHostIp string, udpPort int, inventaObj *inventa.Inventa) *EndpointManager
  • func (m *EndpointManager) EnsureEndpoint(participantId string) *Endpoint
  • func (m *EndpointManager) Run(waitGroup *sync.WaitGroup)
• type SignalingResult

Constants

const (
	STREAM_IMAGES = "images"
)

Types

type Endpoint

type Endpoint struct {
	ParticipantId              string
	PeerConnection             *webrtc.PeerConnection
	ICEConnectionState         string
	OnICEConnectionStateChange func(newConnectionState string, oldConnectionState string)
}

func NewEndpoint

func NewEndpoint(participantId string) *Endpoint

func (*Endpoint) AcceptSDPOfferAnswer

func (e *Endpoint) AcceptSDPOfferAnswer(sdpOfferAnswer string) error

func (*Endpoint) DoSignaling

func (e *Endpoint) DoSignaling(endpointManager *EndpointManager) (*SignalingResult, error)

type EndpointManager

type EndpointManager struct {
	Endpoints map[string]*Endpoint //key: ParticipantId
	WebrtcApi *webrtc.API
	Inventa   *inventa.Inventa
	// contains filtered or unexported fields
}

func NewEndpointManager

func NewEndpointManager(dockerHostIp string, udpPort int, inventaObj *inventa.Inventa) *EndpointManager

func (*EndpointManager) EnsureEndpoint

func (m *EndpointManager) EnsureEndpoint(participantId string) *Endpoint

func (*EndpointManager) Run

func (m *EndpointManager) Run(waitGroup *sync.WaitGroup)

type SignalingResult

type SignalingResult struct {
	SDP string `json:"sdp"`
}