buffer

package

Go to main page

Versions in this module

v1

v1.8.3

Jan 7, 2025

v1.8.2

Jan 6, 2025

v1.8.1

Jan 3, 2025

v1.8.0

Oct 19, 2024

v1.7.2

Aug 12, 2024

v1.7.1

Aug 11, 2024

Changes in this version

+ func IsRedCodec(mime string) bool

+ func IsSvcCodec(mime string) bool

type ExtPacket

+ IsOutOfOrder bool

type RTCPSenderReportData

+ Octets uint32

+ Packets uint32

type RTPStatsReceiver

+ func (r *RTPStatsReceiver) HighestTimestamp() uint32

type RTPStatsSender

+ func (r *RTPStatsSender) ExtHighestSequenceNumber() uint64

v1.7.0

Jun 25, 2024

v1.6.3

Jun 23, 2024

v1.6.2

Jun 16, 2024

Changes in this version

type RTPFlowState

+ func (r *RTPFlowState) MarshalLogObject(e zapcore.ObjectEncoder) error

type RTPStatsReceiver

+ func (r *RTPStatsReceiver) MarshalLogObject(e zapcore.ObjectEncoder) error

type RTPStatsSender

+ func (r *RTPStatsSender) MarshalLogObject(e zapcore.ObjectEncoder) error

v1.6.1

Apr 26, 2024

Changes in this version

type Buffer

+ func (b *Buffer) GetLastSenderReportTime() time.Time

type ExtPacket

+ AbsCaptureTimeExt *act.AbsCaptureTime

type RTCPSenderReportData

+ func (r *RTCPSenderReportData) PropagationDelay() time.Duration

type RTPStatsReceiver

+ func (r *RTPStatsReceiver) LastSenderReportTime() time.Time

v1.6.0

Apr 11, 2024

Changes in this version

+ const InitPacketBufferSizeAudio

+ const InitPacketBufferSizeVideo

type Buffer

+ func (b *Buffer) SetAudioLossProxying(enable bool)

type RTCPSenderReportData

+ AtAdjusted time.Time

+ func (r *RTCPSenderReportData) MarshalLogObject(e zapcore.ObjectEncoder) error

type RTPDeltaInfo

+ EndTime time.Time

type RTPStatsReceiver

+ func (r RTPStatsReceiver) CheckAndUpdatePli(throttle int64, force bool) bool

type RTPStatsSender

+ func (r RTPStatsSender) CheckAndUpdatePli(throttle int64, force bool) bool

v1.5.3

Feb 17, 2024

Changes in this version

type Buffer

+ func (b *Buffer) SetPrimaryBufferForRTX(primaryBuffer *Buffer)

+ func (b *Buffer) SetTWCCAndExtID(twcc *twcc.Responder, extID uint8)

type Factory

+ func (f *Factory) SetRTXPair(repair, base uint32)

v1.5.2

Dec 22, 2023

Changes in this version

type RTPStatsReceiver

+ func (r *RTPStatsReceiver) String() string

type RTPStatsSender

+ func (r *RTPStatsSender) String() string

v1.5.1

Nov 9, 2023

Changes in this version

+ var ErrDDStructureAttachedToNonFirstPacket = fmt.Errorf("dependency descriptor structure is attached to non-first packet of a frame")

+ var ErrFrameEarlierThanKeyFrame = fmt.Errorf("frame is earlier than current keyframe")

type DependencyDescriptorDecodeTarget

+ func (dt *DependencyDescriptorDecodeTarget) String() string

type ExtDependencyDescriptor

+ ExtKeyFrameNum uint64

type RTCPSenderReportData

+ func (r *RTCPSenderReportData) ToString() string

v1.5.0

Oct 16, 2023

Changes in this version

+ func RTPDriftToString(r *livekit.RTPDrift) string

type ExtPacket

+ ExtSequenceNumber uint64

+ ExtTimestamp uint64

type RTCPSenderReportData

+ PacketCount uint32

+ PaddingOnlyDrops uint64

type RTPFlowState

+ ExtSequenceNumber uint64

+ ExtTimestamp uint64

+ IsDuplicate bool

+ IsNotHandled bool

+ IsOutOfOrder bool

+ type RTPStatsReceiver struct

+ func NewRTPStatsReceiver(params RTPStatsParams) *RTPStatsReceiver

