whip

Apr 5, 2024

Changes in this version

+ type RelayWhipTrackHandler struct

+ func NewRelayWhipTrackHandler(logger logger.Logger, track *webrtc.TrackRemote, quality livekit.VideoQuality, ...) (*RelayWhipTrackHandler, error)

+ func (t *RelayWhipTrackHandler) Close()

+ func (t *RelayWhipTrackHandler) SetMediaTrackStatsGatherer(st *stats.LocalMediaStatsGatherer)

+ func (t *RelayWhipTrackHandler) SetWriter(w io.WriteCloser) error

+ func (t *RelayWhipTrackHandler) Start(onDone func(err error)) (err error)

type SDKMediaSink

+ func (sp *SDKMediaSink) GetTrack(quality livekit.VideoQuality) *SDKMediaSinkTrack

type SDKMediaSinkTrack

+ func (t *SDKMediaSinkTrack) HandleRTCPPacket(pkt rtcp.Packet) error

+ func (t *SDKMediaSinkTrack) PushRTCP(pkts []rtcp.Packet) error

+ func (t *SDKMediaSinkTrack) PushRTP(pkt *rtp.Packet) error

+ func (t *SDKMediaSinkTrack) SetRTCPPacketSink(handleRTCPPacket func(pkt rtcp.Packet))

+ type SDKWhipTrackHandler struct

+ func NewSDKWhipTrackHandler(logger logger.Logger, track *webrtc.TrackRemote, quality livekit.VideoQuality, ...) (*SDKWhipTrackHandler, error)

+ func (t *SDKWhipTrackHandler) Close()

+ func (t *SDKWhipTrackHandler) SetMediaSink(s *SDKMediaSinkTrack)

+ func (t *SDKWhipTrackHandler) SetMediaTrackStatsGatherer(st *stats.LocalMediaStatsGatherer)

+ func (t *SDKWhipTrackHandler) Start(onDone func(err error)) (err error)

type WHIPServer

+ func (s *WHIPServer) CloseHandler(resourceId string)

+ func (s *WHIPServer) DissociateRelay(resourceId string, kind types.StreamKind)

+ type WhipTrackDescription struct

+ Kind types.StreamKind

+ Quality livekit.VideoQuality

+ type WhipTrackHandler interface

+ Close func()

+ SetMediaTrackStatsGatherer func(g *stats.LocalMediaStatsGatherer)

+ Start func(onDone func(err error)) (err error)

Feb 3, 2024

Changes in this version

type MediaSink

+ SetStatsGatherer func(g *stats.LocalMediaStatsGatherer)

type RelayMediaSink

+ func (sp *RelayMediaSink) SetStatsGatherer(st *stats.LocalMediaStatsGatherer)

type SDKMediaSink

+ func (sp *SDKMediaSink) AddTrack(quality livekit.VideoQuality)

+ func (sp *SDKMediaSink) SetWritePLI(quality livekit.VideoQuality, writePLI func()) *SDKMediaSinkTrack

+ type SDKMediaSinkTrack struct

+ func (t *SDKMediaSinkTrack) Close() error

+ func (t *SDKMediaSinkTrack) ForceKeyFrame() error

+ func (t *SDKMediaSinkTrack) OnBind() error

+ func (t *SDKMediaSinkTrack) OnUnbind() error

+ func (t *SDKMediaSinkTrack) PushSample(s *media.Sample, ts time.Duration) error

+ func (t *SDKMediaSinkTrack) SetStatsGatherer(st *stats.LocalMediaStatsGatherer)

Dec 21, 2023

Changes in this version

+ type HealthHandlers map[string]http.HandlerFunc

Jun 26, 2023

Changes in this version

+ var ErrParamsUnavailable = psrpc.NewErrorf(psrpc.InvalidArgument, "codec parameters unavailable in sample")

+ func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler

+ type HealthHandler interface

+ AvailabilityHandler func(http.ResponseWriter, *http.Request)

+ HealthHandler func(http.ResponseWriter, *http.Request)

+ type MediaSink interface

+ Close func() error

+ PushSample func(s *media.Sample, ts time.Duration) error

+ type RelayMediaSink struct

+ func NewRelayMediaSink(logger logger.Logger) *RelayMediaSink

+ func (rs *RelayMediaSink) Close() error

+ func (rs *RelayMediaSink) PushSample(s *media.Sample, ts time.Duration) error

+ func (rs *RelayMediaSink) SetWriter(w io.WriteCloser) error

+ type SDKMediaSink struct

+ func NewSDKMediaSink(l logger.Logger, p *params.Params, sdkOutput *lksdk_output.LKSDKOutput, ...) *SDKMediaSink

+ func (sp *SDKMediaSink) Close() error

+ func (sp *SDKMediaSink) ForceKeyFrame() error

+ func (sp *SDKMediaSink) NextSample() (media.Sample, error)

+ func (sp *SDKMediaSink) OnBind() error

+ func (sp *SDKMediaSink) OnUnbind() error

+ func (sp *SDKMediaSink) PushSample(s *media.Sample, ts time.Duration) error

+ func (sp *SDKMediaSink) SetWriter(w io.WriteCloser) error

+ type WHIPRelayHandler struct

+ func NewWHIPRelayHandler(whipServer *WHIPServer) *WHIPRelayHandler

+ func (h *WHIPRelayHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WHIPServer struct

+ func NewWHIPServer(rpcClient rpc.IngressHandlerClient) *WHIPServer

+ func (s *WHIPServer) AssociateRelay(resourceId string, kind types.StreamKind, w io.WriteCloser) error

+ func (s *WHIPServer) IsIdle() bool

+ func (s *WHIPServer) Start(conf *config.Config, ...) error

+ func (s *WHIPServer) Stop()