connectionquality

Documentation

Index

• Constants
• type ConnectionStats
  • func NewConnectionStats(params ConnectionStatsParams) *ConnectionStats
  • func (cs *ConnectionStats) AddBitrateTransition(bitrate int64, at time.Time)
  • func (cs *ConnectionStats) AddLayerTransition(distance float64, at time.Time)
  • func (cs *ConnectionStats) Close()
  • func (cs *ConnectionStats) GetScoreAndQuality() (float32, livekit.ConnectionQuality)
  • func (cs *ConnectionStats) OnStatsUpdate(fn func(cs *ConnectionStats, stat *livekit.AnalyticsStat))
  • func (cs *ConnectionStats) Start(trackInfo *livekit.TrackInfo, at time.Time)
  • func (cs *ConnectionStats) UpdateLayerMute(isMuted bool, at time.Time)
  • func (cs *ConnectionStats) UpdateMute(isMuted bool, at time.Time)
• type ConnectionStatsParams

Constants

const (
	MaxMOS = float32(4.5)
	MinMOS = float32(1.0)
)

const (
	UpdateInterval = 5 * time.Second
)

Types

type ConnectionStats

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

func NewConnectionStats

func NewConnectionStats(params ConnectionStatsParams) *ConnectionStats

func (*ConnectionStats) AddBitrateTransition

func (cs *ConnectionStats) AddBitrateTransition(bitrate int64, at time.Time)

func (*ConnectionStats) AddLayerTransition

func (cs *ConnectionStats) AddLayerTransition(distance float64, at time.Time)

func (*ConnectionStats) Close

func (cs *ConnectionStats) Close()

func (*ConnectionStats) GetScoreAndQuality

func (cs *ConnectionStats) GetScoreAndQuality() (float32, livekit.ConnectionQuality)

func (*ConnectionStats) OnStatsUpdate

func (cs *ConnectionStats) OnStatsUpdate(fn func(cs *ConnectionStats, stat *livekit.AnalyticsStat))

func (*ConnectionStats) Start

func (cs *ConnectionStats) Start(trackInfo *livekit.TrackInfo, at time.Time)

func (*ConnectionStats) UpdateLayerMute

func (cs *ConnectionStats) UpdateLayerMute(isMuted bool, at time.Time)

func (*ConnectionStats) UpdateMute

func (cs *ConnectionStats) UpdateMute(isMuted bool, at time.Time)

type ConnectionStatsParams

type ConnectionStatsParams struct {
	UpdateInterval            time.Duration
	MimeType                  string
	IsFECEnabled              bool
	IncludeRTT                bool
	IncludeJitter             bool
	GetDeltaStats             func() map[uint32]*buffer.StreamStatsWithLayers
	GetDeltaStatsOverridden   func() map[uint32]*buffer.StreamStatsWithLayers
	GetLastReceiverReportTime func() time.Time
	Logger                    logger.Logger
}