collectors

Documentation

Index

• type ContainerCollector
  • func NewContainerCollector(env core.Environment, conf *config.Config) *ContainerCollector
  • func (c *ContainerCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)
  • func (c *ContainerCollector) UpdateConfig(config *config.Config)
• type NginxCollector
  • func NewNginxCollector(conf *config.Config, env core.Environment, ...) *NginxCollector
  • func (c *NginxCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)
  • func (c *NginxCollector) GetNginxId() string
  • func (c *NginxCollector) Stop()
  • func (c *NginxCollector) UpdateCollectorConfig(collectorConfig *metrics.NginxCollectorConfig, conf *config.Config, ...)
  • func (c *NginxCollector) UpdateConfig(config *config.Config)
  • func (c *NginxCollector) UpdateSources()
• type SystemCollector
  • func NewSystemCollector(env core.Environment, conf *config.Config) *SystemCollector
  • func (c *SystemCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)
  • func (c *SystemCollector) UpdateConfig(config *config.Config)

Types

type ContainerCollector

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

func NewContainerCollector

func NewContainerCollector(env core.Environment, conf *config.Config) *ContainerCollector

func (*ContainerCollector) Collect

func (c *ContainerCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)

func (*ContainerCollector) UpdateConfig

func (c *ContainerCollector) UpdateConfig(config *config.Config)

type NginxCollector

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

func NewNginxCollector

func NewNginxCollector(conf *config.Config, env core.Environment, collectorConf *metrics.NginxCollectorConfig, binary core.NginxBinary) *NginxCollector

func (*NginxCollector) Collect

func (c *NginxCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)

func (*NginxCollector) GetNginxId

func (c *NginxCollector) GetNginxId() string

func (*NginxCollector) Stop

func (c *NginxCollector) Stop()

func (*NginxCollector) UpdateCollectorConfig

func (c *NginxCollector) UpdateCollectorConfig(collectorConfig *metrics.NginxCollectorConfig, conf *config.Config, env core.Environment)

func (*NginxCollector) UpdateConfig

func (c *NginxCollector) UpdateConfig(config *config.Config)

func (*NginxCollector) UpdateSources

func (c *NginxCollector) UpdateSources()

type SystemCollector

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

func NewSystemCollector

func NewSystemCollector(env core.Environment, conf *config.Config) *SystemCollector

func (*SystemCollector) Collect

func (c *SystemCollector) Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *metrics.StatsEntityWrapper)

func (*SystemCollector) UpdateConfig

func (c *SystemCollector) UpdateConfig(config *config.Config)