Versions in this module Expand all Collapse all v0 v0.0.1 Nov 29, 2022 Changes in this version + var ErrSendSideBWEClosed = errors.New("SendSideBwe closed") + var ErrUnknownStream = errors.New("unknown ssrc") + type DelayStats struct + Estimate time.Duration + LastReceiveDelta time.Duration + Measurement time.Duration + State state + TargetBitrate int + Threshold time.Duration + Usage usage + type LeakyBucketPacer struct + func NewLeakyBucketPacer(initialBitrate int) *LeakyBucketPacer + func (p *LeakyBucketPacer) AddStream(ssrc uint32, writer interceptor.RTPWriter) + func (p *LeakyBucketPacer) Close() error + func (p *LeakyBucketPacer) Run() + func (p *LeakyBucketPacer) SetTargetBitrate(rate int) + func (p *LeakyBucketPacer) Write(header *rtp.Header, payload []byte, attributes interceptor.Attributes) (int, error) + type LossStats struct + AverageLoss float64 + TargetBitrate int + type NoOpPacer struct + func NewNoOpPacer() *NoOpPacer + func (p *NoOpPacer) AddStream(ssrc uint32, writer interceptor.RTPWriter) + func (p *NoOpPacer) Close() error + func (p *NoOpPacer) SetTargetBitrate(int) + func (p *NoOpPacer) Write(header *rtp.Header, payload []byte, attributes interceptor.Attributes) (int, error) + type Option func(*SendSideBWE) error + func SendSideBWEInitialBitrate(rate int) Option + func SendSideBWEMaxBitrate(rate int) Option + func SendSideBWEMinBitrate(rate int) Option + func SendSideBWEPacer(p Pacer) Option + type Pacer interface + AddStream func(ssrc uint32, writer interceptor.RTPWriter) + Close func() error + SetTargetBitrate func(int) + type SendSideBWE struct + func NewSendSideBWE(opts ...Option) (*SendSideBWE, error) + func (e *SendSideBWE) AddStream(info *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter + func (e *SendSideBWE) Close() error + func (e *SendSideBWE) GetStats() map[string]interface{} + func (e *SendSideBWE) GetTargetBitrate() int + func (e *SendSideBWE) OnTargetBitrateChange(f func(bitrate int)) + func (e *SendSideBWE) WriteRTCP(pkts []rtcp.Packet, attributes interceptor.Attributes) error + type Stats struct