collector

Documentation

Index

• func Enabled(cfg pkgconfigmodel.Reader) bool
• type Collector
  • func NewProcessCollector(coreConfig, sysProbeConfig pkgconfigmodel.Reader) *Collector
  • func (c *Collector) Start(ctx context.Context, store workloadmeta.Component) error

Functions

func Enabled

func Enabled(cfg pkgconfigmodel.Reader) bool

Enabled checks to see if we should enable the local process collector. Since it's job is to collect processes when the process check is disabled, we only enable it when `process_config.process_collection.enabled` == false Additionally, if the remote process collector is not enabled in the core agent, there is no reason to collect processes. Therefore, we check `language_detection.enabled`. We also check `process_config.run_in_core_agent.enabled` because this collector should only be used when the core agent collector is not running. Finally, we only want to run this collector in the process agent, so if we're running as anything else we should disable the collector.

Types

type Collector

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

Collector collects processes to send to the remote process collector in the core agent. It is only intended to be used when language detection is enabled, and the process check is disabled.

func NewProcessCollector

func NewProcessCollector(coreConfig, sysProbeConfig pkgconfigmodel.Reader) *Collector

NewProcessCollector creates a new process collector.

func (*Collector) Start

func (c *Collector) Start(ctx context.Context, store workloadmeta.Component) error

Start will start the collector