utils

package

v1.6.1 Latest Latest Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/livekit/livekit-server

Links

Open Source Insights

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 GetAttempt(ctx context.Context) int
func GetLogger(ctx context.Context) logger.Logger
func MedianFloat32(input []float32) float32
type ChangeNotifier
- func NewChangeNotifier() *ChangeNotifier
- func (n *ChangeNotifier) AddObserver(key string, onChanged func())
- func (n *ChangeNotifier) HasObservers() bool
- func (n *ChangeNotifier) NotifyChanged()
- func (n *ChangeNotifier) RemoveObserver(key string)
type ChangeNotifierManager
- func NewChangeNotifierManager() *ChangeNotifierManager
- func (m *ChangeNotifierManager) GetNotifier(key string) *ChangeNotifier
- func (m *ChangeNotifierManager) GetOrCreateNotifier(key string) *ChangeNotifier
- func (m *ChangeNotifierManager) RemoveNotifier(key string, force bool)
type IceConfigCache
- func NewIceConfigCache[T comparable](ttl time.Duration) *IceConfigCache[T]
- func (icc *IceConfigCache[T]) Get(key T) *livekit.ICEConfig
- func (icc *IceConfigCache[T]) Put(key T, iceConfig *livekit.ICEConfig)
- func (icc *IceConfigCache[T]) Stop()
type IncrementalDispatcher
- func NewIncrementalDispatcher[T any]() *IncrementalDispatcher[T]
- func (d *IncrementalDispatcher[T]) Add(item T)
- func (d *IncrementalDispatcher[T]) Done()
- func (d *IncrementalDispatcher[T]) ForEach(fn func(T))
type OpsQueue
- func NewOpsQueue(params OpsQueueParams) *OpsQueue
- func (oq *OpsQueue) Enqueue(op T)
- func (oq *OpsQueue) Start()
- func (oq *OpsQueue) Stop() <-chan struct{}
type OpsQueueParams
type TypedOpsQueue
- func NewTypedOpsQueue[T any](params OpsQueueParams) *TypedOpsQueue[T]
- func (oq *TypedOpsQueue[T]) Enqueue(fn func(T), arg T)
- func (oq *TypedOpsQueue) Start()
- func (oq *TypedOpsQueue) Stop() <-chan struct{}
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 ¶ added in v1.5.2

func ClientInfoWithoutAddress(c *livekit.ClientInfo) *livekit.ClientInfo

func ContextWithAttempt ¶ added in v1.3.4

func ContextWithAttempt(ctx context.Context, attempt int) context.Context

func ContextWithLogger ¶ added in v1.5.2

func ContextWithLogger(ctx context.Context, logger logger.Logger) context.Context

func GetAttempt ¶ added in v1.3.4

func GetAttempt(ctx context.Context) int

func GetLogger ¶ added in v1.5.2

func GetLogger(ctx context.Context) logger.Logger

func MedianFloat32 ¶ added in v1.4.3

func MedianFloat32(input []float32) float32

MedianFloat32 gets median value for an array of float32

Types ¶

type ChangeNotifier ¶ added in v1.3.4

type ChangeNotifier struct {
	// contains filtered or unexported fields
}

func NewChangeNotifier ¶ added in v1.3.4

func NewChangeNotifier() *ChangeNotifier

func (*ChangeNotifier) AddObserver ¶ added in v1.3.4

func (n *ChangeNotifier) AddObserver(key string, onChanged func())

func (*ChangeNotifier) HasObservers ¶ added in v1.3.4

func (n *ChangeNotifier) HasObservers() bool

func (*ChangeNotifier) NotifyChanged ¶ added in v1.3.4

func (n *ChangeNotifier) NotifyChanged()

func (*ChangeNotifier) RemoveObserver ¶ added in v1.3.4

func (n *ChangeNotifier) RemoveObserver(key string)

type ChangeNotifierManager ¶ added in v1.3.4

type ChangeNotifierManager struct {
	// contains filtered or unexported fields
}

func NewChangeNotifierManager ¶ added in v1.3.4

func NewChangeNotifierManager() *ChangeNotifierManager

func (*ChangeNotifierManager) GetNotifier ¶ added in v1.3.4

func (m *ChangeNotifierManager) GetNotifier(key string) *ChangeNotifier

func (*ChangeNotifierManager) GetOrCreateNotifier ¶ added in v1.3.4

func (m *ChangeNotifierManager) GetOrCreateNotifier(key string) *ChangeNotifier

func (*ChangeNotifierManager) RemoveNotifier ¶ added in v1.3.4

func (m *ChangeNotifierManager) RemoveNotifier(key string, force bool)

type IceConfigCache ¶ added in v1.6.1

type IceConfigCache[T comparable] struct {
	// contains filtered or unexported fields
}

func NewIceConfigCache ¶ added in v1.6.1

func NewIceConfigCache[T comparable](ttl time.Duration) *IceConfigCache[T]

func (*IceConfigCache[T]) Get ¶ added in v1.6.1

func (icc *IceConfigCache[T]) Get(key T) *livekit.ICEConfig

func (*IceConfigCache[T]) Put ¶ added in v1.6.1

func (icc *IceConfigCache[T]) Put(key T, iceConfig *livekit.ICEConfig)

func (*IceConfigCache[T]) Stop ¶ added in v1.6.1

func (icc *IceConfigCache[T]) Stop()

type IncrementalDispatcher ¶ added in v1.6.0

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 ¶ added in v1.6.0

func NewIncrementalDispatcher[T any]() *IncrementalDispatcher[T]

func (*IncrementalDispatcher[T]) Add ¶ added in v1.6.0

func (d *IncrementalDispatcher[T]) Add(item T)

func (*IncrementalDispatcher[T]) Done ¶ added in v1.6.0

func (d *IncrementalDispatcher[T]) Done()

func (*IncrementalDispatcher[T]) ForEach ¶ added in v1.6.0

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

func (*OpsQueue) Enqueue ¶

func (oq *OpsQueue) Enqueue(op T)

func (*OpsQueue) Start ¶

func (oq *OpsQueue) Start()

func (*OpsQueue) Stop ¶

func (oq *OpsQueue) Stop() <-chan struct{}

type OpsQueueParams ¶ added in v1.6.0

type OpsQueueParams struct {
	Name        string
	MinSize     uint
	FlushOnStop bool
	Logger      logger.Logger
}

type TypedOpsQueue ¶ added in v1.6.1

type TypedOpsQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewTypedOpsQueue ¶ added in v1.6.1

func NewTypedOpsQueue[T any](params OpsQueueParams) *TypedOpsQueue[T]

func (*TypedOpsQueue[T]) Enqueue ¶ added in v1.6.1

func (oq *TypedOpsQueue[T]) Enqueue(fn func(T), arg T)

func (*TypedOpsQueue) Start ¶ added in v1.6.1

func (oq *TypedOpsQueue) Start()

func (*TypedOpsQueue) Stop ¶ added in v1.6.1

func (oq *TypedOpsQueue) Stop() <-chan struct{}

type UntypedQueueOp ¶ added in v1.6.1

type UntypedQueueOp func()

Source Files ¶

View all Source files

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