Documentation
¶
Index ¶
- Constants
- func ClientInfoWithoutAddress(c *livekit.ClientInfo) *livekit.ClientInfo
- func ContextWithAttempt(ctx context.Context, attempt int) context.Context
- func ContextWithLogger(ctx context.Context, logger logger.Logger) context.Context
- func DedupeSlice[T cmp.Ordered](s []T) []T
- func GetAttempt(ctx context.Context) int
- func GetLogger(ctx context.Context) logger.Logger
- func MedianFloat32(input []float32) float32
- type ChangeNotifier
- type ChangeNotifierManager
- type IceConfigCache
- type IncrementalDispatcher
- type OpsQueue
- type OpsQueueParams
- type TypedOpsQueue
- type UntypedQueueOp
Constants ¶
View Source
const ( ComponentPub = "pub" ComponentSub = "sub" ComponentRoom = "room" ComponentAPI = "api" ComponentTransport = "transport" ComponentSFU = "sfu" // transport subcomponents ComponentCongestionControl = "cc" )
Variables ¶
This section is empty.
Functions ¶
func ClientInfoWithoutAddress ¶
func ClientInfoWithoutAddress(c *livekit.ClientInfo) *livekit.ClientInfo
func ContextWithLogger ¶
func DedupeSlice ¶
func GetAttempt ¶
func MedianFloat32 ¶
MedianFloat32 gets median value for an array of float32
Types ¶
type ChangeNotifier ¶
type ChangeNotifier struct {
// contains filtered or unexported fields
}
func NewChangeNotifier ¶
func NewChangeNotifier() *ChangeNotifier
func (*ChangeNotifier) AddObserver ¶
func (n *ChangeNotifier) AddObserver(key string, onChanged func())
func (*ChangeNotifier) HasObservers ¶
func (n *ChangeNotifier) HasObservers() bool
func (*ChangeNotifier) NotifyChanged ¶
func (n *ChangeNotifier) NotifyChanged()
func (*ChangeNotifier) RemoveObserver ¶
func (n *ChangeNotifier) RemoveObserver(key string)
type ChangeNotifierManager ¶
type ChangeNotifierManager struct {
// contains filtered or unexported fields
}
func NewChangeNotifierManager ¶
func NewChangeNotifierManager() *ChangeNotifierManager
func (*ChangeNotifierManager) GetNotifier ¶
func (m *ChangeNotifierManager) GetNotifier(key string) *ChangeNotifier
func (*ChangeNotifierManager) GetOrCreateNotifier ¶
func (m *ChangeNotifierManager) GetOrCreateNotifier(key string) *ChangeNotifier
func (*ChangeNotifierManager) RemoveNotifier ¶
func (m *ChangeNotifierManager) RemoveNotifier(key string, force bool)
type IceConfigCache ¶
type IceConfigCache[T comparable] struct { // contains filtered or unexported fields }
func NewIceConfigCache ¶
func NewIceConfigCache[T comparable](ttl time.Duration) *IceConfigCache[T]
func (*IceConfigCache[T]) Get ¶
func (icc *IceConfigCache[T]) Get(key T) *livekit.ICEConfig
func (*IceConfigCache[T]) Put ¶
func (icc *IceConfigCache[T]) Put(key T, iceConfig *livekit.ICEConfig)
func (*IceConfigCache[T]) Stop ¶
func (icc *IceConfigCache[T]) Stop()
type IncrementalDispatcher ¶
type IncrementalDispatcher[T any] struct { // contains filtered or unexported fields }
IncrementalDispatcher is a dispatcher that allows multiple consumers to consume items as they become available, while producers can add items at anytime.
func NewIncrementalDispatcher ¶
func NewIncrementalDispatcher[T any]() *IncrementalDispatcher[T]
func (*IncrementalDispatcher[T]) Add ¶
func (d *IncrementalDispatcher[T]) Add(item T)
func (*IncrementalDispatcher[T]) Done ¶
func (d *IncrementalDispatcher[T]) Done()
func (*IncrementalDispatcher[T]) ForEach ¶
func (d *IncrementalDispatcher[T]) ForEach(fn func(T))
type OpsQueue ¶
type OpsQueue struct {
// contains filtered or unexported fields
}
func NewOpsQueue ¶
func NewOpsQueue(params OpsQueueParams) *OpsQueue
type OpsQueueParams ¶
type TypedOpsQueue ¶
type TypedOpsQueue[T any] struct { // contains filtered or unexported fields }
func NewTypedOpsQueue ¶
func NewTypedOpsQueue[T any](params OpsQueueParams) *TypedOpsQueue[T]
func (*TypedOpsQueue[T]) Enqueue ¶
func (oq *TypedOpsQueue[T]) Enqueue(fn func(T), arg T)
type UntypedQueueOp ¶
type UntypedQueueOp func()
Source Files
Click to show internal directories.
Click to hide internal directories.