+ func (r *RTPStatsReceiver) DeltaInfo(snapshotID uint32) *RTPDeltaInfo

+ func (r *RTPStatsReceiver) GetRtcpReceptionReport(ssrc uint32, proxyFracLost uint8, snapshotID uint32) *rtcp.ReceptionReport

+ func (r *RTPStatsReceiver) GetRtcpSenderReportData() (srFirst *RTCPSenderReportData, srNewest *RTCPSenderReportData)

+ func (r *RTPStatsReceiver) NewSnapshotId() uint32

+ func (r *RTPStatsReceiver) SetRtcpSenderReportData(srData *RTCPSenderReportData)

+ func (r *RTPStatsReceiver) ToProto() *livekit.RTPStats

+ func (r *RTPStatsReceiver) ToString() string

+ func (r *RTPStatsReceiver) Update(packetTime time.Time, sequenceNumber uint16, timestamp uint32, marker bool, ...) (flowState RTPFlowState)

+ func (r RTPStatsReceiver) GetRtt() uint32

+ func (r RTPStatsReceiver) IsActive() bool

+ func (r RTPStatsReceiver) LastPli() time.Time

+ func (r RTPStatsReceiver) SetLogger(logger logger.Logger)

+ func (r RTPStatsReceiver) Stop()

+ func (r RTPStatsReceiver) TimeSinceLastPli() int64

+ func (r RTPStatsReceiver) UpdateFir(firCount uint32)

+ func (r RTPStatsReceiver) UpdateFirTime()

+ func (r RTPStatsReceiver) UpdateKeyFrame(kfCount uint32)

+ func (r RTPStatsReceiver) UpdateLayerLockPliAndTime(pliCount uint32)

+ func (r RTPStatsReceiver) UpdateNack(nackCount uint32)

+ func (r RTPStatsReceiver) UpdateNackProcessed(nackAckCount uint32, nackMissCount uint32, nackRepeatedCount uint32)

+ func (r RTPStatsReceiver) UpdatePli(pliCount uint32)

+ func (r RTPStatsReceiver) UpdatePliAndTime(pliCount uint32)

+ func (r RTPStatsReceiver) UpdatePliTime()

+ func (r RTPStatsReceiver) UpdateRtt(rtt uint32)

+ type RTPStatsSender struct

+ func NewRTPStatsSender(params RTPStatsParams) *RTPStatsSender

+ func (r *RTPStatsSender) DeltaInfo(snapshotID uint32) *RTPDeltaInfo

+ func (r *RTPStatsSender) DeltaInfoSender(senderSnapshotID uint32) *RTPDeltaInfo

+ func (r *RTPStatsSender) GetExpectedRTPTimestamp(at time.Time) (expectedTSExt uint64, err error)

+ func (r *RTPStatsSender) GetRtcpSenderReport(ssrc uint32, calculatedClockRate uint32) *rtcp.SenderReport

+ func (r *RTPStatsSender) GetTotalPacketsPrimary() uint64

+ func (r *RTPStatsSender) LastReceiverReportTime() time.Time

+ func (r *RTPStatsSender) MaybeAdjustFirstPacketTime(ets uint64)

+ func (r *RTPStatsSender) NewSenderSnapshotId() uint32

+ func (r *RTPStatsSender) NewSnapshotId() uint32

+ func (r *RTPStatsSender) Seed(from *RTPStatsSender)

+ func (r *RTPStatsSender) ToProto() *livekit.RTPStats

+ func (r *RTPStatsSender) ToString() string

+ func (r *RTPStatsSender) Update(packetTime time.Time, extSequenceNumber uint64, extTimestamp uint64, ...)

+ func (r *RTPStatsSender) UpdateFromReceiverReport(rr rtcp.ReceptionReport) (rtt uint32, isRttChanged bool)

+ func (r RTPStatsSender) GetRtt() uint32

+ func (r RTPStatsSender) IsActive() bool

+ func (r RTPStatsSender) LastPli() time.Time

+ func (r RTPStatsSender) SetLogger(logger logger.Logger)

+ func (r RTPStatsSender) Stop()

+ func (r RTPStatsSender) TimeSinceLastPli() int64

+ func (r RTPStatsSender) UpdateFir(firCount uint32)

+ func (r RTPStatsSender) UpdateFirTime()

+ func (r RTPStatsSender) UpdateKeyFrame(kfCount uint32)

+ func (r RTPStatsSender) UpdateLayerLockPliAndTime(pliCount uint32)

+ func (r RTPStatsSender) UpdateNack(nackCount uint32)

+ func (r RTPStatsSender) UpdateNackProcessed(nackAckCount uint32, nackMissCount uint32, nackRepeatedCount uint32)

+ func (r RTPStatsSender) UpdatePli(pliCount uint32)

+ func (r RTPStatsSender) UpdatePliAndTime(pliCount uint32)

+ func (r RTPStatsSender) UpdatePliTime()

+ func (r RTPStatsSender) UpdateRtt(rtt uint32)

v1.4.5

Aug 23, 2023

Changes in this version

type ExtDependencyDescriptor

+ ExtFrameNum uint64

+ Integrity bool

+ type FrameEntity struct

+ func (fe *FrameEntity) AddPacket(extSeq uint64, ddVal *dd.DependencyDescriptor)

+ func (fe *FrameEntity) Integrity() bool

+ func (fe *FrameEntity) Reset()

+ type FrameIntegrityChecker struct

+ func NewFrameIntegrityChecker(frameCount, packetCount int) *FrameIntegrityChecker

+ func (fc *FrameIntegrityChecker) AddPacket(extSeq uint64, extFrameNum uint64, ddVal *dd.DependencyDescriptor)

+ func (fc *FrameIntegrityChecker) FrameIntegrity(extFrameNum uint64) bool

+ type PacketHistory struct

+ func NewPacketHistory(packetCount int) *PacketHistory

+ func (ph *PacketHistory) AddPacket(extSeq uint64)

+ func (ph *PacketHistory) PacketsConsecutive(start, end uint64) bool

type RTPStats

+ func (r *RTPStats) MaybeAdjustFirstPacketTime(srData *RTCPSenderReportData)

v1.4.4

Jul 9, 2023

Changes in this version

+ type ExtDependencyDescriptor struct

+ ActiveDecodeTargetsUpdated bool

+ DecodeTargets []DependencyDescriptorDecodeTarget

+ Descriptor *dd.DependencyDescriptor

+ StructureUpdated bool

type RTPDeltaInfo

+ PacketsOutOfOrder uint32

v1.4.3

Jun 4, 2023

Changes in this version

+ const MeasurementWindowSecondsMin

type RTCPSenderReportData

+ At time.Time

+ RTPTimestampExt uint64

v1.4.2

May 10, 2023

Changes in this version

+ var DefaultMaxLayer = VideoLayer

+ var InvalidLayer = VideoLayer

+ func GetActiveDecodeTargetBitmask(layer VideoLayer, decodeTargets []DependencyDescriptorDecodeTarget) *uint32

+ func IsAV1KeyFrame(payload []byte) bool

+ func IsH264KeyFrame(payload []byte) bool

+ func IsVP9KeyFrame(payload []byte) bool

+ func VPxPictureIdSizeDiff(mBit1 bool, mBit2 bool) int

+ type DependencyDescriptorDecodeTarget struct

+ Layer VideoLayer

+ Target int

+ func ProcessFrameDependencyStructure(structure *dd.FrameDependencyStructure) []DependencyDescriptorDecodeTarget

+ type DependencyDescriptorWithDecodeTarget struct

+ DecodeTargets []DependencyDescriptorDecodeTarget

+ Descriptor *dd.DependencyDescriptor

+ type FrameRateCalculatorForVP9Layer struct

+ func (f *FrameRateCalculatorForVP9Layer) GetFrameRate() []float32

+ type FrameRateCalculatorVP9 struct

+ func NewFrameRateCalculatorVP9(clockRate uint32, logger logger.Logger) *FrameRateCalculatorVP9

+ func (f *FrameRateCalculatorVP9) Completed() bool

+ func (f *FrameRateCalculatorVP9) GetFrameRateCalculatorForSpatial(spatial int32) *FrameRateCalculatorForVP9Layer

+ func (f *FrameRateCalculatorVP9) GetFrameRateForSpatial(spatial int32) []float32

+ func (f *FrameRateCalculatorVP9) RecvPacket(ep *ExtPacket) bool

+ type PIDController struct

+ func NewPIDController(logger logger.Logger) *PIDController

+ func (p *PIDController) SetDerivativeLPF(tau float64)

+ func (p *PIDController) SetGains(kp, ki, kd float64)

+ func (p *PIDController) SetIntegralLimits(min, max float64)

+ func (p *PIDController) SetLogger(logger logger.Logger)

+ func (p *PIDController) SetOutputLimits(min, max float64)

+ func (p *PIDController) Update(setpoint, measurement float64, at time.Time) float64

type RTPStats

+ func (r *RTPStats) DeltaInfoOverridden(snapshotId uint32) *RTPDeltaInfo

+ func (r *RTPStats) GetExpectedRTPTimestamp(at time.Time) (uint32, error)

+ func (r *RTPStats) LastReceiverReport() time.Time

type VP8

+ I bool

+ K bool

+ L bool

+ M bool

+ S bool

+ T bool

+ func (v *VP8) Marshal() ([]byte, error)

v1.4.1

Apr 6, 2023

v1.4.0

Mar 31, 2023

Changes in this version

+ const TooLargeOWDDelta

+ var DefaultMaxLayers = VideoLayer

type Buffer

+ func (b *Buffer) OnFinalRtpStats(fn func(*RTPStats))

type RTPDeltaInfo

+ PacketsMissing uint32

+ StartTime time.Time

+ func AggregateRTPDeltaInfo(deltaInfoList []*RTPDeltaInfo) *RTPDeltaInfo

v1.3.5

Feb 26, 2023

v1.3.4

Feb 10, 2023

Changes in this version

+ const TooLargeOWD

type Buffer

+ func (b *Buffer) GetSenderReportDataExt() *RTCPSenderReportDataExt

+ type RTCPSenderReportDataExt struct

+ SenderReportData RTCPSenderReportData

+ SmoothedOWD time.Duration

type RTPStats

+ func (r *RTPStats) GetRtcpSenderReportDataExt() *RTCPSenderReportDataExt

v1.3.3

Jan 8, 2023

Changes in this version

type Buffer

+ func (b *Buffer) OnRtcpSenderReport(fn func(srData *RTCPSenderReportData))

+ func (b *Buffer) SetPaused(paused bool)

+ type RTCPSenderReportData struct

+ ArrivalTime time.Time

+ NTPTimestamp mediatransportutil.NtpTime

+ RTPTimestamp uint32

type RTPStats

+ func (r *RTPStats) GetRtcpSenderReportData() *RTCPSenderReportData

v1.3.2

Dec 16, 2022

Changes in this version

+ type FactoryOfBufferFactory struct

+ func NewFactoryOfBufferFactory(trackingPackets int) *FactoryOfBufferFactory

+ func (f *FactoryOfBufferFactory) CreateBufferFactory() *Factory

v1.3.1

Nov 9, 2022

v1.3.0

Nov 8, 2022

Changes in this version

type Buffer

+ func (b *Buffer) GetTemporalLayerFpsForSpatial(layer int32) []float32

+ func (b *Buffer) OnFpsChanged(f func())

+ type FrameRateCalculator interface

+ Completed func() bool

+ GetFrameRate func() []float32

+ RecvPacket func(ep *ExtPacket) bool

+ type FrameRateCalculatorDD struct

+ func NewFrameRateCalculatorDD(clockRate uint32, logger logger.Logger) *FrameRateCalculatorDD

+ func (f *FrameRateCalculatorDD) Completed() bool

+ func (f *FrameRateCalculatorDD) GetFrameRateCalculatorForSpatial(spatial int32) *FrameRateCalculatorForDDLayer

+ func (f *FrameRateCalculatorDD) GetFrameRateForSpatial(spatial int32) []float32

+ func (f *FrameRateCalculatorDD) RecvPacket(ep *ExtPacket) bool

+ func (f *FrameRateCalculatorDD) SetMaxLayer(spatial, temporal int32)

+ type FrameRateCalculatorForDDLayer struct

+ func (f *FrameRateCalculatorForDDLayer) GetFrameRate() []float32

+ type FrameRateCalculatorVP8 struct

+ func NewFrameRateCalculatorVP8(clockRate uint32, logger logger.Logger) *FrameRateCalculatorVP8

+ func (f *FrameRateCalculatorVP8) Completed() bool

+ func (f *FrameRateCalculatorVP8) GetFrameRate() []float32

+ func (f *FrameRateCalculatorVP8) RecvPacket(ep *ExtPacket) bool

v1.2.5

Oct 20, 2022

v1.2.4

Oct 13, 2022

Changes in this version

type RTPStats

+ func (r *RTPStats) Seed(from *RTPStats)

v1.2.3

Sep 27, 2022

v1.2.2

Sep 26, 2022

v1.2.1

Sep 13, 2022

Changes in this version

+ const FullResolution

+ const HalfResolution

+ const QuarterResolution

+ func LayerPresenceFromTrackInfo(trackInfo *livekit.TrackInfo) *[livekit.VideoQuality_HIGH + 1]bool

+ func RidToSpatialLayer(rid string, trackInfo *livekit.TrackInfo) int32

+ func SpatialLayerToRid(layer int32, trackInfo *livekit.TrackInfo) string

+ func SpatialLayerToVideoQuality(layer int32, trackInfo *livekit.TrackInfo) livekit.VideoQuality

+ func VideoQualityToRid(quality livekit.VideoQuality, trackInfo *livekit.TrackInfo) string

+ func VideoQualityToSpatialLayer(quality livekit.VideoQuality, trackInfo *livekit.TrackInfo) int32

type Bucket

+ func (b *Bucket) ResyncOnNextPacket()

type RTPStats

+ func (r *RTPStats) ResyncOnNextPacket()

v1.2.0

Aug 26, 2022

Changes in this version

+ type IntervalStats struct

type RTPDeltaInfo

+ HeaderBytes uint64

+ HeaderBytesDuplicate uint64

+ HeaderBytesPadding uint64

type RTPStats

+ func (r *RTPStats) ForceUpdateLastPacket(rtph *rtp.Header, packetTime int64)

v1.1.2

Jul 11, 2022

v1.1.1

Jul 8, 2022

v1.1.0

Jun 22, 2022

Changes in this version

type RTPDeltaInfo

+ Duration time.Duration

v1.0.2

May 28, 2022

v1.0.1

May 19, 2022

v1.0.0

May 18, 2022

Changes in this version

+ const DefaultMaxLayerSpatial

+ const DefaultMaxLayerTemporal

+ const InvalidLayerSpatial

+ const InvalidLayerTemporal

+ var InvalidLayers = VideoLayer

type Buffer

+ func (b *Buffer) OnMaxLayerChanged(fn func(int32, int32))

+ type DependencyDescriptorParser struct

+ func NewDependencyDescriptorParser(ddExt uint8, logger logger.Logger, onMaxLayerChanged func(int32, int32)) *DependencyDescriptorParser

+ func (r *DependencyDescriptorParser) Parse(pkt *rtp.Packet) (*dd.DependencyDescriptor, VideoLayer, error)

type ExtPacket

+ DependencyDescriptor *dd.DependencyDescriptor

type RTPStats

+ func (r *RTPStats) UpdateNackProcessed(nackAckCount uint32, nackMissCount uint32, nackRepeatedCount uint32)

+ type VideoLayer struct

+ Spatial int32

+ Temporal int32

+ func (v VideoLayer) GreaterThan(v2 VideoLayer) bool

+ func (v VideoLayer) IsValid() bool

+ func (v VideoLayer) SpatialGreaterThanOrEqual(v2 VideoLayer) bool

+ func (v VideoLayer) String() string

v0

v0.15.7

May 1, 2022

Changes in this version

+ const FirstSnapshotId

+ const SnInfoMask

+ const SnInfoSize

+ func IsAV1Keyframe(payload []byte) bool

+ func IsVp9Keyframe(payload []byte) bool

type Buffer

+ func (b *Buffer) GetAudioLevel() (float64, bool)

+ func (b *Buffer) GetDeltaStats() *StreamStatsWithLayers

+ func (b *Buffer) OnRtcpFeedback(fn func(fb []rtcp.Packet))

+ func (b *Buffer) SetAudioLevelParams(audioLevelParams audio.AudioLevelParams)

+ func (b *Buffer) SetTWCC(twcc *twcc.Responder)

type LayerStats

+ Bytes uint64

+ Frames uint32

+ Packets uint32

+ type RTPDeltaInfo struct

+ Bytes uint64

+ BytesDuplicate uint64

+ BytesPadding uint64

+ Firs uint32

+ Frames uint32

+ JitterMax float64

+ Nacks uint32

+ Packets uint32

