integrations

Documentation

Index

• Variables
• type Config
  • func (c *Config) DefaultRelabelConfigs() ([]*relabel.Config, error)
  • func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Manager
  • func NewManager(c Config, logger log.Logger, im instance.Manager) (*Manager, error)
  • func (m *Manager) Stop()
  • func (m *Manager) WireAPI(r *mux.Router) error

Variables

var (
	DefaultConfig = Config{
		ScrapeIntegrations:        true,
		IntegrationRestartBackoff: 5 * time.Second,
		UseHostnameLabel:          true,
		ReplaceInstanceLabel:      true,
	}
)

Types

type Config

type Config struct {
	// Whether the Integration subsystem should be enabled.
	Enabled bool `yaml:"-"`

	// When true, scrapes metrics from integrations.
	ScrapeIntegrations bool `yaml:"scrape_integrations"`
	// When true, replaces the instance label with the agent hostname.
	ReplaceInstanceLabel bool `yaml:"replace_instance_label"`

	// DEPRECATED. When true, adds an agent_hostname label to all samples from integrations.
	// ReplaceInstanceLabel should be used instead.
	UseHostnameLabel bool `yaml:"use_hostname_label"`

	Agent             agent.Config              `yaml:"agent"`
	NodeExporter      node_exporter.Config      `yaml:"node_exporter"`
	ProcessExporter   process_exporter.Config   `yaml:"process_exporter"`
	MysqldExporter    mysqld_exporter.Config    `yaml:"mysqld_exporter"`
	RedisExporter     redis_exporter.Config     `yaml:"redis_exporter"`
	DnsmasqExporter   dnsmasq_exporter.Config   `yaml:"dnsmasq_exporter"`
	MemcachedExporter memcached_exporter.Config `yaml:"memcached_exporter"`
	PostgresExporter  postgres_exporter.Config  `yaml:"postgres_exporter"`
	StatsdExporter    statsd_exporter.Config    `yaml:"statsd_exporter"`
	ConsulExporter    consul_exporter.Config    `yaml:"consul_exporter"`

	// Extra labels to add for all integration samples
	Labels model.LabelSet `yaml:"labels"`

	// Prometheus RW configs to use for all integrations.
	PrometheusRemoteWrite []*config.RemoteWriteConfig `yaml:"prometheus_remote_write,omitempty"`

	IntegrationRestartBackoff time.Duration `yaml:"integration_restart_backoff,omitempty"`

	// ListenPort tells the integration Manager which port the Agent is
	// listening on for generating Prometheus instance configs.
	ListenPort *int `yaml:"-"`
}

Config holds the configuration for all integrations.

func (*Config) DefaultRelabelConfigs

func (c *Config) DefaultRelabelConfigs() ([]*relabel.Config, error)

DefaultRelabelConfigs returns the set of relabel configs that should be prepended to all RelabelConfigs for an integration.

func (*Config) UnmarshalYAML

func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements yaml.Unmarshaler for Config.

type Manager

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

Manager manages a set of integrations and runs them.

func NewManager

func NewManager(c Config, logger log.Logger, im instance.Manager) (*Manager, error)

NewManager creates a new integrations manager. NewManager must be given an InstanceManager which is responsible for accepting instance configs to scrape and send metrics from running integrations.

func (*Manager) Stop

func (m *Manager) Stop()

Stop stops the manager and all of its integrations.

func (*Manager) WireAPI

func (m *Manager) WireAPI(r *mux.Router) error