Documentation
¶
Index ¶
- Variables
- func CodecParametersFuzzySearch(needle webrtc.RTPCodecParameters, haystack []webrtc.RTPCodecParameters) (webrtc.RTPCodecParameters, error)
- func GetHeaderExtensionID(extensions []interceptor.RTPHeaderExtension, ...) int
- func ValidateRTPPacket(pkt *rtp.Packet, expectedPayloadType uint8, expectedSSRC uint32) error
- type Debouncer
- type OWDEstimator
- type OWDEstimatorParams
- type RangeMap
- func (r *RangeMap[RT, VT]) ClearAndResetValue(start RT, val VT)
- func (r *RangeMap[RT, VT]) DecValue(end RT, dec VT)
- func (r *RangeMap[RT, VT]) ExcludeRange(startInclusive RT, endExclusive RT) error
- func (r *RangeMap[RT, VT]) GetValue(key RT) (VT, error)
- func (r *RangeMap[RT, VT]) MarshalLogObject(e zapcore.ObjectEncoder) error
- type WrapAround
- func (w *WrapAround[T, ET]) GetExtendedHighest() ET
- func (w *WrapAround[T, ET]) GetExtendedStart() ET
- func (w *WrapAround[T, ET]) GetHighest() T
- func (w *WrapAround[T, ET]) GetStart() T
- func (w *WrapAround[T, ET]) ResetHighest(ev ET)
- func (w *WrapAround[T, ET]) RollbackRestart(ev ET)
- func (w *WrapAround[T, ET]) Rollover(val T, numCycles int) (result WrapAroundUpdateResult[ET])
- func (w *WrapAround[T, ET]) Seed(from *WrapAround[T, ET])
- func (w *WrapAround[T, ET]) UndoUpdate(result WrapAroundUpdateResult[ET])
- func (w *WrapAround[T, ET]) Update(val T) (result WrapAroundUpdateResult[ET])
- type WrapAroundParams
- type WrapAroundUpdateResult
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidRTPVersion = errors.New("invalid RTP version") ErrRTPPayloadTypeMismatch = errors.New("RTP payload type mismatch") ErrRTPSSRCMismatch = errors.New("RTP SSRC mismatch") )
View Source
var OWDEstimatorParamsDefault = OWDEstimatorParams{ PropagationDelayFallFactor: 0.9, PropagationDelayRiseFactor: 0.1, PropagationDelaySpikeAdaptationFactor: 0.5, PropagationDelayDeltaThresholdMin: 10 * time.Millisecond, PropagationDelayDeltaThresholdMaxFactor: 2, PropagationDelayDeltaHighResetNumReports: 2, PropagationDelayDeltaHighResetWait: 10 * time.Second, PropagationDelayDeltaLongTermAdaptationThreshold: 50 * time.Millisecond, }
Functions ¶
func CodecParametersFuzzySearch ¶ added in v1.5.3
func CodecParametersFuzzySearch(needle webrtc.RTPCodecParameters, haystack []webrtc.RTPCodecParameters) (webrtc.RTPCodecParameters, error)
Do a fuzzy find for a codec in the list of codecs Used for lookup up a codec in an existing list to find a match
func GetHeaderExtensionID ¶ added in v1.5.3
func GetHeaderExtensionID(extensions []interceptor.RTPHeaderExtension, extension webrtc.RTPHeaderExtensionCapability) int
GetHeaderExtensionID returns the ID of a header extension, or 0 if not found
Types ¶
type Debouncer ¶ added in v1.8.0
type Debouncer struct {
// contains filtered or unexported fields
}
func NewDebouncer ¶ added in v1.8.0
func (*Debouncer) SetDuration ¶ added in v1.8.0
type OWDEstimator ¶ added in v1.8.0
type OWDEstimator struct {
// contains filtered or unexported fields
}
func NewOWDEstimator ¶ added in v1.8.0
func NewOWDEstimator(params OWDEstimatorParams) *OWDEstimator
func (*OWDEstimator) EstimatedPropagationDelay ¶ added in v1.8.0
func (o *OWDEstimator) EstimatedPropagationDelay() time.Duration
func (*OWDEstimator) MarshalLogObject ¶ added in v1.8.0
func (o *OWDEstimator) MarshalLogObject(e zapcore.ObjectEncoder) error
type OWDEstimatorParams ¶ added in v1.8.0
type OWDEstimatorParams struct {
PropagationDelayFallFactor float64
PropagationDelayRiseFactor float64
PropagationDelaySpikeAdaptationFactor float64
PropagationDelayDeltaThresholdMin time.Duration
PropagationDelayDeltaThresholdMaxFactor int
PropagationDelayDeltaHighResetNumReports int
PropagationDelayDeltaHighResetWait time.Duration
PropagationDelayDeltaLongTermAdaptationThreshold time.Duration
}
type RangeMap ¶ added in v1.5.0
type RangeMap[RT rangeType, VT valueType] struct {
// contains filtered or unexported fields
}
func NewRangeMap ¶ added in v1.5.0
func (*RangeMap[RT, VT]) ClearAndResetValue ¶ added in v1.5.0
func (r *RangeMap[RT, VT]) ClearAndResetValue(start RT, val VT)
func (*RangeMap[RT, VT]) DecValue ¶ added in v1.5.0
func (r *RangeMap[RT, VT]) DecValue(end RT, dec VT)
func (*RangeMap[RT, VT]) ExcludeRange ¶ added in v1.5.0
func (*RangeMap[RT, VT]) MarshalLogObject ¶ added in v1.6.2
func (r *RangeMap[RT, VT]) MarshalLogObject(e zapcore.ObjectEncoder) error
type WrapAround ¶
type WrapAround[T number, ET extendedNumber] struct {
// contains filtered or unexported fields
}
func NewWrapAround ¶
func NewWrapAround[T number, ET extendedNumber](params WrapAroundParams) *WrapAround[T, ET]
func (*WrapAround[T, ET]) GetExtendedHighest ¶
func (w *WrapAround[T, ET]) GetExtendedHighest() ET
func (*WrapAround[T, ET]) GetExtendedStart ¶
func (w *WrapAround[T, ET]) GetExtendedStart() ET
func (*WrapAround[T, ET]) GetHighest ¶
func (w *WrapAround[T, ET]) GetHighest() T
func (*WrapAround[T, ET]) GetStart ¶
func (w *WrapAround[T, ET]) GetStart() T
func (*WrapAround[T, ET]) ResetHighest ¶
func (w *WrapAround[T, ET]) ResetHighest(ev ET)
func (*WrapAround[T, ET]) RollbackRestart ¶ added in v1.5.0
func (w *WrapAround[T, ET]) RollbackRestart(ev ET)
func (*WrapAround[T, ET]) Rollover ¶ added in v1.7.1
func (w *WrapAround[T, ET]) Rollover(val T, numCycles int) (result WrapAroundUpdateResult[ET])
func (*WrapAround[T, ET]) Seed ¶
func (w *WrapAround[T, ET]) Seed(from *WrapAround[T, ET])
func (*WrapAround[T, ET]) UndoUpdate ¶ added in v1.7.1
func (w *WrapAround[T, ET]) UndoUpdate(result WrapAroundUpdateResult[ET])
func (*WrapAround[T, ET]) Update ¶
func (w *WrapAround[T, ET]) Update(val T) (result WrapAroundUpdateResult[ET])
type WrapAroundParams ¶ added in v1.5.2
type WrapAroundParams struct {
IsRestartAllowed bool
}
type WrapAroundUpdateResult ¶ added in v1.5.0
type WrapAroundUpdateResult[ET extendedNumber] struct {
IsUnhandled bool // when set, other fields are invalid
IsRestart bool
PreExtendedStart ET // valid only if IsRestart = true
PreExtendedHighest ET
ExtendedVal ET
}
func (*WrapAroundUpdateResult[ET]) MarshalLogObject ¶ added in v1.7.1
func (w *WrapAroundUpdateResult[ET]) MarshalLogObject(e zapcore.ObjectEncoder) error
Click to show internal directories.
Click to hide internal directories.