utils

Documentation

Index

• 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 NewTimedVersion(at time.Time, ticks int32) *TimedVersion
  • func NewTimedVersionFromProto(proto *livekit.TimedVersion) *TimedVersion
  • func (t *TimedVersion) After(other *TimedVersion) bool
  • func (t *TimedVersion) ToProto() *livekit.TimedVersion
  • func (t *TimedVersion) Update(at time.Time)

Types

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 NewTimedVersion

func NewTimedVersion(at time.Time, ticks int32) *TimedVersion

func NewTimedVersionFromProto

func NewTimedVersionFromProto(proto *livekit.TimedVersion) *TimedVersion

func (*TimedVersion) After

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

func (*TimedVersion) ToProto

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

func (*TimedVersion) Update

func (t *TimedVersion) Update(at time.Time)