agent

Documentation

Index

• Variables
• func NewAccumulator(maker MetricMaker, metrics chan<- telegraf.Metric) telegraf.Accumulator
• type Agent
  • func NewAgent(config *config.Config) (*Agent, error)
  • func (a *Agent) Run(ctx context.Context) error
  • func (a *Agent) Test(ctx context.Context) error
• type MetricMaker
• type Ticker
  • func NewTicker(interval time.Duration, jitter time.Duration) *Ticker
  • func (t *Ticker) Stop()

Variables

var (
	NErrors = selfstat.Register("agent", "gather_errors", map[string]string{})
)

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) 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) error

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

type MetricMaker

type MetricMaker interface {
	Name() string
	MakeMetric(metric telegraf.Metric) telegraf.Metric
}

type Ticker

type Ticker struct {
	C chan time.Time
	// contains filtered or unexported fields
}

func NewTicker

func NewTicker(
	interval time.Duration,
	jitter time.Duration,
) *Ticker

func (*Ticker) Stop

func (t *Ticker) Stop()