Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Collectbeat ¶
type Collectbeat struct {
// contains filtered or unexported fields
}
Collectbeat implements the Beater interface.
func (*Collectbeat) Run ¶
func (bt *Collectbeat) Run(b *beat.Beat) error
Run starts the workers for Collectbeat and blocks until Stop is called and the workers complete. Each host associated with a MetricSet is given its own goroutine for fetching data. The ensures that each host is isolated so that a single unresponsive host cannot inadvertently block other hosts within the same Module and MetricSet from collection.
func (*Collectbeat) Stop ¶
func (bt *Collectbeat) Stop()
Stop signals to Collectbeat that it should stop. It closes the "done" channel and closes the publisher client associated with each Module.
Stop should only be called a single time. Calling it more than once may result in undefined behavior.
type Config ¶
type Config struct {
// Discoverers is a list of discoverer specific configurationd data.
Discoverers map[string]*common.Config `config:"discovery"`
// Upper bound on the random startup delay for metricsets (use 0 to disable startup delay).
MaxStartDelay time.Duration `config:"max_start_delay"`
ConfigModules *common.Config `config:"config.modules"`
}
config is the root of the Collecbeat configuration hierarchy.
Source Files
Click to show internal directories.
Click to hide internal directories.