stats

Documentation

Index

• Constants
• func LogMediaStats(s *ipc.MediaStats, logger logger.Logger)
• type LocalMediaStatsGatherer
  • func NewLocalMediaStatsGatherer() *LocalMediaStatsGatherer
  • func (l *LocalMediaStatsGatherer) GatherStats(ctx context.Context) (*ipc.MediaStats, error)
  • func (l *LocalMediaStatsGatherer) RegisterTrackStats(path string) *MediaTrackStatGatherer
• type LocalStatsUpdater
  • func (a *LocalStatsUpdater) UpdateMediaStats(ctx context.Context, s *ipc.MediaStats) error
• type MediaStatsReporter
  • func NewMediaStats(statsUpdater types.MediaStatsUpdater) *MediaStatsReporter
  • func (m *MediaStatsReporter) Close()
  • func (m *MediaStatsReporter) RegisterGatherer(g types.MediaStatGatherer)
  • func (m *MediaStatsReporter) UpdateStats(ctx context.Context)
• type MediaTrackStatGatherer
  • func NewMediaTrackStatGatherer(path string) *MediaTrackStatGatherer
  • func (g *MediaTrackStatGatherer) MediaReceived(size int64)
  • func (g *MediaTrackStatGatherer) PLI()
  • func (g *MediaTrackStatGatherer) PacketLost(count int64)
  • func (g *MediaTrackStatGatherer) Path() string
  • func (g *MediaTrackStatGatherer) UpdateStats() *ipc.TrackStats
• type Monitor
  • func NewMonitor() *Monitor
  • func (m *Monitor) AcceptIngress(info *livekit.IngressInfo) bool
  • func (m *Monitor) CanAccept() bool
  • func (m *Monitor) CanAcceptIngress(info *livekit.IngressInfo) bool
  • func (m *Monitor) GetCPULoad() float64
  • func (m *Monitor) IngressEnded(info *livekit.IngressInfo)
  • func (m *Monitor) IngressStarted(info *livekit.IngressInfo)
  • func (m *Monitor) Shutdown()
  • func (m *Monitor) Start(conf *config.Config) error
  • func (m *Monitor) Stop()
  • func (m *Monitor) UpdateCostConfig(cpuCostConfig *config.CPUCostConfig) error

Constants

const (
	InputAudio  = "input.audio"
	InputVideo  = "input.video"
	OutputAudio = "output.audio"
	OutputVideo = "output.video"
)

Functions

func LogMediaStats

func LogMediaStats(s *ipc.MediaStats, logger logger.Logger)

Types

type LocalMediaStatsGatherer

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

func NewLocalMediaStatsGatherer

func NewLocalMediaStatsGatherer() *LocalMediaStatsGatherer

func (*LocalMediaStatsGatherer) GatherStats

func (l *LocalMediaStatsGatherer) GatherStats(ctx context.Context) (*ipc.MediaStats, error)

func (*LocalMediaStatsGatherer) RegisterTrackStats

func (l *LocalMediaStatsGatherer) RegisterTrackStats(path string) *MediaTrackStatGatherer

type LocalStatsUpdater

type LocalStatsUpdater struct {
	Params *params.Params
}

func (*LocalStatsUpdater) UpdateMediaStats

func (a *LocalStatsUpdater) UpdateMediaStats(ctx context.Context, s *ipc.MediaStats) error

type MediaStatsReporter

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

func NewMediaStats

func NewMediaStats(statsUpdater types.MediaStatsUpdater) *MediaStatsReporter

func (*MediaStatsReporter) Close

func (m *MediaStatsReporter) Close()

func (*MediaStatsReporter) RegisterGatherer

func (m *MediaStatsReporter) RegisterGatherer(g types.MediaStatGatherer)

func (*MediaStatsReporter) UpdateStats

func (m *MediaStatsReporter) UpdateStats(ctx context.Context)

type MediaTrackStatGatherer

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

func NewMediaTrackStatGatherer

func NewMediaTrackStatGatherer(path string) *MediaTrackStatGatherer

func (*MediaTrackStatGatherer) MediaReceived

func (g *MediaTrackStatGatherer) MediaReceived(size int64)

func (*MediaTrackStatGatherer) PLI

func (g *MediaTrackStatGatherer) PLI()

func (*MediaTrackStatGatherer) PacketLost

func (g *MediaTrackStatGatherer) PacketLost(count int64)

func (*MediaTrackStatGatherer) Path

func (g *MediaTrackStatGatherer) Path() string

func (*MediaTrackStatGatherer) UpdateStats

func (g *MediaTrackStatGatherer) UpdateStats() *ipc.TrackStats

type Monitor

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

func NewMonitor

func NewMonitor() *Monitor

func (*Monitor) AcceptIngress

func (m *Monitor) AcceptIngress(info *livekit.IngressInfo) bool

func (*Monitor) CanAccept

func (m *Monitor) CanAccept() bool

func (*Monitor) CanAcceptIngress

func (m *Monitor) CanAcceptIngress(info *livekit.IngressInfo) bool

func (*Monitor) GetCPULoad

func (m *Monitor) GetCPULoad() float64

func (*Monitor) IngressEnded

func (m *Monitor) IngressEnded(info *livekit.IngressInfo)

func (*Monitor) IngressStarted

func (m *Monitor) IngressStarted(info *livekit.IngressInfo)

func (*Monitor) Shutdown

func (m *Monitor) Shutdown()

Server is shutting down, but may stay up for some time for draining

func (*Monitor) Start

func (m *Monitor) Start(conf *config.Config) error

func (*Monitor) Stop

func (m *Monitor) Stop()

Stop the monitor before server termination

func (*Monitor) UpdateCostConfig

func (m *Monitor) UpdateCostConfig(cpuCostConfig *config.CPUCostConfig) error