pacer

Jan 3, 2025

Changes in this version

type Base

+ func (b *Base) TimeSinceLastSentPacket() time.Duration

type Pacer

+ EndProbeCluster func(probeClusterId ccutils.ProbeClusterId) ccutils.ProbeClusterInfo

+ SetPacerProbeObserverListener func(listener PacerProbeObserverListener)

+ StartProbeCluster func(pci ccutils.ProbeClusterInfo)

+ TimeSinceLastSentPacket func() time.Duration

+ type PacerProbeObserverListener interface

+ OnPacerProbeObserverClusterComplete func(probeClusterId ccutils.ProbeClusterId)

type Packet

+ HeaderSize int

+ IsProbe bool

+ IsRTX bool

+ ProbeClusterId ccutils.ProbeClusterId

+ type ProbeObserver struct

+ func NewProbeObserver(logger logger.Logger) *ProbeObserver

+ func (po *ProbeObserver) EndProbeCluster(probeClusterId ccutils.ProbeClusterId) ccutils.ProbeClusterInfo

+ func (po *ProbeObserver) RecordPacket(size int, isRTX bool, probeClusterId ccutils.ProbeClusterId, isProbe bool)

+ func (po *ProbeObserver) SetPacerProbeObserverListener(listener PacerProbeObserverListener)

+ func (po *ProbeObserver) StartProbeCluster(pci ccutils.ProbeClusterInfo)

Oct 16, 2023

Changes in this version

type Packet

+ Pool *sync.Pool

+ PoolEntity *[]byte

Aug 23, 2023

Changes in this version

type Base

+ func (b *Base) SetBitrate(_bitrate int)

+ func (b *Base) SetInterval(_interval time.Duration)

+ type LeakyBucket struct

+ func NewLeakyBucket(logger logger.Logger, interval time.Duration, bitrate int) *LeakyBucket

+ func (l *LeakyBucket) Enqueue(p Packet)

+ func (l *LeakyBucket) SetBitrate(bitrate int)

+ func (l *LeakyBucket) SetInterval(interval time.Duration)

+ func (l *LeakyBucket) Stop()

type Pacer

+ SetBitrate func(bitrate int)

+ SetInterval func(interval time.Duration)

Jul 9, 2023

Changes in this version

+ type Base struct

+ func NewBase(logger logger.Logger) *Base

+ func (b *Base) SendPacket(p *Packet) error

+ type ExtensionData struct

+ ID uint8

+ Payload []byte

+ type NoQueue struct

+ func NewNoQueue(logger logger.Logger) *NoQueue

+ func (n *NoQueue) Enqueue(p Packet)

+ func (n *NoQueue) Stop()

+ type Pacer interface

+ Enqueue func(p Packet)

+ Stop func()

+ type Packet struct

+ AbsSendTimeExtID uint8

+ Extensions []ExtensionData

+ Header *rtp.Header

+ Metadata interface{}

+ OnSent func(md interface{}, sentHeader *rtp.Header, payloadSize int, sentTime time.Time, ...)

+ Payload []byte

+ TransportWideExtID uint8

+ WriteStream webrtc.TrackLocalWriter

+ type PacketTime struct

+ func NewPacketTime() *PacketTime

+ func (p *PacketTime) Get() time.Time

+ type PassThrough struct

+ func NewPassThrough(logger logger.Logger) *PassThrough

+ func (p *PassThrough) Enqueue(pkt Packet)

+ func (p *PassThrough) Stop()