utils

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 OpsQueue
  • func NewOpsQueue(name string, minSize uint, flushOnStop bool) *OpsQueue
  • func (oq *OpsQueue) Enqueue(op func())
  • func (oq *OpsQueue) Start()
  • func (oq *OpsQueue) Stop() <-chan struct{}

Constants

const (
	ComponentPub       = "pub"
	ComponentSub       = "sub"
	ComponentRoom      = "room"
	ComponentAPI       = "api"
	ComponentTransport = "transport"
	ComponentSFU       = "sfu"
	// transport subcomponents
	ComponentCongestionControl = "cc"
)

Functions

func ClientInfoWithoutAddress

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

func ContextWithAttempt

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

func ContextWithLogger

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

func GetAttempt

func GetAttempt(ctx context.Context) int

func GetLogger

func GetLogger(ctx context.Context) logger.Logger

func MedianFloat32

func MedianFloat32(input []float32) float32

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 OpsQueue

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

func NewOpsQueue

func NewOpsQueue(name string, minSize uint, flushOnStop bool) *OpsQueue

func (*OpsQueue) Enqueue

func (oq *OpsQueue) Enqueue(op func())

func (*OpsQueue) Start

func (oq *OpsQueue) Start()

func (*OpsQueue) Stop

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