synchronizer

package

v2.10.0 Latest Latest Go to latest Published: Aug 21, 2025 License: Apache-2.0 Imports: 8 Imported by: 3

Details

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

Repository

github.com/livekit/server-sdk-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Synchronizer
- func NewSynchronizer(onStarted func()) *Synchronizer
- func NewSynchronizerWithOptions(opts ...SynchronizerOption) *Synchronizer
type SynchronizerConfig
type SynchronizerOption
- func WithMaxTsDiff(maxTsDiff time.Duration) SynchronizerOption
- func WithOnStarted(onStarted func()) SynchronizerOption
type TrackRemote
type TrackSynchronizer

Constants ¶

View Source

const (
	DefaultMaxTsDiff = time.Minute
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Synchronizer ¶

type Synchronizer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

a single Synchronizer is shared between all audio and video writers

func NewSynchronizer ¶

func NewSynchronizer(onStarted func()) *Synchronizer

func NewSynchronizerWithOptions ¶ added in v2.10.0

func NewSynchronizerWithOptions(opts ...SynchronizerOption) *Synchronizer

func (*Synchronizer) AddTrack ¶

func (s *Synchronizer) AddTrack(track TrackRemote, identity string) *TrackSynchronizer

func (*Synchronizer) End ¶

func (s *Synchronizer) End()

func (*Synchronizer) GetEndedAt ¶

func (s *Synchronizer) GetEndedAt() int64

func (*Synchronizer) GetStartedAt ¶

func (s *Synchronizer) GetStartedAt() int64

func (*Synchronizer) OnRTCP ¶

func (s *Synchronizer) OnRTCP(packet rtcp.Packet)

OnRTCP syncs a/v using sender reports

func (*Synchronizer) RemoveTrack ¶

func (s *Synchronizer) RemoveTrack(trackID string)

type SynchronizerConfig ¶ added in v2.10.0

type SynchronizerConfig struct {
	MaxTsDiff time.Duration
	OnStarted func()
}

SynchronizerConfig holds configuration for the Synchronizer

type SynchronizerOption ¶ added in v2.10.0

type SynchronizerOption func(*SynchronizerConfig)

func WithMaxTsDiff ¶ added in v2.10.0

func WithMaxTsDiff(maxTsDiff time.Duration) SynchronizerOption

WithMaxTsDiff sets the maximum acceptable difference between RTP packets In case exceeded the synchronizer will adjust the PTS offset to keep the audio and video in sync

func WithOnStarted ¶ added in v2.10.0

func WithOnStarted(onStarted func()) SynchronizerOption

WithOnStarted sets the callback to be called when the synchronizer starts

type TrackRemote ¶

type TrackRemote interface {
	ID() string
	Codec() webrtc.RTPCodecParameters
	Kind() webrtc.RTPCodecType
	SSRC() webrtc.SSRC
}

type TrackSynchronizer ¶

type TrackSynchronizer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TrackSynchronizer) GetPTS ¶

func (t *TrackSynchronizer) GetPTS(pkt *rtp.Packet) (time.Duration, error)

GetPTS will reset sequence numbers and/or offsets if necessary Packets are expected to be in order

func (*TrackSynchronizer) Initialize ¶

func (t *TrackSynchronizer) Initialize(pkt *rtp.Packet)

Initialize should be called as soon as the first packet is received

func (*TrackSynchronizer) OnSenderReport ¶ added in v2.8.2

func (t *TrackSynchronizer) OnSenderReport(f func(drift time.Duration))

Source Files ¶

View all Source files

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