metric

Documentation

Index

• Variables
• type MetricConfig
• type MetricTimestamper
  • func NewMetricTimestamper(params MetricTimestamperParams) *MetricTimestamper
  • func (m *MetricTimestamper) Process(batch *livekit.MetricsBatch)
• type MetricTimestamperConfig
• type MetricTimestamperParams

Variables

var (
	DefaultMetricConfig = MetricConfig{
		Timestamper: DefaultMetricTimestamperConfig,
	}
)

var (
	DefaultMetricTimestamperConfig = MetricTimestamperConfig{
		OneWayDelayEstimatorMinInterval: 5 * time.Second,
		OneWayDelayEstimatorMaxBatch:    100,
	}
)

Types

type MetricConfig

type MetricConfig struct {
	Timestamper MetricTimestamperConfig `yaml:"timestamper_config,omitempty"`
}

type MetricTimestamper

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

func NewMetricTimestamper

func NewMetricTimestamper(params MetricTimestamperParams) *MetricTimestamper

func (*MetricTimestamper) Process

func (m *MetricTimestamper) Process(batch *livekit.MetricsBatch)

type MetricTimestamperConfig

type MetricTimestamperConfig struct {
	OneWayDelayEstimatorMinInterval time.Duration `yaml:"one_way_delay_estimator_min_interval,omitempty"`
	OneWayDelayEstimatorMaxBatch    int           `yaml:"one_way_delay_estimator_max_batch,omitempty"`
}

type MetricTimestamperParams

type MetricTimestamperParams struct {
	Config MetricTimestamperConfig
	Logger logger.Logger
}