whip

package

v1.2.0 Latest Latest Go to latest Published: Oct 18, 2023 License: Apache-2.0 Imports: 38 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/livekit/ingress

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler
type HealthHandler
type MediaSink
type RelayMediaSink
- func NewRelayMediaSink(logger logger.Logger) *RelayMediaSink
type SDKMediaSink
- func NewSDKMediaSink(l logger.Logger, p *params.Params, sdkOutput *lksdk_output.LKSDKOutput, ...) *SDKMediaSink
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

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func NewWHIPHandler ¶

func NewWHIPHandler(webRTCConfig *rtcconfig.WebRTCConfig) *whipHandler

Types ¶

type HealthHandler ¶

type HealthHandler interface {
	HealthHandler(http.ResponseWriter, *http.Request)
	AvailabilityHandler(http.ResponseWriter, *http.Request)
}

type MediaSink ¶

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

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 SDKMediaSink ¶

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

func NewSDKMediaSink ¶

func NewSDKMediaSink(l logger.Logger, p *params.Params, sdkOutput *lksdk_output.LKSDKOutput, track *webrtc.TrackRemote, outputSync *utils.TrackOutputSynchronizer, writePLI func()) *SDKMediaSink

func (*SDKMediaSink) Close ¶

func (sp *SDKMediaSink) Close() error

func (*SDKMediaSink) ForceKeyFrame ¶

func (sp *SDKMediaSink) ForceKeyFrame() error

func (*SDKMediaSink) NextSample ¶

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

func (*SDKMediaSink) OnBind ¶

func (sp *SDKMediaSink) OnBind() error

func (*SDKMediaSink) OnUnbind ¶

func (sp *SDKMediaSink) OnUnbind() error

func (*SDKMediaSink) PushSample ¶

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

func (*SDKMediaSink) SetWriter ¶

func (sp *SDKMediaSink) SetWriter(w io.WriteCloser) 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, 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.MediaStatsReporter, func(error), error),
	healthHandler HealthHandler,
) error

func (*WHIPServer) Stop ¶

func (s *WHIPServer) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL