sfu

Jan 3, 2025

Changes in this version

+ var DefaultAudioConfig = AudioConfig

+ var DefaultPLIThrottleConfig = PLIThrottleConfig

+ var DefaultStreamTrackerConfigScreenshare = StreamTrackerConfig

+ var DefaultStreamTrackerConfigVideo = StreamTrackerConfig

+ var DefaultStreamTrackerManagerConfig = StreamTrackerManagerConfig

+ type AudioConfig struct

+ ActiveREDEncoding bool

+ EnableLossProxying bool

type DownTrack

+ func (d *DownTrack) GetPrimaryStreamLastReceiverReportTime() time.Time

+ func (d *DownTrack) GetPrimaryStreamPacketsSent() uint64

+ func (d *DownTrack) SSRCRTX() uint32

+ func (d *DownTrack) SetProbeClusterId(probeClusterId ccutils.ProbeClusterId)

+ func (d *DownTrack) SwapProbeClusterId(match ccutils.ProbeClusterId, swap ccutils.ProbeClusterId)

+ func (d *DownTrack) WriteProbePackets(bytesToSend int, usePadding bool) int

type DownTrackState

+ DeltaStatsRTXSenderSnapshotId uint32

+ PlayoutDelayControllerState PlayoutDelayControllerState

+ RTPStatsRTX *rtpstats.RTPStatsSender

+ type PLIThrottleConfig struct

+ HighQuality time.Duration

+ LowQuality time.Duration

+ MidQuality time.Duration

type PlayoutDelayController

+ func (c *PlayoutDelayController) GetState() PlayoutDelayControllerState

+ func (c *PlayoutDelayController) SeedState(pdcs PlayoutDelayControllerState)

+ type PlayoutDelayControllerState struct

+ SenderSnapshotID uint32

+ func (p PlayoutDelayControllerState) MarshalLogObject(e zapcore.ObjectEncoder) error

type RedPrimaryReceiver

+ func (r *RedPrimaryReceiver) ResyncDownTracks()

type RedReceiver

+ func (r *RedReceiver) ResyncDownTracks()

+ type StreamTrackerConfig struct

+ BitrateReportInterval map[int32]time.Duration

+ FrameTracker map[int32]streamtracker.StreamTrackerFrameConfig

+ PacketTracker map[int32]streamtracker.StreamTrackerPacketConfig

+ StreamTrackerType StreamTrackerType

+ type StreamTrackerFrameConfig struct

+ MinFPS float64

+ type StreamTrackerManagerConfig struct

+ Screenshare StreamTrackerConfig

+ Video StreamTrackerConfig

+ type StreamTrackerPacketConfig struct

+ CycleDuration time.Duration

+ CyclesRequired uint32

+ SamplesRequired uint32

+ type StreamTrackerType string

+ const StreamTrackerTypeFrame

+ const StreamTrackerTypePacket

+ type TrackRemote interface

+ Codec func() webrtc.RTPCodecParameters

+ ID func() string

+ Kind func() webrtc.RTPCodecType

+ Msid func() string

+ RID func() string

+ SSRC func() webrtc.SSRC

+ StreamID func() string

+ type TrackRemoteFromSdp struct

+ func NewTrackRemoteFromSdp(track *webrtc.TrackRemote, codec webrtc.RTPCodecParameters) *TrackRemoteFromSdp

+ func (t *TrackRemoteFromSdp) Codec() webrtc.RTPCodecParameters

Oct 19, 2024

Changes in this version

type DownTrack

+ func (d *DownTrack) OnCodecNegotiated(f func(webrtc.RTPCodecCapability))

type DownTrackState

+ func (d DownTrackState) MarshalLogObject(e zapcore.ObjectEncoder) error

type TrackReceiver

+ AddOnReady func(func())

type WebRTCReceiver

+ func (w *WebRTCReceiver) AddOnReady(fn func())

Aug 11, 2024

Changes in this version

type DownTrack

+ func (d *DownTrack) StopWriteAndGetState() DownTrackState

type DowntrackParams

+ DisableSenderReportPassThrough bool

type RTPMunger

+ func (r *RTPMunger) GetState() *livekit.RTPMungerState

+ func (r *RTPMunger) SeedState(state *livekit.RTPMungerState)

Jun 16, 2024

Changes in this version

+ type ForwardStats struct

+ func NewForwardStats(latencyUpdateInterval, reportInterval, latencyWindowLength time.Duration) *ForwardStats

+ func (s *ForwardStats) GetLastStats(duration time.Duration) (latency, jitter time.Duration)

+ func (s *ForwardStats) GetStats() (latency, jitter time.Duration)

+ func (s *ForwardStats) Stop()

+ func (s *ForwardStats) Update(arrival, left time.Time)

type ForwarderState

+ DummyStartTSOffset uint64

type RTPMunger

+ func (r *RTPMunger) GetTSOffset() uint64

type ReceiverOpts

+ func WithForwardStats(forwardStats *ForwardStats) ReceiverOpts

type TrackSender

+ Resync func()

Apr 26, 2024

Changes in this version

type DowntrackParams

+ Source livekit.TrackSource

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetLastSenderReportTime() time.Time

Apr 11, 2024

Changes in this version

+ const ResumeBehindHighThresholdSeconds

+ var ErrPayloadOverflow = errors.New("payload overflow")

type DowntrackParams

+ RTCPWriter func([]rtcp.Packet) error

type Forwarder

+ func (f *Forwarder) GetSenderReportParams() (int32, uint64, *buffer.RTCPSenderReportData)

+ func (f *Forwarder) SetRefSenderReport(isSVC bool, layer int32, srData *buffer.RTCPSenderReportData)

+ func (f *Forwarder) TranslateCodecHeader(extPkt *buffer.ExtPacket, tpr *TranslationParamsRTP, outputBuffer []byte) (bool, int, int, error)

type RTPMunger

+ func (r *RTPMunger) GetPinnedTSOffset() uint64

type VideoAllocation

+ func (v *VideoAllocation) MarshalLogObject(e zapcore.ObjectEncoder) error

type VideoTransition

+ func (v *VideoTransition) MarshalLogObject(e zapcore.ObjectEncoder) error

Feb 17, 2024

Changes in this version

+ var ErrDuplicateLayer = errors.New("duplicate layer")

+ type PlayoutDelayController struct

+ func NewPlayoutDelayController(minDelay, maxDelay uint32, logger logger.Logger, ...) (*PlayoutDelayController, error)

+ func (c *PlayoutDelayController) GetDelayExtension(seq uint16) []byte

+ func (c *PlayoutDelayController) OnSeqAcked(seq uint16)

+ func (c *PlayoutDelayController) SetJitter(jitter uint32)

+ type PlayoutDelayState int32

+ const PlayoutDelayAcked

+ const PlayoutDelaySending

+ const PlayoutDelayStateChanged

+ func (s PlayoutDelayState) String() string

Dec 22, 2023

Changes in this version

type StreamTrackerManager

+ func (s *StreamTrackerManager) UpdateTrackInfo(ti *livekit.TrackInfo)

type TrackReceiver

+ GetTrackStats func() *livekit.RTPStats

+ UpdateTrackInfo func(ti *livekit.TrackInfo)

type WebRTCReceiver

+ func (w *WebRTCReceiver) UpdateTrackInfo(ti *livekit.TrackInfo)

Nov 9, 2023

Changes in this version

+ const FlagFilterRTXLayers

+ const ResumeBehindHighTresholdSeconds

type RTPMungerState

+ ExtSecondLastTS uint64

+ LastMarker bool

+ SecondLastMarker bool

Oct 16, 2023

Changes in this version

+ var ErrSequenceNumberOffsetNotFound = errors.New("sequence number offset not found")

type DownTrack

+ func (d *DownTrack) GetDeltaStatsSender() map[uint32]*buffer.StreamStatsWithLayers

+ func (d *DownTrack) GetLastReceiverReportTime() time.Time

+ func (d *DownTrack) GetTotalPacketsSent() uint64

type DownTrackState

+ DeltaStatsSenderSnapshotId uint32

type DownTrackStreamAllocatorListener

+ IsBWEEnabled func(dt *DownTrack) bool

+ IsSubscribeMutable func(dt *DownTrack) bool

type Forwarder

+ func (f *Forwarder) GetReferenceTimestampOffset() uint64

