interceptor

Jan 17, 2024

Changes in this version

+ type RTTInterceptor struct

+ func NewRTTInterceptor(onRttUpdate func(rtt uint32)) *RTTInterceptor

+ func (r *RTTInterceptor) BindRTCPReader(reader interceptor.RTCPReader) interceptor.RTCPReader

+ type RTTInterceptorFactory struct

+ func NewRTTInterceptorFactory(onRttUpdate func(rtt uint32)) *RTTInterceptorFactory

+ func (r *RTTInterceptorFactory) NewInterceptor(_ string) (interceptor.Interceptor, error)

Dec 11, 2023

Changes in this version

+ const MaxPayloadSize

+ var ErrPayloadSizeTooLarge = fmt.Errorf("packetization payload size should not greater than %d bytes", MaxPayloadSize)

+ type LimitSizeInterceptor struct

+ func (l *LimitSizeInterceptor) BindLocalStream(stream *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter

+ type LimitSizeInterceptorFactory struct

+ func NewLimitSizeInterceptorFactory() *LimitSizeInterceptorFactory

+ func (l *LimitSizeInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error)

Nov 30, 2023

Changes in this version

+ type PacerInterceptor struct

+ func (pi *PacerInterceptor) BindLocalStream(stream *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter

+ func (pi *PacerInterceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter

+ func (pi *PacerInterceptor) Close() error

+ type PacerInterceptorFactory struct

+ func NewPacerInterceptorFactory(pacer pacer.Factory) *PacerInterceptorFactory

+ func (p *PacerInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error)

+ type PacketPool struct

+ func NewPacketPool(size ...int) *PacketPool

+ func (p *PacketPool) Get(size int) (*[]byte, *sync.Pool)

Sep 22, 2022

Changes in this version

+ type NackGeneratorInterceptor struct

+ func NewNackGeneratorInterceptor() (*NackGeneratorInterceptor, error)

+ func (n *NackGeneratorInterceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter

+ func (n *NackGeneratorInterceptor) BindRemoteStream(info *interceptor.StreamInfo, reader interceptor.RTPReader) interceptor.RTPReader

+ func (n *NackGeneratorInterceptor) SetRTT(rtt uint32)

+ func (n *NackGeneratorInterceptor) UnbindRemoteStream(info *interceptor.StreamInfo)

+ type NackGeneratorInterceptorFactory struct

+ func (g *NackGeneratorInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error)

+ func (g *NackGeneratorInterceptorFactory) SetRTT(rtt uint32)