telemetry

Documentation

Index

• type Execution
• type RegionMetrics
• type RegionPusher
  • func NewRegionPusher(ctx context.Context, timeSpan time.Duration, client sm.TelemetryClient, ...) *RegionPusher
  • func (p *RegionPusher) AddExecution(e Execution)
• type Telemeter
  • func NewTelemeter(ctx context.Context, instance string, pushTimeSpan time.Duration, ...) *Telemeter
  • func (t *Telemeter) AddExecution(e Execution)

Types

type Execution

type Execution struct {
	LocalTenantID int64
	RegionID      int32
	CheckClass    sm.CheckClass
	Duration      time.Duration
}

Execution represents the telemetry for a check execution.

type RegionMetrics

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

type RegionPusher

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

RegionPusher periodically sends telemetry data for a specific region.

func NewRegionPusher

func NewRegionPusher(
	ctx context.Context, timeSpan time.Duration,
	client sm.TelemetryClient, logger zerolog.Logger, instance string, regionID int32,
	metrics RegionMetrics, opts ...any,
) *RegionPusher

NewRegionPusher builds a new RegionPusher. Notice that the effective time span used to dictate the pace for periodic push events will be defined based on the given time span plus a random jitter [0,59)s.

func (*RegionPusher) AddExecution

func (p *RegionPusher) AddExecution(e Execution)

AddExecution adds a new execution to the tenant telemetry.

type Telemeter

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

Telemeter maintains the telemetry data for all the tenants running checks in the agent instance, organized by region.

func NewTelemeter

func NewTelemeter(
	ctx context.Context, instance string, pushTimeSpan time.Duration, client sm.TelemetryClient,
	logger zerolog.Logger, registerer prom.Registerer,
) *Telemeter

NewTelemeter creates a new Telemeter component.

func (*Telemeter) AddExecution

func (t *Telemeter) AddExecution(e Execution)

AddExecution adds a new execution to the agent's telemetry.