+ func (f *Forwarder) RTPMungerDebugInfo() map[string]interface{}

type ForwarderState

+ ExtFirstTS uint64

type RTPMunger

+ func (r *RTPMunger) DebugInfo() map[string]interface{}

type RTPMungerState

+ ExtLastSN uint64

+ ExtLastTS uint64

+ ExtSecondLastSN uint64

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetDeltaStats() map[uint32]*buffer.StreamStatsWithLayers

Aug 23, 2023

Changes in this version

+ const LayerSwitchBehindThresholdSeconds

+ const ResumeBehindThresholdSeconds

+ const SwitchAheadThresholdSeconds

type DownTrack

+ func (d *DownTrack) ProvisionalAllocateReset()

+ type DowntrackParams struct

+ BufferFactory *buffer.Factory

+ Codecs []webrtc.RTPCodecParameters

+ Logger logger.Logger

+ MaxTrack int

+ Pacer pacer.Pacer

+ PlayoutDelayLimit *livekit.PlayoutDelay

+ Receiver TrackReceiver

+ StreamID string

+ SubID livekit.ParticipantID

+ Trailer []byte

type Forwarder

+ func (f *Forwarder) GetMaxSubscribedSpatial() int32

+ func (f *Forwarder) PauseReason() VideoPauseReason

+ func (f *Forwarder) ProvisionalAllocateReset()

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetCalculatedClockRate(layer int32) uint32

type TrackReceiver

+ GetCalculatedClockRate func(layer int32) uint32

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetCalculatedClockRate(layer int32) uint32

Jul 9, 2023

Changes in this version

type StreamTrackerManager

+ func (s *StreamTrackerManager) AddDependencyDescriptorTrackers()

Jun 4, 2023

Changes in this version

type ForwarderState

+ FirstTS uint32

+ PreStartTime time.Time

+ RefTSOffset uint32

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetRTCPSenderReportData(layer int32) (*buffer.RTCPSenderReportData, *buffer.RTCPSenderReportData)

May 10, 2023

Changes in this version

+ const ParkedLayerWaitDuration

type DownTrack

+ func (d *DownTrack) GetAndResetBytesSent() (uint32, uint32)

+ func (d *DownTrack) MaxLayer() buffer.VideoLayer

type DownTrackState

+ DeltaStatsOverriddenSnapshotId uint32

type DownTrackStreamAllocatorListener

+ OnMaxPublishedSpatialChanged func(dt *DownTrack)

+ OnMaxPublishedTemporalChanged func(dt *DownTrack)

+ OnNACK func(dt *DownTrack, nackInfos []NackInfo)

+ OnRTCPReceiverReport func(dt *DownTrack, rr rtcp.ReceptionReport)

+ OnResume func(dt *DownTrack)

+ OnSubscribedLayerChanged func(dt *DownTrack, layers buffer.VideoLayer)

type Forwarder

+ func (f *Forwarder) AdjustTimestamp(tsAdjust float64)

+ func (f *Forwarder) CurrentLayer() buffer.VideoLayer

+ func (f *Forwarder) GetPadding(frameEndNeeded bool) ([]byte, error)

+ func (f *Forwarder) MaxLayer() buffer.VideoLayer

+ func (f *Forwarder) OnParkedLayerExpired(fn func())

+ func (f *Forwarder) TargetLayer() buffer.VideoLayer

type ForwarderState

+ Codec interface{}

+ type NackInfo struct

+ Attempts uint8

+ SequenceNumber uint16

+ Timestamp uint32

type RTPMunger

+ func (r *RTPMunger) UpdateTsOffset(tsAdjust uint32)

type StreamTrackerManager

+ func (s *StreamTrackerManager) SetRTCPSenderReportData(layer int32, senderReport *buffer.RTCPSenderReportData)

type VideoAllocation

+ MaxLayer buffer.VideoLayer

+ TargetLayer buffer.VideoLayer

Mar 31, 2023

Changes in this version

type DownTrack

+ func (d *DownTrack) ClearStreamAllocatorReportInterval()

+ func (d *DownTrack) GetConnectionScoreAndQuality() (float32, livekit.ConnectionQuality)

+ func (d *DownTrack) SetStreamAllocatorListener(listener DownTrackStreamAllocatorListener)

+ func (d *DownTrack) SetStreamAllocatorReportInterval(interval time.Duration)

+ func (d *DownTrack) UpTrackBitrateReport(availableLayers []int32, bitrates Bitrates)

+ func (d *DownTrack) UpTrackMaxTemporalLayerSeenChange(maxTemporalLayerSeen int32)

+ type DownTrackStreamAllocatorListener interface

+ OnAvailableLayersChanged func(dt *DownTrack)

+ OnBitrateAvailabilityChanged func(dt *DownTrack)

+ OnMaxPublishedLayerChanged func(dt *DownTrack)

+ OnPacketsSent func(dt *DownTrack, size int)

+ OnREMB func(dt *DownTrack, remb *rtcp.ReceiverEstimatedMaximumBitrate)

+ OnSubscribedLayersChanged func(dt *DownTrack, layers buffer.VideoLayer)

+ OnSubscriptionChanged func(dt *DownTrack)

+ OnTargetLayerReached func(dt *DownTrack)

+ OnTransportCCFeedback func(dt *DownTrack, cc *rtcp.TransportLayerCC)

type Forwarder

+ func (f *Forwarder) GetOptimalBandwidthNeeded(brs Bitrates) int64

+ func (f *Forwarder) SetMaxTemporalLayerSeen(maxTemporalLayerSeen int32)

type RTPMungerState

+ Started bool

type StreamTrackerManager

+ func (s *StreamTrackerManager) Close()

+ func (s *StreamTrackerManager) GetMaxTemporalLayerSeen() int32

+ func (s *StreamTrackerManager) GetRTCPSenderReportDataExt(layer int32) *buffer.RTCPSenderReportDataExt

+ func (s *StreamTrackerManager) GetReferenceLayerRTPTimestamp(ts uint32, layer int32, referenceLayer int32) (uint32, error)

+ func (s *StreamTrackerManager) SetListener(listener StreamTrackerManagerListener)

+ func (s *StreamTrackerManager) SetRTCPSenderReportDataExt(layer int32, senderReport *buffer.RTCPSenderReportDataExt)

+ type StreamTrackerManagerListener interface

+ OnAvailableLayersChanged func()

+ OnBitrateAvailabilityChanged func()

+ OnBitrateReport func(availableLayers []int32, bitrates Bitrates)

+ OnMaxAvailableLayerChanged func(maxAvailableLayer int32)

+ OnMaxPublishedLayerChanged func(maxPublishedLayer int32)

+ OnMaxTemporalLayerSeenChanged func(maxTemporalLayerSeen int32)

type TrackSender

+ UpTrackBitrateReport func(availableLayers []int32, bitrates Bitrates)

+ UpTrackMaxTemporalLayerSeenChange func(maxTemporalLayerSeen int32)

type VideoAllocation

+ BandwidthDelta int64

+ BandwidthNeeded int64

+ BandwidthRequested int64

+ Bitrates Bitrates

+ DistanceToDesired float64

+ IsDeficient bool

+ MaxLayers buffer.VideoLayer

+ PauseReason VideoPauseReason

+ RequestLayerSpatial int32

+ TargetLayers buffer.VideoLayer

type VideoAllocationProvisional

+ Bitrates Bitrates

type VideoTransition

+ BandwidthDelta int64

+ From buffer.VideoLayer

+ To buffer.VideoLayer

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetConnectionScoreAndQuality() (float32, livekit.ConnectionQuality)

+ func (w *WebRTCReceiver) OnAvailableLayersChanged()

+ func (w *WebRTCReceiver) OnBitrateAvailabilityChanged()

+ func (w *WebRTCReceiver) OnBitrateReport(availableLayers []int32, bitrates Bitrates)

+ func (w *WebRTCReceiver) OnMaxAvailableLayerChanged(maxAvailableLayer int32)

+ func (w *WebRTCReceiver) OnMaxPublishedLayerChanged(maxPublishedLayer int32)

+ func (w *WebRTCReceiver) OnMaxTemporalLayerSeenChanged(maxTemporalLayerSeen int32)

Feb 26, 2023

Changes in this version

type DownTrack

+ func (d *DownTrack) OnMaxPublishedLayerChanged(fn func(dt *DownTrack))

