agent

Documentation

Index

• func AddAgentInfoAttribute(agentInfo *agentinfo.AgentInfo, otelConfigProvider *otelconfig.Provider)
• func AgentOTelComponents(in AgentOTelComponentsIn) (otelcol.Factories, error)
• func ModuleForAgentOTel() fx.Option
• func ProvidePeersPrefix(agentInfo *agentinfo.AgentInfo) (peers.PeerDiscoveryPrefix, error)
• type AgentOTelComponentsIn

Functions

func AddAgentInfoAttribute

func AddAgentInfoAttribute(
	agentInfo *agentinfo.AgentInfo,
	otelConfigProvider *otelconfig.Provider,
)

AddAgentInfoAttribute adds the agent group and instance labels to OTel config.

func AgentOTelComponents

func AgentOTelComponents(in AgentOTelComponentsIn) (otelcol.Factories, error)

AgentOTelComponents constructs OTel Collector Factories for Agent.

func ModuleForAgentOTel

func ModuleForAgentOTel() fx.Option

ModuleForAgentOTel provides fx options for AgentOTelComponent.

func ProvidePeersPrefix

func ProvidePeersPrefix(agentInfo *agentinfo.AgentInfo) (peers.PeerDiscoveryPrefix, error)

ProvidePeersPrefix provides the peers prefix.

Types

type AgentOTelComponentsIn

type AgentOTelComponentsIn struct {
	fx.In
	Alerter            alerts.Alerter      `name:"AlertsFx"`
	ReceiverFactories  []receiver.Factory  `group:"otel-collector-receiver-factories"`
	ProcessorFactories []processor.Factory `group:"otel-collector-processor-factories"`
	PromRegistry       *prometheus.Registry
	Engine             iface.Engine
	ClasEng            iface.ClassificationEngine
	ServerGRPC         *grpc.Server `name:"default"`
	ControlPointCache  *cache.Cache[selectors.TypedControlPointID]
	AlertMgr           *alertmanager.AlertManager
}

AgentOTelComponentsIn bundles and annotates parameters.