Versions in this module Expand all Collapse all v1 v1.10.11 Aug 7, 2021 Changes in this version + var Logger logr.Logger = logr.Discard() + func IsLaterTimestamp(timestamp1 uint32, timestamp2 uint32) bool + func IsTimestampWrapAround(timestamp1 uint32, timestamp2 uint32) bool + type Bucket struct + func NewBucket(buf []byte) *Bucket + func (b *Bucket) AddPacket(pkt []byte, sn uint16, latest bool) ([]byte, error) + func (b *Bucket) GetPacket(buf []byte, sn uint16) (i int, err error) + type Buffer struct + func NewBuffer(ssrc uint32, vp, ap *sync.Pool, logger logr.Logger) *Buffer + func (b *Buffer) Bind(params webrtc.RTPParameters, o Options) + func (b *Buffer) Bitrate() uint64 + func (b *Buffer) Close() error + func (b *Buffer) GetClockRate() uint32 + func (b *Buffer) GetLatestTimestamp() (latestTimestamp uint32, latestTimestampTimeInNanosSinceEpoch int64) + func (b *Buffer) GetMediaSSRC() uint32 + func (b *Buffer) GetPacket(buff []byte, sn uint16) (int, error) + func (b *Buffer) GetSenderReportData() (rtpTime uint32, ntpTime uint64, lastReceivedTimeInNanosSinceEpoch int64) + func (b *Buffer) GetStats() (stats Stats) + func (b *Buffer) MaxTemporalLayer() int32 + func (b *Buffer) OnAudioLevel(fn func(level uint8)) + func (b *Buffer) OnClose(fn func()) + func (b *Buffer) OnFeedback(fn func(fb []rtcp.Packet)) + func (b *Buffer) OnTransportWideCC(fn func(sn uint16, timeNS int64, marker bool)) + func (b *Buffer) Read(buff []byte) (n int, err error) + func (b *Buffer) ReadExtended() (*ExtPacket, error) + func (b *Buffer) SetSenderReportData(rtpTime uint32, ntpTime uint64) + func (b *Buffer) Write(pkt []byte) (n int, err error) + type ExtPacket struct + Arrival int64 + Cycle uint32 + Head bool + KeyFrame bool + Packet rtp.Packet + Payload interface{} + type Factory struct + func NewBufferFactory(trackingPackets int, logger logr.Logger) *Factory + func (f *Factory) GetBuffer(ssrc uint32) *Buffer + func (f *Factory) GetBufferPair(ssrc uint32) (*Buffer, *RTCPReader) + func (f *Factory) GetOrNew(packetType packetio.BufferPacketType, ssrc uint32) io.ReadWriteCloser + func (f *Factory) GetRTCPReader(ssrc uint32) *RTCPReader + type Options struct + MaxBitRate uint64 + type RTCPReader struct + func NewRTCPReader(ssrc uint32) *RTCPReader + func (r *RTCPReader) Close() error + func (r *RTCPReader) OnClose(fn func()) + func (r *RTCPReader) OnPacket(f func([]byte)) + func (r *RTCPReader) Read(_ []byte) (n int, err error) + func (r *RTCPReader) Write(p []byte) (n int, err error) + type Stats struct + Jitter float64 + LastExpected uint32 + LastReceived uint32 + LostRate float32 + PacketCount uint32 + TotalByte uint64 + type VP8 struct + IsKeyFrame bool + MBit bool + PicIDIdx int + PictureID uint16 + TID uint8 + TL0PICIDX uint8 + TemporalSupported bool + TlzIdx int + func (p *VP8) Unmarshal(payload []byte) error