+ func (d *DownTrack) UpTrackMaxPublishedLayerChange(maxPublishedLayer int32)

type Forwarder

+ func (f *Forwarder) IsAnyMuted() bool

+ func (f *Forwarder) SetMaxPublishedLayer(maxPublishedLayer int32)

type RedPrimaryReceiver

+ func (r *RedPrimaryReceiver) IsClosed() bool

type RedReceiver

+ func (r *RedReceiver) IsClosed() bool

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetMaxPublishedLayer() int32

+ func (s *StreamTrackerManager) OnMaxPublishedLayerChanged(f func(maxPublishedLayer int32))

type TrackReceiver

+ IsClosed func() bool

type TrackSender

+ UpTrackMaxPublishedLayerChange func(maxPublishedLayer int32)

type WebRTCReceiver

+ func (w *WebRTCReceiver) IsClosed() bool

Feb 10, 2023

Changes in this version

+ const ParkedLayersWaitDuration

type DownTrack

+ func (d *DownTrack) OnBinding(fn func())

+ func (d *DownTrack) OnTargetLayerFound(fn func(dt *DownTrack))

+ func (d *DownTrack) PubMute(pubMuted bool)

type Forwarder

+ func (f *Forwarder) IsPubMuted() bool

+ func (f *Forwarder) OnParkedLayersExpired(fn func())

+ func (f *Forwarder) PubMute(pubMuted bool) (bool, VideoLayers)

+ func (f *Forwarder) SetNumAdvertisedLayers(numAdvertisedLayers int32)

type StreamTrackerManager

+ func (s *StreamTrackerManager) Start()

+ func (s *StreamTrackerManager) Stop()

type Track

+ func (t *Track) SetPaused(isPaused bool) bool

type TrackReceiver

+ GetRTCPSenderReportDataExt func(layer int32) *buffer.RTCPSenderReportDataExt

+ type VideoPauseReason int

+ const VideoPauseReasonBandwidth

+ const VideoPauseReasonFeedDry

+ const VideoPauseReasonMuted

+ const VideoPauseReasonNone

+ const VideoPauseReasonPubMuted

+ func (v VideoPauseReason) String() string

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetRTCPSenderReportDataExt(layer int32) *buffer.RTCPSenderReportDataExt

Jan 8, 2023

Changes in this version

+ var ErrBufferNotFound = errors.New("buffer not found")

type DownTrack

+ func (d *DownTrack) HandleRTCPSenderReportData(_payloadType webrtc.PayloadType, _layer int32, ...) error

+ func (d *DownTrack) SetActivePaddingOnMuteUpTrack()

type Forwarder

+ func (f *Forwarder) GetReferenceLayerSpatial() int32

type ForwarderState

+ ReferenceLayerSpatial int32

type StreamTrackerManager

+ func (s *StreamTrackerManager) IsPaused() bool

type TrackReceiver

+ GetRTCPSenderReportData func(layer int32) *buffer.RTCPSenderReportData

+ GetReferenceLayerRTPTimestamp func(ts uint32, layer int32, referenceLayer int32) (uint32, error)

type TrackSender

+ HandleRTCPSenderReportData func(payloadType webrtc.PayloadType, layer int32, ...) error

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetRTCPSenderReportData(layer int32) *buffer.RTCPSenderReportData

+ func (w *WebRTCReceiver) GetReferenceLayerRTPTimestamp(ts uint32, layer int32, referenceLayer int32) (uint32, error)

Dec 16, 2022

Changes in this version

type ForwarderState

+ Started bool

Nov 8, 2022

Changes in this version

type DownTrackState

+ DeltaStatsSnapshotId uint32

+ type RedReceiver struct

+ func NewRedReceiver(receiver TrackReceiver, dsp DownTrackSpreaderParams) *RedReceiver

+ func (r *RedReceiver) AddDownTrack(track TrackSender) error

+ func (r *RedReceiver) CanClose() bool

+ func (r *RedReceiver) Close()

+ func (r *RedReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID)

+ func (r *RedReceiver) ForwardRTP(pkt *buffer.ExtPacket, spatialLayer int32)

+ func (r *RedReceiver) ReadRTP(buf []byte, layer uint8, sn uint16) (int, error)

type TrackReceiver

+ GetRedReceiver func() TrackReceiver

+ GetTemporalLayerFpsForSpatial func(layer int32) []float32

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetRedReceiver() TrackReceiver

+ func (w *WebRTCReceiver) GetTemporalLayerFpsForSpatial(layer int32) []float32

Oct 13, 2022

Changes in this version

type DownTrack

+ func (d *DownTrack) GetState() DownTrackState

+ func (d *DownTrack) SeedState(state DownTrackState)

+ type DownTrackState struct

+ ForwarderState ForwarderState

+ RTPStats *buffer.RTPStats

+ func (d DownTrackState) String() string

type ForwarderState

+ func (f ForwarderState) String() string

type RTPMungerState

+ func (r RTPMungerState) String() string

type StreamState

+ func (s StreamState) String() string

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetLayeredBitrate() Bitrates

type TrackReceiver

+ GetLayeredBitrate func() Bitrates

type VP8MungerState

+ func (v VP8MungerState) String() string

type VideoTransition

+ func (v VideoTransition) String() string

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetLayeredBitrate() Bitrates

Sep 13, 2022

Changes in this version

+ const FlagAllowOvershootExemptTrackWhileDeficient

+ const FlagAllowOvershootInCatchup

+ const FlagAllowOvershootInProbe

+ const FlagAllowOvershootWhileDeficient

+ const FlagAllowOvershootWhileOptimal

+ var ExemptedLayersScreenshare = []int32

+ var ExemptedLayersVideo = []int32

Aug 26, 2022

Changes in this version

+ const MimeTypeAudioRed

+ var ErrIncompleteRedBlock = errors.New("incomplete red block payload")

+ var ErrIncompleteRedHeader = errors.New("incomplete red block header")

+ func ExtractPrimaryEncodingForRED(payload []byte) ([]byte, error)

+ func IsRedCodec(mime string) bool

type DownTrack

+ func (d *DownTrack) TrackInfoAvailable()

type Forwarder

+ func (f *Forwarder) IsReducedQuality() (int32, bool)

+ type RedPrimaryReceiver struct

+ func NewRedPrimaryReceiver(receiver TrackReceiver, dsp DownTrackSpreaderParams) *RedPrimaryReceiver

+ func (r *RedPrimaryReceiver) AddDownTrack(track TrackSender) error

+ func (r *RedPrimaryReceiver) CanClose() bool

+ func (r *RedPrimaryReceiver) Close()

+ func (r *RedPrimaryReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID)

+ func (r *RedPrimaryReceiver) ForwardRTP(pkt *buffer.ExtPacket, spatialLayer int32)

+ func (r *RedPrimaryReceiver) ReadRTP(buf []byte, layer uint8, sn uint16) (int, error)

type StreamTrackerManager

+ func (s *StreamTrackerManager) DistanceToDesired() int32

type TrackReceiver

+ GetPrimaryReceiverForRed func() TrackReceiver

+ TrackInfo func() *livekit.TrackInfo

type TrackSender

+ TrackInfoAvailable func()

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetPrimaryReceiverForRed() TrackReceiver

+ func (w *WebRTCReceiver) TrackInfo() *livekit.TrackInfo

Jul 8, 2022

Changes in this version

type DownTrack

+ func (d *DownTrack) GetForwarderState() ForwarderState

+ func (d *DownTrack) GetTransceiver() *webrtc.RTPTransceiver

+ func (d *DownTrack) SeedForwarderState(state ForwarderState)

type Forwarder

+ func (f *Forwarder) GetState() ForwarderState

+ func (f *Forwarder) SeedState(state ForwarderState)

+ type ForwarderState struct

+ LastTSCalc int64

+ RTP RTPMungerState

+ VP8 VP8MungerState

type RTPMunger

+ func (r *RTPMunger) GetLast() RTPMungerState

+ func (r *RTPMunger) SeedLast(state RTPMungerState)

+ type RTPMungerState struct

+ LastSN uint16

+ LastTS uint32

type VP8Munger

+ func (v *VP8Munger) GetLast() VP8MungerState

+ func (v *VP8Munger) SeedLast(state VP8MungerState)

+ type VP8MungerState struct