+ PacketsDuplicate uint32

+ PacketsLost uint32

+ PacketsPadding uint32

+ Plis uint32

+ RttMax uint32

type RTPSnapshotInfo

+ JitterMax float64

+ RttMax uint32

type RTPStats

+ func (r *RTPStats) DeltaInfo(snapshotId uint32) *RTPDeltaInfo

+ func (r *RTPStats) UpdateFromReceiverReport(extHighestSN uint32, packetsLost uint32, rtt uint32, jitter float64)

type RTPStatsParams

+ IsReceiverReportDriven bool

+ type SnInfo struct

v0.15.6

Mar 28, 2022

Changes in this version

+ const GapHistogramNumBins

+ const NumSequenceNumbers

+ const SequenceNumberMax

+ const SequenceNumberMin

+ func AggregateRTPStats(statses []*livekit.RTPStats) *livekit.RTPStats

type Buffer

+ func (b *Buffer) GetQualityInfo() *RTPSnapshotInfo

+ type ConnectionQualityParams struct

+ Jitter float32

+ LossPercentage float32

+ Rtt uint32

+ type DataStats struct

+ func NewDataStats(params DataStatsParam) *DataStats

+ func (s *DataStats) Stop()

+ func (s *DataStats) ToProtoActive() *livekit.RTPStats

+ func (s *DataStats) ToProtoAggregateOnly() *livekit.RTPStats

+ func (s *DataStats) Update(bytes int, time int64)

+ type DataStatsParam struct

+ WindowDuration time.Duration

type ExtPacket

+ SpatialLayer int32

+ TemporalLayer int32

+ type NtpTime uint64

+ func ToNtpTime(t time.Time) NtpTime

+ func (t NtpTime) Duration() time.Duration

+ func (t NtpTime) Time() time.Time

+ type RTPFlowState struct

+ HasLoss bool

+ IsHighestSN bool

+ LossEndExclusive uint16

+ LossStartInclusive uint16

+ type RTPSnapshotInfo struct

+ MaxJitter float64

+ MaxRtt uint32

+ PacketsExpected uint32

+ PacketsLost uint32

+ type RTPStats struct

+ func NewRTPStats(params RTPStatsParams) *RTPStats

+ func (r *RTPStats) GetRtcpSenderReport(ssrc uint32) *rtcp.SenderReport

+ func (r *RTPStats) GetRtt() uint32

+ func (r *RTPStats) GetTotalPacketsPrimary() uint32

+ func (r *RTPStats) IsActive() bool

+ func (r *RTPStats) LastPli() time.Time

+ func (r *RTPStats) NewSnapshotId() uint32

+ func (r *RTPStats) SetLogger(logger logger.Logger)

+ func (r *RTPStats) SetRtcpSenderReportData(rtpTS uint32, ntpTS NtpTime, arrival time.Time)

+ func (r *RTPStats) SnapshotInfo(snapshotId uint32) *RTPSnapshotInfo

+ func (r *RTPStats) SnapshotRtcpReceptionReport(ssrc uint32, proxyFracLost uint8, snapshotId uint32) *rtcp.ReceptionReport

+ func (r *RTPStats) Stop()

+ func (r *RTPStats) TimeSinceLastPli() int64

+ func (r *RTPStats) ToProto() *livekit.RTPStats

+ func (r *RTPStats) ToString() string

+ func (r *RTPStats) Update(rtph *rtp.Header, payloadSize int, paddingSize int, packetTime int64) (flowState RTPFlowState)

+ func (r *RTPStats) UpdateFir(firCount uint32)

+ func (r *RTPStats) UpdateFirTime()

+ func (r *RTPStats) UpdateJitter(jitter float64)

+ func (r *RTPStats) UpdateKeyFrame(kfCount uint32)

+ func (r *RTPStats) UpdateLayerLockPliAndTime(pliCount uint32)

+ func (r *RTPStats) UpdateNack(nackCount uint32)

+ func (r *RTPStats) UpdateNackAndMiss(nackCount uint32, nackMissCount uint32)

+ func (r *RTPStats) UpdateNackMiss(nackMissCount uint32)

+ func (r *RTPStats) UpdatePacketsLost(packetsLost uint32)

+ func (r *RTPStats) UpdatePli(pliCount uint32)

+ func (r *RTPStats) UpdatePliAndTime(pliCount uint32)

