Documentation
¶
Overview ¶
Package logsagentpipelineimpl contains the implementation for the logs agent pipeline component
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewLogsAgent ¶
func NewLogsAgent(deps Dependencies) logsagentpipeline.LogsAgent
NewLogsAgent returns a new instance of Agent with the given dependencies
func NewLogsAgentComponent ¶
func NewLogsAgentComponent(deps Dependencies) optional.Option[logsagentpipeline.Component]
NewLogsAgentComponent returns a new instance of Agent as a Component
func NewStatusProvider ¶
func NewStatusProvider() statusinterface.Status
NewStatusProvider fetches the status and returns a service wrapping it
Types ¶
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
Agent represents the data pipeline that collects, decodes, processes and sends logs to the backend.
func (*Agent) GetPipelineProvider ¶
GetPipelineProvider gets the pipeline provider
func (*Agent) SetupPipeline ¶
func (a *Agent) SetupPipeline( processingRules []*config.ProcessingRule, )
SetupPipeline initializes the logs agent pipeline and its dependencies
type Dependencies ¶
type Dependencies struct {
fx.In
Lc fx.Lifecycle
Log logComponent.Component
Config configComponent.Component
Hostname hostnameinterface.Component
}
Dependencies specifies the list of dependencies needed to initialize the logs agent
type StatusProvider ¶
type StatusProvider struct{}
StatusProvider is the type for logs agent status methods
func (StatusProvider) AddGlobalWarning ¶
func (p StatusProvider) AddGlobalWarning(string, string)
AddGlobalWarning keeps track of a warning message to display on the status.
func (StatusProvider) RemoveGlobalWarning ¶
func (p StatusProvider) RemoveGlobalWarning(string)
RemoveGlobalWarning loses track of a warning message that does not need to be displayed on the status anymore.
Source Files