+ ExtLastPictureId int32

+ KeyIdxUsed int

+ LastKeyIdx uint8

+ LastTl0PicIdx uint8

+ PictureIdUsed int

+ TidUsed int

+ Tl0PicIdxUsed int

Jun 22, 2022

Changes in this version

+ var ErrDownTrackAlreadyBound = errors.New("already bound")

+ var ErrDownTrackClosed = errors.New("downtrack closed")

+ func IsSvcCodec(mime string) bool

type DownTrack

+ func (d *DownTrack) IsClosed() bool

+ func (d *DownTrack) SetConnected()

+ func (d *DownTrack) SubscriberID() livekit.ParticipantID

type DownTrackSpreader

+ func (d *DownTrackSpreader) DownTrackCount() int

type Forwarder

+ func (f *Forwarder) DetermineCodec(codec webrtc.RTPCodecCapability)

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetLayerDimension(layer int32) (uint32, uint32)

+ func (s *StreamTrackerManager) GetMaxExpectedLayer() (layer int32, width uint32, height uint32)

+ func (s *StreamTrackerManager) OnMaxLayerChanged(f func(maxLayer int32))

type TrackReceiver

+ GetLayerDimension func(layer int32) (uint32, uint32)

+ HeaderExtensions func() []webrtc.RTPHeaderExtensionParameter

+ IsDtxDisabled func() bool

+ TrackSource func() livekit.TrackSource

type TrackSender

+ IsClosed func() bool

+ SubscriberID func() livekit.ParticipantID

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetLayerDimension(layer int32) (uint32, uint32)

+ func (w *WebRTCReceiver) HeaderExtensions() []webrtc.RTPHeaderExtensionParameter

+ func (w *WebRTCReceiver) IsDtxDisabled() bool

+ func (w *WebRTCReceiver) OnMaxLayerChange(fn func(maxLayer int32))

+ func (w *WebRTCReceiver) TrackSource() livekit.TrackSource

May 28, 2022

Changes in this version

+ const RTPBlankFramesCloseSeconds

+ const RTPBlankFramesMuteSeconds

+ const SignalAdjustState

+ const SignalAllocateAllTracks

+ const SignalAllocateTrack

type Event

+ TrackID livekit.TrackID

type Track

+ func (t *Track) SetDirty(isDirty bool) bool

+ func (t *Track) SetMaxLayers(layers VideoLayers) bool

May 18, 2022

Changes in this version

+ const RTPBlankFramesSeconds

+ var OpusSilenceFrame = []byte

+ type DDVideoLayerSelector struct

+ func NewDDVideoLayerSelector(logger logger.Logger) *DDVideoLayerSelector

+ func (s *DDVideoLayerSelector) Select(expPkt *buffer.ExtPacket, tp *TranslationParams) (selected bool)

+ func (s *DDVideoLayerSelector) SelectLayer(layer VideoLayers)

type StreamTrackerParams

+ BitrateReportInterval time.Duration

type TranslationParamsVP8

+ Header *buffer.VP8

+ type Uint16Wrapper struct

+ func (w *Uint16Wrapper) Unwrap(value uint16) int32

May 1, 2022

Changes in this version

+ const SnOffsetCacheMask

+ const SnOffsetCacheSize

+ type DownTrackSpreader struct

+ func NewDownTrackSpreader(params DownTrackSpreaderParams) *DownTrackSpreader

+ func (d *DownTrackSpreader) Broadcast(layer int32, pkt *buffer.ExtPacket)

+ func (d *DownTrackSpreader) Free(peerID livekit.ParticipantID)

+ func (d *DownTrackSpreader) GetDownTracks() []TrackSender

+ func (d *DownTrackSpreader) HasDownTrack(peerID livekit.ParticipantID) bool

+ func (d *DownTrackSpreader) ResetAndGetDownTracks() []TrackSender

+ func (d *DownTrackSpreader) Store(ts TrackSender)

+ type DownTrackSpreaderParams struct

+ Logger logger.Logger

+ Threshold int

type ReceiverOpts

+ func WithAudioConfig(audioConfig config.AudioConfig) ReceiverOpts

+ func WithPliThrottleConfig(pliThrottleConfig config.PLIThrottleConfig) ReceiverOpts

type TrackReceiver

+ GetAudioLevel func() (float64, bool)

type VideoLayers

+ func (v VideoLayers) IsValid() bool

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetAudioLevel() (float64, bool)

Mar 28, 2022

Changes in this version

+ var ChannelObserverParamsNonProbe = ChannelObserverParams

+ var ChannelObserverParamsProbe = ChannelObserverParams

+ var ConfigScreenshare = []StreamTrackerParams

+ var ConfigVideo = []StreamTrackerParams

+ var ErrDownTrackAlreadyExist = errors.New("DownTrack already exist")

+ var ErrReceiverClosed = errors.New("receiver closed")

+ type ChannelCongestionReason int

+ const ChannelCongestionReasonEstimate

+ const ChannelCongestionReasonLoss

+ const ChannelCongestionReasonNone

+ func (c ChannelCongestionReason) String() string

+ type ChannelObserverParams struct

+ EstimateCollapseValues bool

+ EstimateDownwardTrendThreshold float64

+ EstimateRequiredSamples int

+ NackRatioThreshold float64

+ NackWindowMaxDuration time.Duration

+ NackWindowMinDuration time.Duration

+ Name string

type DownTrack

+ func (d *DownTrack) AllocateOptimal() VideoAllocation

+ func (d *DownTrack) GetTrackStats() map[uint32]*buffer.StreamStatsWithLayers

+ func (d *DownTrack) OnBitrateAvailabilityChanged(fn func(dt *DownTrack))

+ func (d *DownTrack) OnPacketSentUnsafe(fn func(dt *DownTrack, size int))

+ func (d *DownTrack) OnPaddingSentUnsafe(fn func(dt *DownTrack, size int))

+ func (d *DownTrack) UpTrackBitrateAvailabilityChange()

type Forwarder

+ func (f *Forwarder) AllocateOptimal(brs Bitrates) VideoAllocation

+ func (f *Forwarder) CheckSync() (locked bool, layer int32)

type Signal

+ const SignalBitrateAvailabilityChange

type StreamTracker

+ func (s *StreamTracker) BitrateTemporalCumulative() [4]int64

+ func (s *StreamTracker) OnBitrateAvailable(f func())

type StreamTrackerManager

+ func (s *StreamTrackerManager) GetBitrateTemporalCumulative() Bitrates

+ func (s *StreamTrackerManager) OnBitrateAvailabilityChanged(f func())

+ type StreamTrackerParams struct

+ CycleDuration time.Duration

+ CyclesRequired uint32

+ Logger logger.Logger

+ SamplesRequired uint32

type Track

+ func (t *Track) AllocateOptimal() VideoAllocation

type TrackSender

+ UpTrackBitrateAvailabilityChange func()

type TrendDetector

+ func (t *TrendDetector) GetValues() []int64

+ func (t *TrendDetector) ToString() string

+ type TrendDetectorParams struct

+ CollapseValues bool

+ DownwardTrendThreshold float64

+ Logger logger.Logger

+ Name string

+ RequiredSamples int

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetTrackStats() map[uint32]*buffer.StreamStatsWithLayers

Feb 28, 2022

Changes in this version

+ const FlagFilterRTX

+ const FlagStopRTXOnPLI

+ const NackRatioAttenuator

+ const NackRatioThresholdNonProbe

+ const NackRatioThresholdProbe

+ const NumRequiredEstimatesNonProbe

+ const NumRequiredEstimatesProbe

+ const PriorityDefaultScreenshare

+ const PriorityDefaultVideo

+ const PriorityMax

+ const PriorityMin

+ const ProbeBackoffFactor

+ const ProbeMaxDuration

+ const ProbeMinBps

+ const ProbeMinDuration

+ const ProbePct

+ const ProbeSettleWait

+ const ProbeTrendWait

+ const ProbeWaitBase

+ const ProbeWaitMax

+ const RtxGateWindow

+ var ErrTrackAlreadyBind = errors.New("already bind")

type AddTrackParams

+ Priority uint8

+ PublisherID livekit.ParticipantID

+ type ChannelObserver struct

+ func NewChannelObserver(name string, logger logger.Logger, estimateRequiredSamples int, ...) *ChannelObserver

