agent

Documentation

Index

• func NewAccumulator(maker MetricMaker, metrics chan<- telegraf.Metric) telegraf.Accumulator
• type Agent
  • func NewAgent(config *config.Config) (*Agent, error)
  • func (a *Agent) Precision() time.Duration
  • func (a *Agent) Run(ctx context.Context) error
  • func (a *Agent) Test(ctx context.Context, waitDuration time.Duration) error
• type AlignedTicker
  • func NewAlignedTicker(now time.Time, interval, jitter time.Duration) *AlignedTicker
  • func (t *AlignedTicker) Elapsed() <-chan time.Time
  • func (t *AlignedTicker) Stop()
• type MetricMaker
• type RollingTicker
  • func NewRollingTicker(interval, jitter time.Duration) *RollingTicker
  • func (t *RollingTicker) Elapsed() <-chan time.Time
  • func (t *RollingTicker) Stop()
• type Ticker
• type UnalignedTicker
  • func NewUnalignedTicker(interval, jitter time.Duration) *UnalignedTicker
  • func (t *UnalignedTicker) Elapsed() <-chan time.Time
  • func (t *UnalignedTicker) InjectTick()
  • func (t *UnalignedTicker) Stop()

Functions

func NewAccumulator

func NewAccumulator(
	maker MetricMaker,
	metrics chan<- telegraf.Metric,
) telegraf.Accumulator

Types

type Agent

type Agent struct {
	Config *config.Config
}

Agent runs a set of plugins.

func NewAgent

func NewAgent(config *config.Config) (*Agent, error)

NewAgent returns an Agent for the given Config.

func (*Agent) Precision

func (a *Agent) Precision() time.Duration

Returns the rounding precision for metrics.

func (*Agent) Run

func (a *Agent) Run(ctx context.Context) error

Run starts and runs the Agent until the context is done.

func (*Agent) Test

func (a *Agent) Test(ctx context.Context, waitDuration time.Duration) error

Test runs the inputs once and prints the output to stdout in line protocol.

type AlignedTicker

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

AlignedTicker delivers ticks at aligned times plus an optional jitter. Each tick is realigned to avoid drift and handle changes to the system clock.

The ticks may have an jitter duration applied to them as an random offset to the interval. However the overall pace of is that of the interval, so on average you will have one collection each interval.

The first tick is emitted at the next alignment.

Ticks are dropped for slow consumers.

The implementation currently does not recalculate until the next tick with no maximum sleep, when using large intervals alignment is not corrected until the next tick.

func NewAlignedTicker

func NewAlignedTicker(now time.Time, interval, jitter time.Duration) *AlignedTicker

func (*AlignedTicker) Elapsed

func (t *AlignedTicker) Elapsed() <-chan time.Time

func (*AlignedTicker) Stop

func (t *AlignedTicker) Stop()

type MetricMaker

type MetricMaker interface {
	LogName() string
	MakeMetric(metric telegraf.Metric) telegraf.Metric
	Log() telegraf.Logger
}

type RollingTicker

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

RollingTicker delivers ticks at regular but unaligned intervals.

Because the next interval is scheduled based on the interval + jitter, you are guaranteed at least interval seconds without missing a tick and ticks will be evenly scheduled over time.

On average you will have one collection each interval + (jitter/2).

The first tick is emitted after interval+jitter seconds.

Ticks are dropped for slow consumers.

func NewRollingTicker

func NewRollingTicker(interval, jitter time.Duration) *RollingTicker

func (*RollingTicker) Elapsed

func (t *RollingTicker) Elapsed() <-chan time.Time

func (*RollingTicker) Stop

func (t *RollingTicker) Stop()

type Ticker

type Ticker interface {
	Elapsed() <-chan time.Time
	Stop()
}

type UnalignedTicker

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

UnalignedTicker delivers ticks at regular but unaligned intervals. No effort is made to avoid drift.

The ticks may have an jitter duration applied to them as an random offset to the interval. However the overall pace of is that of the interval, so on average you will have one collection each interval.

The first tick is emitted immediately.

Ticks are dropped for slow consumers.

func NewUnalignedTicker

func NewUnalignedTicker(interval, jitter time.Duration) *UnalignedTicker

func (*UnalignedTicker) Elapsed

func (t *UnalignedTicker) Elapsed() <-chan time.Time

func (*UnalignedTicker) InjectTick

func (t *UnalignedTicker) InjectTick()

func (*UnalignedTicker) Stop

func (t *UnalignedTicker) Stop()