metrics

Documentation

Index

• func InitOtel(ctx context.Context, cfg config.Config, logger *log.Logrus, appVersion string) (func(), 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)

Functions

func InitOtel

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

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)