+ func (c *ChannelObserver) AddEstimate(estimate int64)

+ func (c *ChannelObserver) AddNack(packets uint32, repeatedNacks uint32)

+ func (c *ChannelObserver) GetHighestEstimate() int64

+ func (c *ChannelObserver) GetLowestEstimate() int64

+ func (c *ChannelObserver) GetNackRatio() float64

+ func (c *ChannelObserver) GetTrend() ChannelTrend

+ func (c *ChannelObserver) Reset()

+ func (c *ChannelObserver) SeedEstimate(estimate int64)

+ func (c *ChannelObserver) SeedNack(packets uint32, repeatedNacks uint32)

+ type ChannelTrend int

+ const ChannelTrendClearing

+ const ChannelTrendCongesting

+ const ChannelTrendNeutral

+ func (c ChannelTrend) String() string

type Cluster

+ func (c *Cluster) GetInfo() ProbeClusterInfo

type DownTrack

+ func (d *DownTrack) GetNackStats() (totalPackets uint32, totalRepeatedNACKs uint32)

+ func (d *DownTrack) GetNextHigherTransition() (VideoTransition, bool)

type Forwarder

+ func (f *Forwarder) FilterRTX(nacks []uint16) (filtered []uint16, disallowedLayers [DefaultMaxLayerSpatial + 1]bool)

+ func (f *Forwarder) GetNextHigherTransition(brs Bitrates) (VideoTransition, bool)

+ func (f *Forwarder) ReceivedFirstKeyFrame() bool

+ type ProbeClusterId uint32

+ const ProbeClusterIdInvalid

+ type ProbeClusterInfo struct

+ BytesSent int

+ Duration time.Duration

+ Id ProbeClusterId

type Prober

+ func (p *Prober) OnProbeClusterDone(f func(info ProbeClusterInfo))

type RTPMunger

+ func (r *RTPMunger) FilterRTX(nacks []uint16) []uint16

type Signal

+ const SignalProbeClusterDone

+ const SignalSetTrackPriority

type StreamAllocator

+ func (s *StreamAllocator) SetTrackPriority(downTrack *DownTrack, priority uint8)

type Track

+ func (t *Track) GetNackDelta() (uint32, uint32)

+ func (t *Track) GetNextHigherTransition() (VideoTransition, bool)

+ func (t *Track) Priority() uint8

+ func (t *Track) PublisherID() livekit.ParticipantID

+ func (t *Track) SetPriority(priority uint8) bool

+ type TrendDetector struct

+ func NewTrendDetector(name string, logger logger.Logger, requiredSamples int) *TrendDetector

+ func (t *TrendDetector) AddValue(value int64)

+ func (t *TrendDetector) GetDirection() TrendDirection

+ func (t *TrendDetector) GetHighest() int64

+ func (t *TrendDetector) GetLowest() int64

+ func (t *TrendDetector) Reset()

+ func (t *TrendDetector) Seed(value int64)

+ type TrendDirection int

+ const TrendDirectionDownward

+ const TrendDirectionNeutral

+ const TrendDirectionUpward

+ func (t TrendDirection) String() string

Feb 9, 2022

Changes in this version

type DownTrack

+ func (d *DownTrack) OnMaxLayerChanged(fn func(dt *DownTrack, layer int32))

+ func (d *DownTrack) OnRttUpdate(fn func(dt *DownTrack, rtt uint32))

+ func (d *DownTrack) Resync()

type Forwarder

+ func (f *Forwarder) IsMuted() bool

+ func (f *Forwarder) Resync()

+ type StreamTrackerManager struct

+ func NewStreamTrackerManager() *StreamTrackerManager

+ func (s *StreamTrackerManager) AddTracker(layer int32)

+ func (s *StreamTrackerManager) GetAvailableLayers() []int32

+ func (s *StreamTrackerManager) GetTracker(layer int32) *StreamTracker

+ func (s *StreamTrackerManager) HasSpatialLayer(layer int32) bool

+ func (s *StreamTrackerManager) IsReducedQuality() bool

+ func (s *StreamTrackerManager) OnAvailableLayersChanged(f func(availableLayers []int32))

+ func (s *StreamTrackerManager) RemoveAllTrackers()

+ func (s *StreamTrackerManager) RemoveTracker(layer int32)

+ func (s *StreamTrackerManager) SetMaxExpectedSpatialLayer(layer int32)

+ func (s *StreamTrackerManager) SetPaused(paused bool)

type VideoLayers

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

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetConnectionScore() float32

+ func (w *WebRTCReceiver) OnStatsUpdate(fn func(w *WebRTCReceiver, stat *livekit.AnalyticsStat))

+ func (w *WebRTCReceiver) SetRTT(rtt uint32)

Jan 29, 2022

Changes in this version

+ var VP8KeyFrame8x8 = []byte

+ func RidToLayer(rid string) int32

+ type AudioLevelHandle func(level uint8, duration uint32)

type DownTrack

+ func (d *DownTrack) CloseWithFlush(flush bool)

+ func (d *DownTrack) OnStatsUpdate(fn func(dt *DownTrack, stat *livekit.AnalyticsStat))

+ func (d *DownTrack) RID() string

+ func (d *DownTrack) UpTrackLayersChange(availableLayers []uint16)

type Forwarder

+ func (f *Forwarder) UpTrackLayersChange(availableLayers []uint16)

type StreamAllocator

+ func (s *StreamAllocator) SetBandwidthEstimator(bwe cc.BandwidthEstimator)

type TrackReceiver

+ DebugInfo func() map[string]interface{}

+ SetMaxExpectedSpatialLayer func(layer int32)

+ SetUpTrackPaused func(paused bool)

type TrackSender

+ UpTrackLayersChange func(availableLayers []uint16)

type WebRTCReceiver

+ func (w *WebRTCReceiver) GetTotalBytes() uint64

+ func (w *WebRTCReceiver) OnAudioLevel(fn AudioLevelHandle)

Jan 6, 2022

Changes in this version

+ const InvalidLayerSpatial

+ const InvalidLayerTemporal

+ type AddTrackParams struct

+ IsSimulcast bool

+ Source livekit.TrackSource

type DownTrack

+ func (d *DownTrack) OnTransportCCFeedback(fn func(dt *DownTrack, cc *rtcp.TransportLayerCC))

type Receiver

+ SetMaxExpectedSpatialLayer func(layer int32)

type Signal

+ const SignalTargetBitrate

type StreamAllocatorParams

+ Config config.CongestionControlConfig

type StreamStateInfo

+ ParticipantID livekit.ParticipantID

+ TrackID livekit.TrackID

type StreamTracker

+ func (s *StreamTracker) Reset()

type WebRTCReceiver

+ func (w *WebRTCReceiver) SetMaxExpectedSpatialLayer(layer int32)

Dec 22, 2021

Changes in this version

+ const BoostWait

+ const ChannelCapacityInfinity

+ const DefaultMaxLayerSpatial

+ const DefaultMaxLayerTemporal

+ const EstimateCommit

+ const FlagPauseOnDowngrade

+ const FullResolution

+ const GratuitousProbeMaxDuration

+ const GratuitousProbeMinBps

+ const GratuitousProbeMinDuration

+ const GratuitousProbeMoreWait

+ const GratuitousProbeWait

+ const HalfResolution

+ const ProbeWait

+ const QuarterResolution

+ const TransitionCostSpatial

+ var DefaultMaxLayers = VideoLayers

+ var ErrUnknownKind = errors.New("unknown kind of codec")

+ var InvalidLayers = VideoLayers

+ var PacketFactory *sync.Pool

+ var VideoAllocationDefault = VideoAllocation

+ func FixedPointToPercent(frac uint8) uint32

+ type Bitrates [DefaultMaxLayerSpatial + 1][DefaultMaxLayerTemporal + 1]int64

type Cluster

+ func (c *Cluster) IsFinished() bool

+ func (c *Cluster) ProbeSent(size int)

+ func (c *Cluster) String() string

type DownTrack

+ func (d *DownTrack) Allocate(availableChannelCapacity int64) VideoAllocation

+ func (d *DownTrack) AllocateNextHigher() (VideoAllocation, bool)

+ func (d *DownTrack) BandwidthRequested() int64

+ func (d *DownTrack) DistanceToDesired() int32

+ func (d *DownTrack) FinalizeAllocate() VideoAllocation