+ func (r *RTPStats) UpdatePliTime()

+ func (r *RTPStats) UpdateRtt(rtt uint32)

+ type RTPStatsParams struct

+ ClockRate uint32

+ Logger logger.Logger

+ type Snapshot struct

type StreamStatsWithLayers

+ RTPStats *livekit.RTPStats

v0.15.5

Feb 28, 2022

v0.15.4

Feb 9, 2022

Changes in this version

type Buffer

+ func (b *Buffer) SendPLI()

+ func (b *Buffer) SetLogger(logger logger.Logger)

+ func (b *Buffer) SetPLIThrottle(duration int64)

+ func (b *Buffer) SetRTT(rtt uint32)

+ type LayerStats struct

+ TotalBytes uint64

+ TotalFrames uint32

+ TotalPackets uint32

type NackQueue

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

+ type StreamStats struct

+ Jitter float64

+ RTT uint32

+ TotalFIRs uint32

+ TotalFrames uint32

+ TotalNACKs uint32

+ TotalPLIs uint32

+ TotalPacketsLost uint32

+ TotalPaddingBytes uint64

+ TotalPaddingPackets uint32

+ TotalPrimaryBytes uint64

+ TotalPrimaryPackets uint32

+ TotalRetransmitBytes uint64

+ TotalRetransmitPackets uint32

+ type StreamStatsWithLayers struct

+ Layers map[int]LayerStats

+ StreamStats StreamStats

v0.15.3

Jan 29, 2022

Changes in this version

type Stats

+ TotalBytes uint64

v0.15.2

Jan 6, 2022

Changes in this version

type Buffer

+ func (b *Buffer) SetStatsTestOnly(stats Stats)

v0.15.1

Dec 22, 2021

v0.15.0

Dec 22, 2021

Changes in this version

+ const ReportDelta

+ var ErrBufferTooSmall = errors.New("buffer too small")

+ var ErrPacketNotFound = errors.New("packet not found in cache")

+ var ErrPacketTooOld = errors.New("received packet too old")

+ var ErrRTXPacket = errors.New("packet already received")

+ func IsH264Keyframe(payload []byte) bool

+ func IsNewerUint16(val1, val2 uint16) bool

type ExtPacket

+ AudioLevel uint8

+ RawPacket []byte

+ type NackQueue struct

+ func NewNACKQueue() *NackQueue

+ func (n *NackQueue) Pairs(headSN uint32) ([]rtcp.NackPair, bool)

+ func (n *NackQueue) Push(extSN uint32)

+ func (n *NackQueue) Remove(extSN uint32)

v0.14.2

Nov 19, 2021

v0.14.1

Nov 11, 2021

Changes in this version

+ const MaxSN

+ var Logger logr.Logger = logr.Discard()

+ func IsLaterTimestamp(timestamp1 uint32, timestamp2 uint32) bool

+ func IsTimestampWrapAround(timestamp1 uint32, timestamp2 uint32) bool

+ func VP8PictureIdSizeDiff(mBit1 bool, mBit2 bool) int

+ 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) BitrateTemporal() []uint64

+ func (b *Buffer) BitrateTemporalCumulative() []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) SetLastFractionLostReport(lost uint8)

+ 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 SeqWrapHandler struct

+ func (s *SeqWrapHandler) Cycles() uint32

+ func (s *SeqWrapHandler) MaxSeqNo() uint32

+ func (s *SeqWrapHandler) Unwrap(seq uint16) (uint32, bool)

+ func (s *SeqWrapHandler) UpdateMaxSeq(extSeq uint32)

+ type Stats struct

+ Jitter float64

+ LastExpected uint32

+ LastReceived uint32

+ LostRate float32

+ PacketCount uint32

+ TotalByte uint64

+ type VP8 struct

+ FirstByte byte

+ HeaderSize int

+ IsKeyFrame bool

+ KEYIDX uint8

+ KEYIDXPresent int

+ MBit bool

+ PicIDIdx int

+ PictureID uint16

+ PictureIDPresent int

+ TID uint8

+ TIDPresent int

+ TL0PICIDX uint8

+ TL0PICIDXPresent int

+ TemporalSupported bool

+ TlzIdx int

+ Y uint8

+ func (p *VP8) Unmarshal(payload []byte) error

+ func (v *VP8) MarshalTo(buf []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL