README
¶
package collector
This package is responsible for providing any resource and functionality needed in a check life cycle: create a check instance, schedule a check, running a check are all operations implemented in this package or one of the subpackages.
For further details, please refer to the specific READMEs:
Documentation
¶
Index ¶
- func GetChecksByNameForConfigs(checkName string, configs []integration.Config) []check.Check
- func GetLoaderErrors() map[string]map[string]string
- type CheckScheduler
- func (s *CheckScheduler) AddLoader(loader check.Loader)
- func (s *CheckScheduler) GetChecksFromConfigs(configs []integration.Config, populateCache bool) []check.Check
- func (s *CheckScheduler) Schedule(configs []integration.Config)
- func (s *CheckScheduler) Stop()
- func (s *CheckScheduler) Unschedule(configs []integration.Config)
- type Collector
- func (c *Collector) GetAllInstanceIDs(checkName string) []check.ID
- func (c *Collector) ReloadAllCheckInstances(name string, newInstances []check.Check) ([]check.ID, error)
- func (c *Collector) RunCheck(ch check.Check) (check.ID, error)
- func (c *Collector) Stop()
- func (c *Collector) StopCheck(id check.ID) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetChecksByNameForConfigs ¶
func GetChecksByNameForConfigs(checkName string, configs []integration.Config) []check.Check
GetChecksByNameForConfigs returns checks matching name for passed in configs
func GetLoaderErrors ¶
GetLoaderErrors returns the check loader errors
Types ¶
type CheckScheduler ¶
type CheckScheduler struct {
// contains filtered or unexported fields
}
CheckScheduler is the check scheduler
func InitCheckScheduler ¶
func InitCheckScheduler(collector *Collector) *CheckScheduler
InitCheckScheduler creates and returns a check scheduler
func (*CheckScheduler) AddLoader ¶
func (s *CheckScheduler) AddLoader(loader check.Loader)
AddLoader adds a new Loader that AutoConfig can use to load a check.
func (*CheckScheduler) GetChecksFromConfigs ¶
func (s *CheckScheduler) GetChecksFromConfigs(configs []integration.Config, populateCache bool) []check.Check
GetChecksFromConfigs gets all the check instances for given configurations optionally can populate the configToChecks cache
func (*CheckScheduler) Schedule ¶
func (s *CheckScheduler) Schedule(configs []integration.Config)
Schedule schedules configs to checks
func (*CheckScheduler) Stop ¶
func (s *CheckScheduler) Stop()
Stop handles clean stop of registered schedulers
func (*CheckScheduler) Unschedule ¶
func (s *CheckScheduler) Unschedule(configs []integration.Config)
Unschedule unschedules checks matching configs
type Collector ¶
type Collector struct {
// contains filtered or unexported fields
}
Collector abstract common operations about running a Check
func NewCollector ¶
NewCollector create a Collector instance and sets up the Python Environment
func (*Collector) GetAllInstanceIDs ¶
GetAllInstanceIDs returns the ID's of all instances of a check
func (*Collector) ReloadAllCheckInstances ¶
func (c *Collector) ReloadAllCheckInstances(name string, newInstances []check.Check) ([]check.ID, error)
ReloadAllCheckInstances completely restarts a check with a new configuration
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
defaults
Package defaults provides common defaults used in agent checks
|
Package defaults provides common defaults used in agent checks |
|
cluster
Package cluster provides core checks for cluster level checks, used by the Datadog Cluster Agent.
|
Package cluster provides core checks for cluster level checks, used by the Datadog Cluster Agent. |
|
cluster/dockerswarm
Package dockerswarm provides core checks for docker swarm topology
|
Package dockerswarm provides core checks for docker swarm topology |
|
cluster/kubeapi
Package kubeapi provides core checks for kubernetes api
|
Package kubeapi provides core checks for kubernetes api |
|
containers
Package containers provides core checks for containers and orchestrators
|
Package containers provides core checks for containers and orchestrators |
|
containers/topology
Package topology is responsible for gathering topology for containers StackState
|
Package topology is responsible for gathering topology for containers StackState |
|
net
Package net provides core checks for networking
|
Package net provides core checks for networking |
|
nvidia/jetson
Package nvidia provides core checks for Nvidia's jetson device family
|
Package nvidia provides core checks for Nvidia's jetson device family |
|
system
Package system provides core checks for OS-level system metrics
|
Package system provides core checks for OS-level system metrics |
|
systemd
Package systemd provides core checks for systemd
|
Package systemd provides core checks for systemd |
|
Package metadata implements specific Metadata Collectors for the Agent.
|
Package metadata implements specific Metadata Collectors for the Agent. |