+ func (d *DownTrack) GetConnectionScore() float64

+ func (d *DownTrack) GetForwardingStatus() ForwardingStatus

+ func (d *DownTrack) IsDeficient() bool

+ func (d *DownTrack) MaxLayers() VideoLayers

+ func (d *DownTrack) OnPaddingSent(fn func(dt *DownTrack, size int))

+ func (d *DownTrack) OnSubscribedLayersChanged(fn func(dt *DownTrack, layers VideoLayers))

+ func (d *DownTrack) Pause() VideoAllocation

+ func (d *DownTrack) PeerID() string

+ func (d *DownTrack) ProvisionalAllocate(availableChannelCapacity int64, layers VideoLayers) int64

+ func (d *DownTrack) ProvisionalAllocateCommit() VideoAllocation

+ func (d *DownTrack) ProvisionalAllocateGetBestWeightedTransition() VideoTransition

+ func (d *DownTrack) ProvisionalAllocateGetCooperativeTransition() VideoTransition

+ func (d *DownTrack) ProvisionalAllocatePrepare()

+ func (d *DownTrack) SetMaxSpatialLayer(spatialLayer int32)

+ func (d *DownTrack) SetMaxTemporalLayer(temporalLayer int32)

+ func (d *DownTrack) UpdatePaddingStats(packetLen uint32)

+ func (d *DownTrack) UpdatePrimaryStats(packetLen uint32)

+ func (d *DownTrack) UpdateRtxStats(packetLen uint32)

type Event

+ Data interface{}

+ func (e Event) String() string

+ type Forwarder struct

+ func NewForwarder(codec webrtc.RTPCodecCapability, kind webrtc.RTPCodecType) *Forwarder

+ func (f *Forwarder) Allocate(availableChannelCapacity int64, brs Bitrates) VideoAllocation

+ func (f *Forwarder) AllocateNextHigher(brs Bitrates) (VideoAllocation, bool)

+ func (f *Forwarder) BandwidthRequested() int64

+ func (f *Forwarder) CurrentLayers() VideoLayers

+ func (f *Forwarder) DistanceToDesired() int32

+ func (f *Forwarder) FinalizeAllocate(brs Bitrates) VideoAllocation

+ func (f *Forwarder) GetForwardingStatus() ForwardingStatus

+ func (f *Forwarder) GetPaddingVP8(frameEndNeeded bool) *buffer.VP8

+ func (f *Forwarder) GetRTPMungerParams() RTPMungerParams

+ func (f *Forwarder) GetSnTsForBlankFrames() ([]SnTs, bool, error)

+ func (f *Forwarder) GetSnTsForPadding(num int) ([]SnTs, error)

+ func (f *Forwarder) GetTranslationParams(extPkt *buffer.ExtPacket, layer int32) (*TranslationParams, error)

+ func (f *Forwarder) IsDeficient() bool

+ func (f *Forwarder) MaxLayers() VideoLayers

+ func (f *Forwarder) Mute(val bool) bool

+ func (f *Forwarder) Muted() bool

+ func (f *Forwarder) Pause(brs Bitrates) VideoAllocation

+ func (f *Forwarder) ProvisionalAllocate(availableChannelCapacity int64, layers VideoLayers) int64

+ func (f *Forwarder) ProvisionalAllocateCommit() VideoAllocation

+ func (f *Forwarder) ProvisionalAllocateGetBestWeightedTransition() VideoTransition

+ func (f *Forwarder) ProvisionalAllocateGetCooperativeTransition() VideoTransition

+ func (f *Forwarder) ProvisionalAllocatePrepare(bitrates Bitrates)

+ func (f *Forwarder) SetMaxSpatialLayer(spatialLayer int32) (bool, VideoLayers)

+ func (f *Forwarder) SetMaxTemporalLayer(temporalLayer int32) (bool, VideoLayers)

+ func (f *Forwarder) TargetLayers() VideoLayers

+ func (f *Forwarder) UptrackLayersChange(availableLayers []uint16)

+ type ForwardingStatus int

+ const ForwardingStatusOff

+ const ForwardingStatusOptimal

+ const ForwardingStatusPartial

+ type MaxDistanceSorter []*Track

+ func (m MaxDistanceSorter) Len() int

+ func (m MaxDistanceSorter) Less(i, j int) bool

+ func (m MaxDistanceSorter) Swap(i, j int)

+ type MinDistanceSorter []*Track

+ func (m MinDistanceSorter) Len() int

+ func (m MinDistanceSorter) Less(i, j int) bool

+ func (m MinDistanceSorter) Swap(i, j int)

+ type PacketStats struct

type Prober

+ func (p *Prober) ProbeSent(size int)

+ type ProberParams struct

+ Logger logger.Logger

+ type RTPMunger struct

+ func NewRTPMunger() *RTPMunger

+ func (r *RTPMunger) GetParams() RTPMungerParams

+ func (r *RTPMunger) IsOnFrameBoundary() bool

+ func (r *RTPMunger) PacketDropped(extPkt *buffer.ExtPacket)

+ func (r *RTPMunger) SetLastSnTs(extPkt *buffer.ExtPacket)

+ func (r *RTPMunger) UpdateAndGetPaddingSnTs(num int, clockRate uint32, frameRate uint32, forceMarker bool) ([]SnTs, error)

+ func (r *RTPMunger) UpdateAndGetSnTs(extPkt *buffer.ExtPacket) (*TranslationParamsRTP, error)

+ func (r *RTPMunger) UpdateSnTsOffsets(extPkt *buffer.ExtPacket, snAdjust uint16, tsAdjust uint32)

+ type RTPMungerParams struct

type Receiver

+ NumAvailableSpatialLayers func() int

+ ReadRTP func(buf []byte, layer uint8, sn uint16) (int, error)

+ SendPLI func(layer int32)

type SequenceNumberOrdering

+ const SequenceNumberOrderingDuplicate

type Signal

+ const SignalAddTrack

+ const SignalAvailableLayersChange

+ const SignalEstimate

+ const SignalPeriodicPing

+ const SignalReceiverReport

+ const SignalRemoveTrack

+ const SignalSendProbe

+ const SignalSubscribedLayersChange

+ const SignalSubscriptionChange

+ func (s Signal) String() string

+ type SnTs struct

type State

+ const StateDeficient

+ const StateStable

+ func (s State) String() string

type StreamAllocator

+ func (s *StreamAllocator) OnStreamStateChange(f func(update *StreamStateUpdate) error)

+ type StreamAllocatorParams struct

+ Logger logger.Logger

+ type StreamState int

+ const StreamStateActive

+ const StreamStatePaused

+ type StreamStateInfo struct

+ ParticipantSid string

+ State StreamState

+ TrackSid string

+ type StreamStateUpdate struct

+ StreamStates []*StreamStateInfo

+ func NewStreamStateUpdate() *StreamStateUpdate

+ func (s *StreamStateUpdate) Empty() bool

+ func (s *StreamStateUpdate) HandleStreamingChange(change VideoStreamingChange, track *Track)

type Track

+ func (t *Track) Allocate(availableChannelCapacity int64) VideoAllocation

+ func (t *Track) AllocateNextHigher() (VideoAllocation, bool)

+ func (t *Track) DistanceToDesired() int32

+ func (t *Track) DownTrack() *DownTrack

+ func (t *Track) FinalizeAllocate()

+ func (t *Track) ID() string

+ func (t *Track) IsDeficient() bool

+ func (t *Track) IsManaged() bool

+ func (t *Track) Pause() VideoAllocation

+ func (t *Track) PeerID() string

+ func (t *Track) ProvisionalAllocate(availableChannelCapacity int64, layers VideoLayers) int64

+ func (t *Track) ProvisionalAllocateCommit() VideoAllocation

+ func (t *Track) ProvisionalAllocateGetBestWeightedTransition() VideoTransition

+ func (t *Track) ProvisionalAllocateGetCooperativeTransition() VideoTransition

+ func (t *Track) ProvisionalAllocatePrepare()

+ func (t *Track) UpdateMaxLayers(layers VideoLayers)

+ type TrackReceiver interface

+ AddDownTrack func(track TrackSender)

+ Codec func() webrtc.RTPCodecCapability

+ DeleteDownTrack func(peerID string)

+ GetBitrateTemporalCumulative func() Bitrates

+ GetSenderReportTime func(layer int32) (rtpTS uint32, ntpTS uint64)

