agent

package

v1.14.0 Latest Latest Go to latest Published: Mar 26, 2020 License: MIT Imports: 12 Imported by: 22

Details

This section is empty.

This section is empty.

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

type Agent struct {
	Config *config.Config
}

Agent runs a set of plugins.

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

NewAgent returns an Agent for the given Config.

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

Returns the rounding precision for metrics.

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

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

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 MetricMaker interface {
	LogName() string
	MakeMetric(metric telegraf.Metric) telegraf.Metric
	Log() telegraf.Logger
}

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

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

func (t *Ticker) Stop()