transport

Documentation

Index

• Variables
• type Handler
• type NegotiationState
  • func (n NegotiationState) String() string
• type UnimplementedHandler
  • func (h UnimplementedHandler) OnAnswer(sd webrtc.SessionDescription) error
  • func (h UnimplementedHandler) OnDataPacket(kind livekit.DataPacket_Kind, data []byte)
  • func (h UnimplementedHandler) OnDataSendError(err error)
  • func (h UnimplementedHandler) OnFailed(isShortLived bool)
  • func (h UnimplementedHandler) OnFullyEstablished()
  • func (h UnimplementedHandler) OnICECandidate(c *webrtc.ICECandidate, target livekit.SignalTarget) error
  • func (h UnimplementedHandler) OnInitialConnected()
  • func (h UnimplementedHandler) OnNegotiationFailed()
  • func (h UnimplementedHandler) OnNegotiationStateChanged(state NegotiationState)
  • func (h UnimplementedHandler) OnOffer(sd webrtc.SessionDescription) error
  • func (h UnimplementedHandler) OnStreamStateChange(update *streamallocator.StreamStateUpdate) error
  • func (h UnimplementedHandler) OnTrack(track *webrtc.TrackRemote, rtpReceiver *webrtc.RTPReceiver)

Variables

var (
	ErrNoICECandidateHandler = errors.New("no ICE candidate handler")
	ErrNoOfferHandler        = errors.New("no offer handler")
	ErrNoAnswerHandler       = errors.New("no answer handler")
)

Types

type Handler

type Handler interface {
	OnICECandidate(c *webrtc.ICECandidate, target livekit.SignalTarget) error
	OnInitialConnected()
	OnFullyEstablished()
	OnFailed(isShortLived bool)
	OnTrack(track *webrtc.TrackRemote, rtpReceiver *webrtc.RTPReceiver)
	OnDataPacket(kind livekit.DataPacket_Kind, data []byte)
	OnDataSendError(err error)
	OnOffer(sd webrtc.SessionDescription) error
	OnAnswer(sd webrtc.SessionDescription) error
	OnNegotiationStateChanged(state NegotiationState)
	OnNegotiationFailed()
	OnStreamStateChange(update *streamallocator.StreamStateUpdate) error
}

type NegotiationState

type NegotiationState int

const (
	NegotiationStateNone NegotiationState = iota
	// waiting for remote description
	NegotiationStateRemote
	// need to Negotiate again
	NegotiationStateRetry
)

func (NegotiationState) String

func (n NegotiationState) String() string

type UnimplementedHandler

type UnimplementedHandler struct{}

func (UnimplementedHandler) OnAnswer

func (h UnimplementedHandler) OnAnswer(sd webrtc.SessionDescription) error

func (UnimplementedHandler) OnDataPacket

func (h UnimplementedHandler) OnDataPacket(kind livekit.DataPacket_Kind, data []byte)

func (UnimplementedHandler) OnDataSendError

func (h UnimplementedHandler) OnDataSendError(err error)

func (UnimplementedHandler) OnFailed

func (h UnimplementedHandler) OnFailed(isShortLived bool)

func (UnimplementedHandler) OnFullyEstablished

func (h UnimplementedHandler) OnFullyEstablished()

func (UnimplementedHandler) OnICECandidate

func (h UnimplementedHandler) OnICECandidate(c *webrtc.ICECandidate, target livekit.SignalTarget) error

func (UnimplementedHandler) OnInitialConnected

func (h UnimplementedHandler) OnInitialConnected()

func (UnimplementedHandler) OnNegotiationFailed

func (h UnimplementedHandler) OnNegotiationFailed()

func (UnimplementedHandler) OnNegotiationStateChanged

func (h UnimplementedHandler) OnNegotiationStateChanged(state NegotiationState)

func (UnimplementedHandler) OnOffer

func (h UnimplementedHandler) OnOffer(sd webrtc.SessionDescription) error

func (UnimplementedHandler) OnStreamStateChange

func (h UnimplementedHandler) OnStreamStateChange(update *streamallocator.StreamStateUpdate) error

func (UnimplementedHandler) OnTrack

func (h UnimplementedHandler) OnTrack(track *webrtc.TrackRemote, rtpReceiver *webrtc.RTPReceiver)