+ ReadRTP func(buf []byte, layer uint8, sn uint16) (int, error)

+ SendPLI func(layer int32)

+ StreamID func() string

+ TrackID func() string

+ type TrackSender interface

+ Close func()

+ Codec func() webrtc.RTPCodecCapability

+ ID func() string

+ PeerID func() string

+ UptrackLayersChange func(availableLayers []uint16)

+ WriteRTP func(p *buffer.ExtPacket, layer int32) error

+ type TrackSorter []*Track

+ func (t TrackSorter) Len() int

+ func (t TrackSorter) Less(i, j int) bool

+ func (t TrackSorter) Swap(i, j int)

+ type TranslationParams struct

+ type TranslationParamsRTP struct

+ type TranslationParamsVP8 struct

type VP8Munger

+ func (v *VP8Munger) PictureIdOffset(extPictureId int32) (int32, bool)

+ type VideoAllocation struct

+ func (v VideoAllocation) String() string

+ type VideoAllocationProvisional struct

+ type VideoAllocationState int

+ const VideoAllocationStateAwaitingMeasurement

+ const VideoAllocationStateDeficient

+ const VideoAllocationStateFeedDry

+ const VideoAllocationStateMuted

+ const VideoAllocationStateNone

+ const VideoAllocationStateOptimal

+ func (v VideoAllocationState) String() string

+ type VideoLayers struct

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

+ func (v VideoLayers) String() string

+ type VideoStreamingChange int

+ const VideoStreamingChangeNone

+ const VideoStreamingChangePausing

+ const VideoStreamingChangeResuming

+ func (v VideoStreamingChange) String() string

+ type VideoTransition struct

type WebRTCReceiver

+ func (w *WebRTCReceiver) NumAvailableSpatialLayers() int

+ func (w *WebRTCReceiver) ReadRTP(buf []byte, layer uint8, sn uint16) (int, error)

+ func (w *WebRTCReceiver) SendPLI(layer int32)

Nov 19, 2021

Changes in this version

+ var ErrNoRequiredBuff = errors.New("buff size if less than required")

+ var H264KeyFrame2x2 = [][]byte

+ var H264KeyFrame2x2IDR = []byte

+ var H264KeyFrame2x2PPS = []byte

+ var H264KeyFrame2x2SPS = []byte

type DownTrack

+ func (d *DownTrack) OnRTCP(fn func([]rtcp.Packet))

Nov 11, 2021

Changes in this version

+ const AudioLossWeight

+ const BoostMaxBps

+ const BoostMinBps

+ const BoostPct

+ const EstimateEpsilon

+ const GratuitousProbeHeadroomBps

+ const GratuitousProbeMaxBps

+ const GratuitousProbeMaxDurationMs

+ const GratuitousProbeMinDurationMs

+ const GratuitousProbePct

+ const InitialChannelCapacity

+ const RTPBlankFramesMax

+ const RTPPaddingEstimatedHeaderSize

+ const RTPPaddingMaxPayloadSize

+ const VideoLossWeight

+ var BoostWaitMs = 3 * 1000 * time.Millisecond

+ var ErrDuplicatePacket = errors.New("duplicate packet")

+ var ErrFilteredVP8TemporalLayer = errors.New("filtered VP8 temporal layer")

+ var ErrNotVP8 = errors.New("not VP8")

+ var ErrOutOfOrderSequenceNumberCacheMiss = errors.New("out-of-order sequence number not found in cache")

+ var ErrOutOfOrderVP8PictureIdCacheMiss = errors.New("out-of-order VP8 picture id not found in cache")

+ var ErrPaddingNotOnFrameBoundary = errors.New("padding cannot send on non-frame boundary")

+ var ErrPaddingOnlyPacket = errors.New("padding only packet that need not be forwarded")

+ var ErrSpatialLayerNotFound = errors.New("the requested layer does not exist")

+ var ErrSpatialNotSupported = errors.New("current track does not support simulcast/SVC")

+ var EstimateCommitMs = 2 * 1000 * time.Millisecond

+ var GratuitousProbeWaitMs = 8 * 1000 * time.Millisecond

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

+ var ProbeWaitMs = 5 * 1000 * time.Millisecond

+ var VP8KeyFrame1x1 = []byte

+ type BoostMode int

+ const BoostMode_BANDWIDTH

+ const BoostMode_LAYER

+ type Cluster struct

+ func NewCluster(desiredRateBps int, expectedRateBps int, minDuration time.Duration, ...) *Cluster

+ func (c *Cluster) GetSleepDuration() time.Duration

+ func (c *Cluster) PacketSent(size int)

+ func (c *Cluster) Process(p *Prober) bool

+ func (c *Cluster) Start()

+ type DownTrack struct

+ func NewDownTrack(c webrtc.RTPCodecCapability, r Receiver, bf *buffer.Factory, peerID string, ...) (*DownTrack, error)

+ func (d *DownTrack) AddReceiverReportListener(listener ReceiverReportListener)

+ func (d *DownTrack) AdjustAllocation(availableChannelCapacity uint64) (uint64, uint64)

+ func (d *DownTrack) Bind(t webrtc.TrackLocalContext) (webrtc.RTPCodecParameters, error)

+ func (d *DownTrack) Close()

+ func (d *DownTrack) Codec() webrtc.RTPCodecCapability

+ func (d *DownTrack) CreateSenderReport() *rtcp.SenderReport

+ func (d *DownTrack) CreateSourceDescriptionChunks() []rtcp.SourceDescriptionChunk

+ func (d *DownTrack) CurrentMaxLossFraction() uint8

+ func (d *DownTrack) CurrentSpatialLayer() int32

+ func (d *DownTrack) DebugInfo() map[string]interface{}

+ func (d *DownTrack) Enabled() bool

+ func (d *DownTrack) ID() string

+ func (d *DownTrack) IncreaseAllocation() (bool, uint64, uint64)

+ func (d *DownTrack) Kind() webrtc.RTPCodecType

+ func (d *DownTrack) MaxSpatialLayer() int32

+ func (d *DownTrack) MaybeTranslateVP8(pkt *rtp.Packet, meta packetMeta) error

+ func (d *DownTrack) Mute(val bool)

+ func (d *DownTrack) OnAvailableLayersChanged(fn func(dt *DownTrack, layerAdded bool))

+ func (d *DownTrack) OnBind(fn func())

+ func (d *DownTrack) OnCloseHandler(fn func())

+ func (d *DownTrack) OnPacketSent(fn func(dt *DownTrack, size int))

+ func (d *DownTrack) OnREMB(fn func(dt *DownTrack, remb *rtcp.ReceiverEstimatedMaximumBitrate))

+ func (d *DownTrack) OnSubscriptionChanged(fn func(dt *DownTrack))

+ func (d *DownTrack) SSRC() uint32

+ func (d *DownTrack) SetInitialLayers(spatialLayer, temporalLayer int32)

+ func (d *DownTrack) SetRTPHeaderExtensions(rtpHeaderExtensions []webrtc.RTPHeaderExtensionParameter)

+ func (d *DownTrack) SetTransceiver(transceiver *webrtc.RTPTransceiver)

+ func (d *DownTrack) Stop() error

+ func (d *DownTrack) StreamID() string

+ func (d *DownTrack) SwitchSpatialLayer(targetLayer int32, setAsMax bool) error

+ func (d *DownTrack) SwitchSpatialLayerDone(layer int32)

+ func (d *DownTrack) SwitchTemporalLayer(targetLayer int32, setAsMax bool)

+ func (d *DownTrack) TargetSpatialLayer() int32

+ func (d *DownTrack) Unbind(_ webrtc.TrackLocalContext) error

+ func (d *DownTrack) UpdateStats(packetLen uint32)

+ func (d *DownTrack) UptrackLayersChange(availableLayers []uint16, layerAdded bool) (int32, error)

+ func (d *DownTrack) WritePaddingRTP(bytesToSend int) int

+ func (d *DownTrack) WriteRTP(p *buffer.ExtPacket, layer int32) error

+ func (d *DownTrack) WriteRTPHeaderExtensions(hdr *rtp.Header) error

+ type DownTrackType int

+ const SimpleDownTrack

+ const SimulcastDownTrack

+ type Event struct

+ DownTrack *DownTrack

+ Signal Signal

