metrics

Documentation

Index

• func InitOtel(ctx context.Context, cfg config.Config, logger *log.Logrus, appVersion string) (func(), error)
• func NewStatsdClient(statsdAddress string) (*statsd.StatsdClient, error)
• type OtelMonitor
  • func NewOtelMonitor() *OtelMonitor
  • func (*OtelMonitor) RecordPlugin(context.Context, agent.PluginInfo)
  • func (m *OtelMonitor) RecordRun(ctx context.Context, run agent.Run)
  • func (m *OtelMonitor) RecordSinkRetryCount(ctx context.Context, pluginInfo agent.PluginInfo)
• type StatsdMonitor
  • func NewStatsdMonitor(client statsdClient, prefix string) *StatsdMonitor
  • func (m *StatsdMonitor) RecordPlugin(_ context.Context, pluginInfo agent.PluginInfo)
  • func (m *StatsdMonitor) RecordRun(_ context.Context, run agent.Run)
  • func (*StatsdMonitor) RecordSinkRetryCount(context.Context, agent.PluginInfo)

Functions

func InitOtel

func InitOtel(ctx context.Context, cfg config.Config, logger *log.Logrus, appVersion string) (func(), error)

func NewStatsdClient

func NewStatsdClient(statsdAddress string) (*statsd.StatsdClient, error)

NewStatsdClient returns a new statsd client if the given address is valid

Types

type OtelMonitor

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

OtelMonitor represents the otel monitor.

func NewOtelMonitor

func NewOtelMonitor() *OtelMonitor

func (*OtelMonitor) RecordPlugin

func (*OtelMonitor) RecordPlugin(context.Context, agent.PluginInfo)

RecordPlugin records a individual plugin behavior in a run, this is being handled in otelmw

func (*OtelMonitor) RecordRun

func (m *OtelMonitor) RecordRun(ctx context.Context, run agent.Run)

RecordRun records a run behavior

func (*OtelMonitor) RecordSinkRetryCount

func (m *OtelMonitor) RecordSinkRetryCount(ctx context.Context, pluginInfo agent.PluginInfo)

type StatsdMonitor

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

StatsdMonitor represents the statsd monitor.

func NewStatsdMonitor

func NewStatsdMonitor(client statsdClient, prefix string) *StatsdMonitor

NewStatsdMonitor creates a new StatsdMonitor

func (*StatsdMonitor) RecordPlugin

func (m *StatsdMonitor) RecordPlugin(_ context.Context, pluginInfo agent.PluginInfo)

RecordPlugin records a individual plugin behavior in a run

func (*StatsdMonitor) RecordRun

func (m *StatsdMonitor) RecordRun(_ context.Context, run agent.Run)

RecordRun records a run behavior

func (*StatsdMonitor) RecordSinkRetryCount

func (*StatsdMonitor) RecordSinkRetryCount(context.Context, agent.PluginInfo)