Documentation ¶
Index ¶
- Constants
- Variables
- func EnableLockTracker()
- func GetMimeTypeForAudioCodec(codec livekit.AudioCodec) string
- func GetMimeTypeForVideoCodec(codec livekit.VideoCodec) string
- func HashedID(id string) string
- func Least[T Numeric](less func(a, b T) bool, vs ...T) T
- func LocalNodeID() (string, error)
- func MarshalGuid[T livekit.Guid](id T) livekit.GuidBlock
- func Max[T Numeric](vs ...T) T
- func Min[T Numeric](vs ...T) T
- func Most[T Numeric](less func(a, b T) bool, vs ...T) T
- func NewGuid(prefix string) string
- func NumMutexes() int
- func ParallelExec[T any](vals []T, parallelThreshold, step uint64, fn func(T))
- func RandomSecret() string
- func UnmarshalGuid[T livekit.Guid](b livekit.GuidBlock) T
- type CPUStats
- type ErrArray
- type EventEmitter
- type EventEmitterParams
- type EventObserver
- type EventObserverList
- type FlowGraph
- type Graph
- func (g *Graph[K, N, E]) DeleteEdge(src, dst K)
- func (g *Graph[K, N, E]) DeleteNode(id K)
- func (g *Graph[K, N, E]) Edge(src, dst K) (p E)
- func (g *Graph[K, N, E]) HasEdge(src, dst K) bool
- func (g *Graph[K, N, E]) HasNode(id K) bool
- func (g *Graph[K, N, E]) InEdges(dst K) map[K]E
- func (g *Graph[K, N, E]) InsertEdge(src, dst K, props E)
- func (g *Graph[K, N, E]) InsertNode(props N)
- func (g *Graph[K, N, E]) Node(id K) (props N)
- func (g *Graph[K, N, E]) OutEdges(src K) map[K]E
- func (g *Graph[K, N, E]) ShortestPath(src, dst K) ([]N, int64)
- func (g *Graph[K, N, E]) Size() int
- func (g *Graph[K, N, E]) TopologicalSort() []N
- type GraphEdge
- type GraphEdgeProps
- type GraphNode
- type GraphNodeProps
- type MessageBus
- type MinCostMaxFlow
- type Mutex
- type Numeric
- type ProtoProxy
- type PubSub
- type RWMutex
- type RedisMessageBus
- func (r *RedisMessageBus) Lock(ctx context.Context, key string, expiration time.Duration) (bool, error)
- func (r *RedisMessageBus) Publish(ctx context.Context, channel string, msg proto.Message) error
- func (r *RedisMessageBus) Subscribe(ctx context.Context, channel string) (PubSub, error)
- func (r *RedisMessageBus) SubscribeQueue(ctx context.Context, channel string) (PubSub, error)
- type RedisPubSub
- type StuckLock
- type TimedAggregator
- func (t *TimedAggregator[T]) AddSample(val T) error
- func (t *TimedAggregator[T]) AddSampleAt(val T, at time.Time) error
- func (t *TimedAggregator[T]) GetAggregate() (T, time.Duration)
- func (t *TimedAggregator[T]) GetAggregateAndRestartAt(at time.Time) (T, time.Duration, error)
- func (t *TimedAggregator[T]) GetAggregateAt(at time.Time) (T, time.Duration, error)
- func (t *TimedAggregator[T]) GetAverage() float64
- func (t *TimedAggregator[T]) GetAverageAndRestartAt(at time.Time) (float64, error)
- func (t *TimedAggregator[T]) GetAverageAt(at time.Time) (float64, error)
- func (t *TimedAggregator[T]) Reset()
- func (t *TimedAggregator[T]) Restart()
- func (t *TimedAggregator[T]) RestartAt(at time.Time)
- type TimedAggregatorParams
- type TimedVersion
- func (t *TimedVersion) After(other *TimedVersion) bool
- func (t *TimedVersion) Compare(other *TimedVersion) int
- func (t *TimedVersion) IsZero() bool
- func (t *TimedVersion) Load() TimedVersion
- func (t *TimedVersion) Store(other *TimedVersion)
- func (t *TimedVersion) String() string
- func (t *TimedVersion) Time() time.Time
- func (t *TimedVersion) ToProto() *livekit.TimedVersion
- func (t *TimedVersion) Update(other *TimedVersion) bool
- type TimedVersionGenerator
- type Welford
- type WorkerGroup
Constants ¶
const ( RoomPrefix = "RM_" NodePrefix = "ND_" ParticipantPrefix = "PA_" TrackPrefix = "TR_" APIKeyPrefix = "API" EgressPrefix = "EG_" IngressPrefix = "IN_" RPCPrefix = "RPC_" WHIPResourcePrefix = "WH_" RTMPResourcePrefix = "RT_" )
Variables ¶
var (
ErrAnachronousSample = errors.New("anachronous sample")
)
var ( PromMessageBusCounter = prometheus.NewCounterVec( prometheus.CounterOpts{ Namespace: "livekit", Subsystem: "messagebus", Name: "messages", }, []string{"type", "status"}, ) )
Functions ¶
func EnableLockTracker ¶ added in v1.4.0
func EnableLockTracker()
EnableLockTracker enable lock tracking background worker. This should be called during init
func GetMimeTypeForAudioCodec ¶ added in v1.5.1
func GetMimeTypeForAudioCodec(codec livekit.AudioCodec) string
func GetMimeTypeForVideoCodec ¶ added in v1.5.1
func GetMimeTypeForVideoCodec(codec livekit.VideoCodec) string
func LocalNodeID ¶ added in v0.11.1
func NumMutexes ¶ added in v1.4.0
func NumMutexes() int
func ParallelExec ¶ added in v1.4.3
ParallelExec will executes the given function with each element of vals, if len(vals) >= parallelThreshold, will execute them in parallel, with the given step size. So fn must be thread-safe.
func RandomSecret ¶
func RandomSecret() string
Types ¶
type CPUStats ¶ added in v1.2.0
type CPUStats struct {
// contains filtered or unexported fields
}
func NewCPUStats ¶ added in v1.2.0
func (*CPUStats) GetCPUIdle ¶ added in v1.2.0
type EventEmitter ¶ added in v1.5.7
type EventEmitter[K comparable, V any] struct { // contains filtered or unexported fields }
func NewDefaultEventEmitter ¶ added in v1.5.7
func NewDefaultEventEmitter[K comparable, V any]() *EventEmitter[K, V]
func NewEventEmitter ¶ added in v1.5.7
func NewEventEmitter[K comparable, V any](params EventEmitterParams) *EventEmitter[K, V]
func (*EventEmitter[K, V]) Emit ¶ added in v1.5.7
func (e *EventEmitter[K, V]) Emit(k K, v V)
func (*EventEmitter[K, V]) Observe ¶ added in v1.5.7
func (e *EventEmitter[K, V]) Observe(k K) *EventObserver[V]
func (*EventEmitter[K, V]) ObservedKeys ¶ added in v1.5.7
func (e *EventEmitter[K, V]) ObservedKeys() []K
type EventEmitterParams ¶ added in v1.5.7
func DefaultEventEmitterParams ¶ added in v1.5.8
func DefaultEventEmitterParams() EventEmitterParams
type EventObserver ¶ added in v1.5.7
type EventObserver[V any] struct { // contains filtered or unexported fields }
func NewEventObserver ¶ added in v1.5.7
func NewEventObserver[V any](stopFunc func()) (*EventObserver[V], func(v V))
func (*EventObserver[V]) Events ¶ added in v1.5.7
func (o *EventObserver[V]) Events() <-chan V
func (*EventObserver[V]) Stop ¶ added in v1.5.7
func (o *EventObserver[V]) Stop()
type EventObserverList ¶ added in v1.5.8
type EventObserverList[V any] struct { // contains filtered or unexported fields }
func NewDefaultEventObserverList ¶ added in v1.5.8
func NewDefaultEventObserverList[V any]() *EventObserverList[V]
func NewEventObserverList ¶ added in v1.5.8
func NewEventObserverList[V any](params EventEmitterParams) *EventObserverList[V]
func (*EventObserverList[V]) Emit ¶ added in v1.5.8
func (l *EventObserverList[V]) Emit(v V)
func (*EventObserverList[V]) Len ¶ added in v1.5.8
func (l *EventObserverList[V]) Len() int
func (*EventObserverList[V]) Observe ¶ added in v1.5.8
func (l *EventObserverList[V]) Observe() *EventObserver[V]
type FlowGraph ¶ added in v1.5.7
type FlowGraph struct {
// contains filtered or unexported fields
}
func NewFlowGraph ¶ added in v1.5.7
type Graph ¶ added in v1.5.7
type Graph[K comparable, N GraphNodeProps[K], E GraphEdgeProps] struct { // contains filtered or unexported fields }
func NewGraph ¶ added in v1.5.7
func NewGraph[K comparable, N GraphNodeProps[K], E GraphEdgeProps]() *Graph[K, N, E]
func (*Graph[K, N, E]) DeleteEdge ¶ added in v1.5.7
func (g *Graph[K, N, E]) DeleteEdge(src, dst K)
func (*Graph[K, N, E]) DeleteNode ¶ added in v1.5.8
func (g *Graph[K, N, E]) DeleteNode(id K)
func (*Graph[K, N, E]) InsertEdge ¶ added in v1.5.7
func (g *Graph[K, N, E]) InsertEdge(src, dst K, props E)
func (*Graph[K, N, E]) InsertNode ¶ added in v1.5.7
func (g *Graph[K, N, E]) InsertNode(props N)
func (*Graph[K, N, E]) ShortestPath ¶ added in v1.5.7
func (*Graph[K, N, E]) TopologicalSort ¶ added in v1.5.7
func (g *Graph[K, N, E]) TopologicalSort() []N
type GraphEdge ¶ added in v1.5.7
type GraphEdge[N, E any] struct { // contains filtered or unexported fields }
type GraphEdgeProps ¶ added in v1.5.7
type GraphEdgeProps interface {
Length() int64
}
type GraphNode ¶ added in v1.5.7
type GraphNode[T any] struct { // contains filtered or unexported fields }
type GraphNodeProps ¶ added in v1.5.7
type GraphNodeProps[K comparable] interface { ID() K }
type MessageBus ¶ added in v0.8.4
type MessageBus interface { Subscribe(ctx context.Context, channel string) (PubSub, error) // SubscribeQueue is like subscribe, but ensuring only a single instance gets to process the message SubscribeQueue(ctx context.Context, channel string) (PubSub, error) Publish(ctx context.Context, channel string, msg proto.Message) error }
func NewRedisMessageBus ¶ added in v0.8.4
func NewRedisMessageBus(rc redis.UniversalClient) MessageBus
type MinCostMaxFlow ¶ added in v1.5.7
type MinCostMaxFlow struct {
// contains filtered or unexported fields
}
func (*MinCostMaxFlow) ComputeMaxFlow ¶ added in v1.5.7
func (f *MinCostMaxFlow) ComputeMaxFlow(g FlowGraph, s, t int64) (flow, cost int64)
func (*MinCostMaxFlow) Flow ¶ added in v1.5.7
func (f *MinCostMaxFlow) Flow(s, t int64) int64
type Numeric ¶ added in v1.5.9
type Numeric interface { constraints.Signed | constraints.Unsigned | time.Duration }
type ProtoProxy ¶ added in v1.5.5
ProtoProxy is a caching proxy for protobuf messages that may be expensive to compute. It is used to avoid unnecessary re-generation of Protobufs
func NewProtoProxy ¶ added in v1.5.5
func NewProtoProxy[T proto.Message](refreshInterval time.Duration, updateFn func() T) *ProtoProxy[T]
NewProtoProxy creates a new ProtoProxy that regenerates underlying values at a cadence of refreshInterval this should be used for updates that should be sent periodically, but does not have the urgency of immediate delivery updateFn should provide computations required to generate the protobuf if refreshInterval is 0, then proxy will only update on MarkDirty(true)
func (*ProtoProxy[T]) Get ¶ added in v1.5.5
func (p *ProtoProxy[T]) Get() T
func (*ProtoProxy[T]) MarkDirty ¶ added in v1.5.5
func (p *ProtoProxy[T]) MarkDirty(immediate bool)
func (*ProtoProxy[T]) Stop ¶ added in v1.5.5
func (p *ProtoProxy[T]) Stop()
func (*ProtoProxy[T]) Updated ¶ added in v1.5.5
func (p *ProtoProxy[T]) Updated() <-chan struct{}
type RedisMessageBus ¶ added in v0.8.4
type RedisMessageBus struct {
// contains filtered or unexported fields
}
func (*RedisMessageBus) SubscribeQueue ¶ added in v0.9.3
type RedisPubSub ¶ added in v0.8.4
type RedisPubSub struct {
// contains filtered or unexported fields
}
func (*RedisPubSub) Channel ¶ added in v0.8.4
func (r *RedisPubSub) Channel() <-chan interface{}
func (*RedisPubSub) Close ¶ added in v0.8.4
func (r *RedisPubSub) Close() error
func (*RedisPubSub) Payload ¶ added in v0.8.4
func (r *RedisPubSub) Payload(msg interface{}) []byte
type StuckLock ¶ added in v1.5.7
type StuckLock struct {
// contains filtered or unexported fields
}
func ScanTrackedLocks ¶ added in v1.4.0
ScanTrackedLocks check all lock trackers
func ScanTrackedLocksI ¶ added in v1.4.0
ScanTrackedLocksI check lock trackers incrementally n at a time
func (*StuckLock) FirstLockedAtStack ¶ added in v1.5.7
func (*StuckLock) NumGoroutineHeld ¶ added in v1.5.7
func (*StuckLock) NumGoroutineWaiting ¶ added in v1.5.7
type TimedAggregator ¶ added in v1.5.9
type TimedAggregator[T number] struct {
// contains filtered or unexported fields
}
func NewTimedAggregator ¶ added in v1.5.9
func NewTimedAggregator[T number](params TimedAggregatorParams) *TimedAggregator[T]
func (*TimedAggregator[T]) AddSample ¶ added in v1.5.9
func (t *TimedAggregator[T]) AddSample(val T) error
func (*TimedAggregator[T]) AddSampleAt ¶ added in v1.5.9
func (t *TimedAggregator[T]) AddSampleAt(val T, at time.Time) error
func (*TimedAggregator[T]) GetAggregate ¶ added in v1.5.9
func (t *TimedAggregator[T]) GetAggregate() (T, time.Duration)
func (*TimedAggregator[T]) GetAggregateAndRestartAt ¶ added in v1.5.9
func (*TimedAggregator[T]) GetAggregateAt ¶ added in v1.5.9
func (*TimedAggregator[T]) GetAverage ¶ added in v1.5.9
func (t *TimedAggregator[T]) GetAverage() float64
func (*TimedAggregator[T]) GetAverageAndRestartAt ¶ added in v1.5.9
func (t *TimedAggregator[T]) GetAverageAndRestartAt(at time.Time) (float64, error)
func (*TimedAggregator[T]) GetAverageAt ¶ added in v1.5.9
func (t *TimedAggregator[T]) GetAverageAt(at time.Time) (float64, error)
func (*TimedAggregator[T]) Reset ¶ added in v1.5.9
func (t *TimedAggregator[T]) Reset()
func (*TimedAggregator[T]) Restart ¶ added in v1.5.9
func (t *TimedAggregator[T]) Restart()
func (*TimedAggregator[T]) RestartAt ¶ added in v1.5.9
func (t *TimedAggregator[T]) RestartAt(at time.Time)
type TimedAggregatorParams ¶ added in v1.5.9
type TimedAggregatorParams struct {
CapNegativeValues bool
}
type TimedVersion ¶ added in v1.4.3
type TimedVersion struct {
// contains filtered or unexported fields
}
func NewTimedVersionFromProto ¶ added in v1.4.3
func NewTimedVersionFromProto(proto *livekit.TimedVersion) *TimedVersion
func NewTimedVersionFromTime ¶ added in v1.4.3
func NewTimedVersionFromTime(t time.Time) *TimedVersion
func TimedVersionFromProto ¶ added in v1.4.3
func TimedVersionFromProto(proto *livekit.TimedVersion) TimedVersion
func TimedVersionFromTime ¶ added in v1.4.3
func TimedVersionFromTime(t time.Time) TimedVersion
func (*TimedVersion) After ¶ added in v1.4.3
func (t *TimedVersion) After(other *TimedVersion) bool
func (*TimedVersion) Compare ¶ added in v1.4.3
func (t *TimedVersion) Compare(other *TimedVersion) int
func (*TimedVersion) IsZero ¶ added in v1.5.5
func (t *TimedVersion) IsZero() bool
func (*TimedVersion) Load ¶ added in v1.4.3
func (t *TimedVersion) Load() TimedVersion
func (*TimedVersion) Store ¶ added in v1.4.3
func (t *TimedVersion) Store(other *TimedVersion)
func (*TimedVersion) String ¶ added in v1.4.3
func (t *TimedVersion) String() string
func (*TimedVersion) Time ¶ added in v1.4.3
func (t *TimedVersion) Time() time.Time
func (*TimedVersion) ToProto ¶ added in v1.4.3
func (t *TimedVersion) ToProto() *livekit.TimedVersion
func (*TimedVersion) Update ¶ added in v1.4.3
func (t *TimedVersion) Update(other *TimedVersion) bool
type TimedVersionGenerator ¶ added in v1.4.3
type TimedVersionGenerator interface { New() *TimedVersion Next() TimedVersion }
func NewDefaultTimedVersionGenerator ¶ added in v1.4.3
func NewDefaultTimedVersionGenerator() TimedVersionGenerator
type Welford ¶ added in v1.5.9
type Welford struct {
// contains filtered or unexported fields
}
Welford implements Welford's online algorithm for variance SEE: https://en.wikipedia.org/wiki/Algorithms_for_calculating_variance#Welford's_online_algorithm
func WelfordMerge ¶ added in v1.5.9
type WorkerGroup ¶ added in v1.5.2
type WorkerGroup struct {
// contains filtered or unexported fields
}
func (*WorkerGroup) Go ¶ added in v1.5.2
func (w *WorkerGroup) Go(fn func())
func (*WorkerGroup) Wait ¶ added in v1.5.2
func (w *WorkerGroup) Wait()