+ type Munger struct

+ func NewMunger() *Munger

+ func (m *Munger) IsOnFrameBoundary() bool

+ func (m *Munger) PacketDropped(extPkt *buffer.ExtPacket)

+ func (m *Munger) SetLastSnTs(extPkt *buffer.ExtPacket)

+ func (m *Munger) UpdateAndGetPaddingSnTs(forceMarker bool) (uint16, uint32, error)

+ func (m *Munger) UpdateAndGetSnTs(extPkt *buffer.ExtPacket) (uint16, uint32, SequenceNumberOrdering, error)

+ func (m *Munger) UpdateSnTsOffsets(extPkt *buffer.ExtPacket, snAdjust uint16, tsAdjust uint32)

+ type MungerParams struct

+ type Prober struct

+ func NewProber() *Prober

+ func (p *Prober) AddCluster(desiredRateBps int, expectedRateBps int, minDuration time.Duration, ...)

+ func (p *Prober) IsRunning() bool

+ func (p *Prober) OnSendProbe(f func(bytesToSend int) int)

+ func (p *Prober) PacketSent(size int)

+ func (p *Prober) Reset()

+ type Receiver interface

+ AddDownTrack func(track *DownTrack, bestQualityFirst bool)

+ AddUpTrack func(track *webrtc.TrackRemote, buffer *buffer.Buffer, bestQualityFirst bool)

+ Codec func() webrtc.RTPCodecParameters

+ DebugInfo func() map[string]interface{}

+ DeleteDownTrack func(peerID string)

+ GetBitrate func() [3]uint64

+ GetBitrateTemporal func() [3][4]uint64

+ GetBitrateTemporalCumulative func() [3][4]uint64

+ GetMaxTemporalLayer func() [3]int32

+ GetSenderReportTime func(layer int32) (rtpTS uint32, ntpTS uint64)

+ HasSpatialLayer func(layer int32) bool

+ Kind func() webrtc.RTPCodecType

+ OnCloseHandler func(fn func())

+ RetransmitPackets func(track *DownTrack, packets []packetMeta) error

+ SSRC func(layer int) uint32

+ SendRTCP func(p []rtcp.Packet)

+ SetRTCPCh func(ch chan []rtcp.Packet)

+ SetTrackMeta func(trackID, streamID string)

+ SetUpTrackPaused func(paused bool)

+ StreamID func() string

+ TrackID func() string

+ func NewWebRTCReceiver(receiver *webrtc.RTPReceiver, track *webrtc.TrackRemote, pid string, ...) Receiver

+ type ReceiverOpts func(w *WebRTCReceiver) *WebRTCReceiver

+ func WithLoadBalanceThreshold(downTracks int) ReceiverOpts

+ func WithPliThrottle(period int64) ReceiverOpts

+ func WithStreamTrackers() ReceiverOpts

+ type ReceiverReportListener func(dt *DownTrack, report *rtcp.ReceiverReport)

+ type SequenceNumberOrdering int

+ const SequenceNumberOrderingContiguous

+ const SequenceNumberOrderingGap

+ const SequenceNumberOrderingOutOfOrder

+ const SequenceNumberOrderingUnknown

+ type Signal int

+ const Signal_ADD_TRACK

+ const Signal_AVAILABLE_LAYERS_ADD

+ const Signal_AVAILABLE_LAYERS_REMOVE

+ const Signal_ESTIMATE_DECREASE

+ const Signal_ESTIMATE_INCREASE

+ const Signal_NONE

+ const Signal_PERIODIC_PING

+ const Signal_RECEIVER_REPORT

+ const Signal_REMOVE_TRACK

+ const Signal_SUBSCRIPTION_CHANGE

+ type State int

+ const State_DEFICIENT

+ const State_GRATUITOUS_PROBING

+ const State_PRE_COMMIT

+ const State_STABLE

+ type StreamAllocator struct

+ func NewStreamAllocator() *StreamAllocator

+ func (s *StreamAllocator) AddTrack(downTrack *DownTrack)

+ func (s *StreamAllocator) RemoveTrack(downTrack *DownTrack)

+ func (s *StreamAllocator) Start()

+ func (s *StreamAllocator) Stop()

+ type StreamStatus int32

+ const StreamStatusActive

+ const StreamStatusStopped

+ func (s StreamStatus) String() string

+ type StreamTracker struct

+ CycleDuration time.Duration

+ CyclesRequired uint64

+ OnStatusChanged func(StreamStatus)

+ SamplesRequired uint32

+ func NewStreamTracker() *StreamTracker

+ func (s *StreamTracker) Observe(sn uint16)

+ func (s *StreamTracker) SetPaused(paused bool)

+ func (s *StreamTracker) Start()

+ func (s *StreamTracker) Status() StreamStatus

+ func (s *StreamTracker) Stop()

+ type Track struct

+ func NewTrack(downTrack *DownTrack) *Track

+ func (t *Track) AdjustAllocation(availableChannelCapacity uint64) (uint64, uint64)

+ func (t *Track) BandwidthOptimal() uint64

+ func (t *Track) BandwidthRequested() uint64

+ func (t *Track) GetPacketStats() (webrtc.RTPCodecType, uint32, uint32)

+ func (t *Track) IncreaseAllocation() (bool, uint64)

+ func (t *Track) UpdatePacketStats(rr *rtcp.ReceiverReport)

+ func (t *Track) WritePaddingRTP(bytesToSend int) int

+ type VP8Munger struct

+ func NewVP8Munger() *VP8Munger

+ func (v *VP8Munger) SetLast(extPkt *buffer.ExtPacket)

+ func (v *VP8Munger) UpdateAndGet(extPkt *buffer.ExtPacket, ordering SequenceNumberOrdering, ...) (*buffer.VP8, error)

+ func (v *VP8Munger) UpdateAndGetPadding(newPicture bool) (*buffer.VP8, error)

+ func (v *VP8Munger) UpdateOffsets(extPkt *buffer.ExtPacket)

+ type VP8MungerParams struct

+ type VP8PictureIdWrapHandler struct

+ func (v *VP8PictureIdWrapHandler) Init(extPictureId int32, mBit bool)

+ func (v *VP8PictureIdWrapHandler) MaxPictureId() int32

+ func (v *VP8PictureIdWrapHandler) Unwrap(pictureId uint16, mBit bool) (int32, bool)

+ func (v *VP8PictureIdWrapHandler) UpdateMaxPictureId(extPictureId int32, mBit bool)

+ type WebRTCReceiver struct

+ func (w *WebRTCReceiver) AddDownTrack(track *DownTrack, bestQualityFirst bool)

+ func (w *WebRTCReceiver) AddUpTrack(track *webrtc.TrackRemote, buff *buffer.Buffer, bestQualityFirst bool)

+ func (w *WebRTCReceiver) Codec() webrtc.RTPCodecParameters

+ func (w *WebRTCReceiver) DebugInfo() map[string]interface{}

+ func (w *WebRTCReceiver) DeleteDownTrack(peerID string)

+ func (w *WebRTCReceiver) GetBitrate() [3]uint64

+ func (w *WebRTCReceiver) GetBitrateTemporal() [3][4]uint64

+ func (w *WebRTCReceiver) GetBitrateTemporalCumulative() [3][4]uint64

+ func (w *WebRTCReceiver) GetMaxTemporalLayer() [3]int32

+ func (w *WebRTCReceiver) GetSenderReportTime(layer int32) (rtpTS uint32, ntpTS uint64)

+ func (w *WebRTCReceiver) HasSpatialLayer(layer int32) bool

+ func (w *WebRTCReceiver) Kind() webrtc.RTPCodecType

+ func (w *WebRTCReceiver) OnCloseHandler(fn func())

+ func (w *WebRTCReceiver) RetransmitPackets(track *DownTrack, packets []packetMeta) error

+ func (w *WebRTCReceiver) SSRC(layer int) uint32

+ func (w *WebRTCReceiver) SendRTCP(p []rtcp.Packet)

+ func (w *WebRTCReceiver) SetRTCPCh(ch chan []rtcp.Packet)

+ func (w *WebRTCReceiver) SetTrackMeta(trackID, streamID string)

+ func (w *WebRTCReceiver) SetUpTrackPaused(paused bool)

+ func (w *WebRTCReceiver) StreamID() string

+ func (w *WebRTCReceiver) TrackID() string