whip

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2026 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type HealthHandlers added in v1.2.2 

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 added in v1.4.0 

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

func NewRelayWhipTrackHandler added in v1.4.0 

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 added in v1.4.0 

func (t *RelayWhipTrackHandler) Close()

func (*RelayWhipTrackHandler) SetMediaTrackStatsGatherer added in v1.4.0 

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

func (*RelayWhipTrackHandler) SetWriter added in v1.4.0 

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

func (*RelayWhipTrackHandler) Start added in v1.4.0 

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 added in v1.4.0 

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

type SDKMediaSinkTrack added in v1.3.0 

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

func (*SDKMediaSinkTrack) Close added in v1.3.0 

func (t *SDKMediaSinkTrack) Close() error

func (*SDKMediaSinkTrack) HandleRTCPPacket added in v1.4.0 

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

func (*SDKMediaSinkTrack) PushRTCP added in v1.4.0 

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

func (*SDKMediaSinkTrack) PushRTP added in v1.4.0 

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

func (*SDKMediaSinkTrack) QueueLength added in v1.5.0 

func (t *SDKMediaSinkTrack) QueueLength() int

func (*SDKMediaSinkTrack) SetRTCPPacketSink added in v1.4.0 

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

func (*SDKMediaSinkTrack) SetStatsGatherer added in v1.3.0 

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

type SDKWhipTrackHandler added in v1.4.0 

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

func NewSDKWhipTrackHandler added in v1.4.0 

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 added in v1.4.0 

func (t *SDKWhipTrackHandler) Close()

func (*SDKWhipTrackHandler) SetMediaSink added in v1.4.0 

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

func (*SDKWhipTrackHandler) SetMediaTrackStatsGatherer added in v1.4.0 

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

func (*SDKWhipTrackHandler) Start added in v1.4.0 

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

type WHIPHandler added in v1.5.0 

type WHIPHandler interface {
	Init(ctx context.Context, sdpOffer string) (string, error)
	SetMediaStatsGatherer(st *stats.LocalMediaStatsGatherer)
	Start(ctx context.Context) (map[types.StreamKind]string, error)
	WaitForSessionEnd(ctx context.Context) error
	Close()
	UpdateIngress(ctx context.Context, req *livekit.UpdateIngressRequest) (*livekit.IngressState, error)
	DeleteIngress(ctx context.Context, req *livekit.DeleteIngressRequest) (*livekit.IngressState, error)
	DeleteWHIPResource(ctx context.Context, req *rpc.DeleteWHIPResourceRequest) (*google_protobuf2.Empty, error)
	ICERestartWHIPResource(ctx context.Context, req *rpc.ICERestartWHIPResourceRequest) (*rpc.ICERestartWHIPResourceResponse, error)
	AssociateRelay(kind types.StreamKind, token string, w io.WriteCloser) error
	DissociateRelay(kind types.StreamKind)
}

func NewProxyWHIPHandler added in v1.5.0 

func NewProxyWHIPHandler(p *params.Params, bus psrpc.MessageBus, ua string) (WHIPHandler, 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(bus psrpc.MessageBus) (*WHIPServer, error)

func (*WHIPServer) AssociateRelay 

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

func (*WHIPServer) CloseHandler added in v1.4.0 

func (s *WHIPServer) CloseHandler(resourceId string)

func (*WHIPServer) DissociateRelay added in v1.4.0 

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) (*params.Params, func(mimeTypes map[types.StreamKind]string, err error) *stats.LocalMediaStatsGatherer, func(error), error),
	getWhipProxyEnabled func(ctx context.Context, featureFlags map[string]string) bool,
	healthHandlers HealthHandlers,
) error

func (*WHIPServer) Stop 

func (s *WHIPServer) Stop()

type WhipTrackDescription added in v1.4.0 

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

type WhipTrackHandler added in v1.4.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.