internal

Documentation

Index

• type MetricsReporter
  • func NewMetricsReporter(logger util.Logger, config config.Config, scheduler Scheduler) *MetricsReporter
  • func (r *MetricsReporter) AddMetric(ts interface{}, record map[interface{}]interface{})
  • func (r *MetricsReporter) Close()
  • func (r *MetricsReporter) Datapoints() []*datapoint.Datapoint
• type Scheduler

Types

type MetricsReporter

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

func NewMetricsReporter

func NewMetricsReporter(logger util.Logger, config config.Config, scheduler Scheduler) *MetricsReporter

func (*MetricsReporter) AddMetric

func (r *MetricsReporter) AddMetric(ts interface{}, record map[interface{}]interface{})

func (*MetricsReporter) Close

func (r *MetricsReporter) Close()

func (*MetricsReporter) Datapoints

func (r *MetricsReporter) Datapoints() []*datapoint.Datapoint

type Scheduler

type Scheduler interface {
	ReportingDelay(time.Duration)
	AddCallback(collector sfxclient.Collector)
	Schedule(ctx context.Context) error
	ReportOnce(ctx context.Context) error
}