whip

Documentation

Index

• Variables
• func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler
• type HealthHandlers
• type RelayMediaSink
  • 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 RelayWhipTrackHandler
  • 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 NewSDKMediaSink(l logger.Logger, p *params.Params, sdkOutput *lksdk_output.LKSDKOutput, ...) *SDKMediaSink
  • func (sp *SDKMediaSink) Close() error
  • func (sp *SDKMediaSink) GetTrack(quality livekit.VideoQuality) *SDKMediaSinkTrack
• type SDKMediaSinkTrack
  • func (t *SDKMediaSinkTrack) Close() error
  • 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))
  • func (t *SDKMediaSinkTrack) SetStatsGatherer(st *stats.LocalMediaStatsGatherer)
• type SDKWhipTrackHandler
  • 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 WHIPRelayHandler
  • func NewWHIPRelayHandler(whipServer *WHIPServer) *WHIPRelayHandler
  • func (h *WHIPRelayHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type WHIPServer
  • func NewWHIPServer(rpcClient rpc.IngressHandlerClient) *WHIPServer
  • func (s *WHIPServer) AssociateRelay(resourceId string, kind types.StreamKind, token string, w io.WriteCloser) error
  • func (s *WHIPServer) CloseHandler(resourceId string)
  • func (s *WHIPServer) DissociateRelay(resourceId string, kind types.StreamKind)
  • func (s *WHIPServer) IsIdle() bool
  • func (s *WHIPServer) Start(conf *config.Config, ...) error
  • func (s *WHIPServer) Stop()
• type WhipTrackDescription
• type WhipTrackHandler

Variables

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

Functions

func NewWHIPHandler

func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler

Types

type HealthHandlers

type HealthHandlers map[string]http.HandlerFunc

type RelayMediaSink

type RelayMediaSink struct {
	// contains filtered or unexported fields
}

func NewRelayMediaSink

func NewRelayMediaSink(logger logger.Logger) *RelayMediaSink

func (*RelayMediaSink) Close

func (rs *RelayMediaSink) Close() error

func (*RelayMediaSink) PushSample

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

func (*RelayMediaSink) SetWriter

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

type RelayWhipTrackHandler

type RelayWhipTrackHandler struct {
	// contains filtered or unexported fields
}

func NewRelayWhipTrackHandler

func NewRelayWhipTrackHandler(
	logger logger.Logger,
	track *webrtc.TrackRemote,
	quality livekit.VideoQuality,
	sync *synchronizer.TrackSynchronizer,
	receiver *webrtc.RTPReceiver,
	writePLI func(ssrc webrtc.SSRC),
	onRTCP func(packet rtcp.Packet),
) (*RelayWhipTrackHandler, error)

func (*RelayWhipTrackHandler) Close

func (t *RelayWhipTrackHandler) Close()

func (*RelayWhipTrackHandler) SetMediaTrackStatsGatherer

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

func (*RelayWhipTrackHandler) SetWriter

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

func (*RelayWhipTrackHandler) Start

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

type SDKMediaSink

type SDKMediaSink struct {
	// contains filtered or unexported fields
}

func NewSDKMediaSink

func NewSDKMediaSink(
	l logger.Logger,
	p *params.Params,
	sdkOutput *lksdk_output.LKSDKOutput,
	codecParameters webrtc.RTPCodecParameters,
	streamKind types.StreamKind,
	layers []livekit.VideoQuality,
) *SDKMediaSink

func (*SDKMediaSink) Close

func (sp *SDKMediaSink) Close() error

func (*SDKMediaSink) GetTrack

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

type SDKMediaSinkTrack

type SDKMediaSinkTrack struct {
	// contains filtered or unexported fields
}

func (*SDKMediaSinkTrack) Close

func (t *SDKMediaSinkTrack) Close() error

func (*SDKMediaSinkTrack) HandleRTCPPacket

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

func (*SDKMediaSinkTrack) PushRTCP

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

func (*SDKMediaSinkTrack) PushRTP

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

func (*SDKMediaSinkTrack) SetRTCPPacketSink

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

func (*SDKMediaSinkTrack) SetStatsGatherer

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

type SDKWhipTrackHandler

type SDKWhipTrackHandler struct {
	// contains filtered or unexported fields
}

func NewSDKWhipTrackHandler

func NewSDKWhipTrackHandler(
	logger logger.Logger,
	track *webrtc.TrackRemote,
	quality livekit.VideoQuality,
	receiver *webrtc.RTPReceiver,
	writePLI func(ssrc webrtc.SSRC),
	sendRTCPUpStream func(pkt rtcp.Packet),
) (*SDKWhipTrackHandler, error)

func (*SDKWhipTrackHandler) Close

func (t *SDKWhipTrackHandler) Close()

func (*SDKWhipTrackHandler) SetMediaSink

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

func (*SDKWhipTrackHandler) SetMediaTrackStatsGatherer

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

func (*SDKWhipTrackHandler) Start

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

type WHIPRelayHandler

type WHIPRelayHandler struct {
	// contains filtered or unexported fields
}

func NewWHIPRelayHandler

func NewWHIPRelayHandler(whipServer *WHIPServer) *WHIPRelayHandler

func (*WHIPRelayHandler) ServeHTTP

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

type WHIPServer

type WHIPServer struct {
	// contains filtered or unexported fields
}

func NewWHIPServer

func NewWHIPServer(rpcClient rpc.IngressHandlerClient) *WHIPServer

func (*WHIPServer) AssociateRelay

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

func (*WHIPServer) CloseHandler

func (s *WHIPServer) CloseHandler(resourceId string)

func (*WHIPServer) DissociateRelay

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

func (*WHIPServer) IsIdle

func (s *WHIPServer) IsIdle() bool

func (*WHIPServer) Start

func (s *WHIPServer) Start(
	conf *config.Config,
	onPublish func(streamKey, resourceId string, ihs rpc.IngressHandlerServerImpl) (*params.Params, func(mimeTypes map[types.StreamKind]string, err error) *stats.LocalMediaStatsGatherer, func(error), error),
	healthHandlers HealthHandlers,
) error

func (*WHIPServer) Stop

func (s *WHIPServer) Stop()

type WhipTrackDescription

type WhipTrackDescription struct {
	Kind    types.StreamKind
	Quality livekit.VideoQuality
}

type WhipTrackHandler

type WhipTrackHandler interface {
	Start(onDone func(err error)) (err error)
	Close()
	SetMediaTrackStatsGatherer(g *stats.LocalMediaStatsGatherer)
}