dynacast

Documentation

Index

• type DynacastManager
  • func NewDynacastManager(params DynacastManagerParams) *DynacastManager
  • func (d *DynacastManager) AddCodec(mime string)
  • func (d *DynacastManager) Close()
  • func (d *DynacastManager) ForceQuality(quality livekit.VideoQuality)
  • func (d *DynacastManager) ForceUpdate()
  • func (d *DynacastManager) NotifySubscriberMaxQuality(subscriberID livekit.ParticipantID, mime string, quality livekit.VideoQuality)
  • func (d *DynacastManager) NotifySubscriberNodeMaxQuality(nodeID livekit.NodeID, qualities []types.SubscribedCodecQuality)
  • func (d *DynacastManager) OnSubscribedMaxQualityChange(f func(subscribedQualities []*livekit.SubscribedCodec, ...))
  • func (d *DynacastManager) Restart()
• type DynacastManagerParams
• type DynacastQuality
  • func NewDynacastQuality(params DynacastQualityParams) *DynacastQuality
  • func (d *DynacastQuality) NotifySubscriberMaxQuality(subscriberID livekit.ParticipantID, quality livekit.VideoQuality)
  • func (d *DynacastQuality) NotifySubscriberNodeMaxQuality(nodeID livekit.NodeID, quality livekit.VideoQuality)
  • func (d *DynacastQuality) OnSubscribedMaxQualityChange(f func(mimeType string, maxSubscribedQuality livekit.VideoQuality))
  • func (d *DynacastQuality) Restart()
  • func (d *DynacastQuality) Start()
  • func (d *DynacastQuality) Stop()
• type DynacastQualityParams

Types

type DynacastManager

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

func NewDynacastManager

func NewDynacastManager(params DynacastManagerParams) *DynacastManager

func (*DynacastManager) AddCodec

func (d *DynacastManager) AddCodec(mime string)

func (*DynacastManager) Close

func (d *DynacastManager) Close()

func (*DynacastManager) ForceQuality

func (d *DynacastManager) ForceQuality(quality livekit.VideoQuality)

It is possible for tracks to be in pending close state. When track is waiting to be closed, a node is not streaming a track. This can be used to force an update announcing that subscribed quality is OFF, i.e. indicating not pulling track any more.

func (*DynacastManager) ForceUpdate

func (d *DynacastManager) ForceUpdate()

THere are situations like track unmute or streaming from a different node where subscribed quality needs to sent to the provider immediately. This bypasses any debouncing and forces a subscribed quality update with immediate effect.

func (*DynacastManager) NotifySubscriberMaxQuality

func (d *DynacastManager) NotifySubscriberMaxQuality(subscriberID livekit.ParticipantID, mime string, quality livekit.VideoQuality)

func (*DynacastManager) NotifySubscriberNodeMaxQuality

func (d *DynacastManager) NotifySubscriberNodeMaxQuality(nodeID livekit.NodeID, qualities []types.SubscribedCodecQuality)

func (*DynacastManager) OnSubscribedMaxQualityChange

func (d *DynacastManager) OnSubscribedMaxQualityChange(f func(subscribedQualities []*livekit.SubscribedCodec, maxSubscribedQualities []types.SubscribedCodecQuality))

func (*DynacastManager) Restart

func (d *DynacastManager) Restart()

type DynacastManagerParams

type DynacastManagerParams struct {
	DynacastPauseDelay time.Duration
	Logger             logger.Logger
}

type DynacastQuality

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

DynacastQuality manages max subscribed quality of a single receiver of a media track

func NewDynacastQuality

func NewDynacastQuality(params DynacastQualityParams) *DynacastQuality

func (*DynacastQuality) NotifySubscriberMaxQuality

func (d *DynacastQuality) NotifySubscriberMaxQuality(subscriberID livekit.ParticipantID, quality livekit.VideoQuality)

func (*DynacastQuality) NotifySubscriberNodeMaxQuality

func (d *DynacastQuality) NotifySubscriberNodeMaxQuality(nodeID livekit.NodeID, quality livekit.VideoQuality)

func (*DynacastQuality) OnSubscribedMaxQualityChange

func (d *DynacastQuality) OnSubscribedMaxQualityChange(f func(mimeType string, maxSubscribedQuality livekit.VideoQuality))

func (*DynacastQuality) Restart

func (d *DynacastQuality) Restart()

func (*DynacastQuality) Start

func (d *DynacastQuality) Start()

func (*DynacastQuality) Stop

func (d *DynacastQuality) Stop()

type DynacastQualityParams

type DynacastQualityParams struct {
	MimeType string
	Logger   logger.Logger
}