whip

Documentation

Index

• Variables
• func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler
• type HealthHandlers
• type MediaSink
• 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 (sp *RelayMediaSink) SetStatsGatherer(st *stats.LocalMediaStatsGatherer)
  • func (rs *RelayMediaSink) SetWriter(w io.WriteCloser) error
• type SDKMediaSink
  • func NewSDKMediaSink(l logger.Logger, p *params.Params, sdkOutput *lksdk_output.LKSDKOutput, ...) *SDKMediaSink
  • func (sp *SDKMediaSink) AddTrack(quality livekit.VideoQuality)
  • func (sp *SDKMediaSink) Close() error
  • func (sp *SDKMediaSink) SetWritePLI(quality livekit.VideoQuality, writePLI func()) *SDKMediaSinkTrack
• type SDKMediaSinkTrack
  • 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)
• 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) IsIdle() bool
  • func (s *WHIPServer) Start(conf *config.Config, ...) error
  • func (s *WHIPServer) Stop()

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 MediaSink

type MediaSink interface {
	PushSample(s *media.Sample, ts time.Duration) error
	Close() error
	SetStatsGatherer(g *stats.LocalMediaStatsGatherer)
}

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) SetStatsGatherer

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

func (*RelayMediaSink) SetWriter

func (rs *RelayMediaSink) SetWriter(w io.WriteCloser) 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,
	outputSync *utils.TrackOutputSynchronizer,
) *SDKMediaSink

func (*SDKMediaSink) AddTrack

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

func (*SDKMediaSink) Close

func (sp *SDKMediaSink) Close() error

func (*SDKMediaSink) SetWritePLI

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

type SDKMediaSinkTrack

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

func (*SDKMediaSinkTrack) Close

func (t *SDKMediaSinkTrack) Close() error

func (*SDKMediaSinkTrack) ForceKeyFrame

func (t *SDKMediaSinkTrack) ForceKeyFrame() error

func (*SDKMediaSinkTrack) OnBind

func (t *SDKMediaSinkTrack) OnBind() error

func (*SDKMediaSinkTrack) OnUnbind

func (t *SDKMediaSinkTrack) OnUnbind() error

func (*SDKMediaSinkTrack) PushSample

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

func (*SDKMediaSinkTrack) SetStatsGatherer

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

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) 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()