utils

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: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeregisterIngressRpcHandlers added in v1.5.0 

func DeregisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo)

func DeserializeMediaForRelay 

func DeserializeMediaForRelay(r io.Reader) ([]byte, time.Duration, error)

func NewHandlerLogger added in v1.5.0 

func NewHandlerLogger(resourceID, ingressID string) *medialogutils.CmdLogger

func RegisterIngressRpcHandlers added in v1.5.0 

func RegisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo) error

func ReplaceRTCPPacketSSRC added in v1.4.0 

func ReplaceRTCPPacketSSRC(pkt rtcp.Packet, newSSRC uint32) (rtcp.Packet, error)

func SerializeMediaForRelay 

func SerializeMediaForRelay(w io.Writer, data []byte, ts time.Duration) error

Types

type BlockingQueue added in v1.5.0 

type BlockingQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewBlockingQueue added in v1.5.0 

func NewBlockingQueue[T any](capacity int) *BlockingQueue[T]

func (*BlockingQueue[T]) Close added in v1.5.0 

func (b *BlockingQueue[T]) Close()

func (*BlockingQueue[T]) PopFront added in v1.5.0 

func (b *BlockingQueue[T]) PopFront() (T, error)

func (*BlockingQueue[T]) PushBack added in v1.5.0 

func (b *BlockingQueue[T]) PushBack(item T)

func (*BlockingQueue[T]) QueueLength added in v1.5.0 

func (b *BlockingQueue[T]) QueueLength() int

type OutputSynchronizer added in v1.2.0 

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

func NewOutputSynchronizer added in v1.2.0 

func NewOutputSynchronizer() *OutputSynchronizer

func (*OutputSynchronizer) AddTrack added in v1.2.0 

func (os *OutputSynchronizer) AddTrack() *TrackOutputSynchronizer

func (*OutputSynchronizer) ScheduleEvent added in v1.5.0 

func (os *OutputSynchronizer) ScheduleEvent(ctx context.Context, pts time.Duration, event func()) error

ScheduleEvent TODO adjust timer deadline when zeroTime is adjusted

type PrerollBuffer 

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

func NewPrerollBuffer 

func NewPrerollBuffer(onBufferReset func() error) *PrerollBuffer

func (*PrerollBuffer) Close 

func (pb *PrerollBuffer) Close() error

func (*PrerollBuffer) SetWriter 

func (pb *PrerollBuffer) SetWriter(w io.WriteCloser) error

func (*PrerollBuffer) Write 

func (pb *PrerollBuffer) Write(p []byte) (int, error)

type StateNotifier added in v1.5.0 

type StateNotifier interface {
	UpdateIngressState(ctx context.Context, projectID string, info *livekit.IngressInfo) error
}

func NewHandlerStateNotifier added in v1.5.0 

func NewHandlerStateNotifier(ipcClient ipc.IngressServiceClient) StateNotifier

func NewNoopStateNotifier added in v1.5.0 

func NewNoopStateNotifier() StateNotifier

func NewServiceStateNotifier added in v1.5.0 

func NewServiceStateNotifier(psrpcClient rpc.IOInfoClient) StateNotifier

type TrackOutputSynchronizer added in v1.2.0 

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

func (*TrackOutputSynchronizer) Close added in v1.2.0 

func (ost *TrackOutputSynchronizer) Close()

func (*TrackOutputSynchronizer) WaitForMediaTime added in v1.2.0 

func (ost *TrackOutputSynchronizer) WaitForMediaTime(pts time.Duration, playingTooSlow bool) (bool, error)

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.