utils

Documentation

Index

• func ContextWithAttempt(ctx context.Context, attempt int) context.Context
• func GetAttempt(ctx context.Context) int
• 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(logger logger.Logger, name string, size int) *OpsQueue
  • func (oq *OpsQueue) Enqueue(op func())
  • func (oq *OpsQueue) IsStarted() bool
  • func (oq *OpsQueue) SetLogger(logger logger.Logger)
  • func (oq *OpsQueue) Start()
  • func (oq *OpsQueue) Stop()
• type TimedVersion
  • func NewTimedVersionFromProto(ptv *livekit.TimedVersion) *TimedVersion
  • func (t *TimedVersion) After(other *TimedVersion) bool
  • func (t *TimedVersion) String() string
  • func (t *TimedVersion) ToProto() *livekit.TimedVersion
  • func (t *TimedVersion) Update(other *TimedVersion)
• type TimedVersionGenerator
  • func NewDefaultTimedVersionGenerator() TimedVersionGenerator

Functions

func ContextWithAttempt

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

func GetAttempt

func GetAttempt(ctx context.Context) int

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(logger logger.Logger, name string, size int) *OpsQueue

func (*OpsQueue) Enqueue

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

func (*OpsQueue) IsStarted

func (oq *OpsQueue) IsStarted() bool

func (*OpsQueue) SetLogger

func (oq *OpsQueue) SetLogger(logger logger.Logger)

func (*OpsQueue) Start

func (oq *OpsQueue) Start()

func (*OpsQueue) Stop

func (oq *OpsQueue) Stop()

type TimedVersion

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

func NewTimedVersionFromProto

func NewTimedVersionFromProto(ptv *livekit.TimedVersion) *TimedVersion

func (*TimedVersion) After

func (t *TimedVersion) After(other *TimedVersion) bool

func (*TimedVersion) String

func (t *TimedVersion) String() string

func (*TimedVersion) ToProto

func (t *TimedVersion) ToProto() *livekit.TimedVersion

func (*TimedVersion) Update

func (t *TimedVersion) Update(other *TimedVersion)

type TimedVersionGenerator

type TimedVersionGenerator interface {
	New() *TimedVersion
}

func NewDefaultTimedVersionGenerator

func NewDefaultTimedVersionGenerator() TimedVersionGenerator