synchronizer

Oct 7, 2023

Changes in this version

type Synchronizer

+ func (s *Synchronizer) RemoveTrack(trackID string)

Jun 14, 2023

Changes in this version

+ var ErrBackwardsPTS = errors.New("backwards pts")

Jun 5, 2023

Changes in this version

+ type Synchronizer struct

+ func NewSynchronizer(onStarted func()) *Synchronizer

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

+ func (s *Synchronizer) End()

+ func (s *Synchronizer) GetEndedAt() int64

+ func (s *Synchronizer) GetStartedAt() int64

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

+ type TrackRemote interface

+ Codec func() webrtc.RTPCodecParameters

+ ID func() string

+ Kind func() webrtc.RTPCodecType

+ SSRC func() webrtc.SSRC

+ type TrackStats struct

+ AvgDrift float64

+ AvgSampleDuration float64

+ MaxDrift time.Duration

+ type TrackSynchronizer struct

+ func (t *TrackSynchronizer) GetFrameDuration() time.Duration

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

+ func (t *TrackSynchronizer) GetTrackStats() TrackStats

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

+ func (t *TrackSynchronizer) InsertFrame(pkt *rtp.Packet) time.Duration

+ func (t *TrackSynchronizer) InsertFrameBefore(pkt *rtp.Packet, next *rtp.Packet) (time.Duration, bool)