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
• type ProvideAgentIn

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.

type ProvideAgentIn

type ProvideAgentIn struct {
	fx.In

	Unmarshaller           config.Unmarshaller
	Lis                    *listener.Listener
	PromClient             promapi.Client
	TLSConfig              *tls.Config
	AI                     *agentinfo.AgentInfo
	EtcdClient             *etcdclient.Client
	Lifecycle              fx.Lifecycle
	Shutdowner             fx.Shutdowner
	InstallationModeConfig *agentinfo.InstallationModeConfig  `optional:"true"`
	SecretManagetClient    *secretmanager.SecretManagerClient `optional:"true"`
}