collector

Documentation

Overview

Package collector includes all individual collectors to gather and export system metrics.

Index

• Variables
• func DisableDefaultCollectors()
• func GetDiskNameFromURL(logger log.Logger, z string) string
• func GetGCPZoneFromURL(logger log.Logger, z string) string
• func IsNoDataError(err error) bool
• func NewGCPClient(ctx context.Context, scope string) (client *http.Client, err error)
• type Collector
  • func NewDataprocIsClusterRunningCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)
  • func NewGCEDiskSnapshotCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)
  • func NewGCEIsMachineRunningCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)
  • func NewIsDiskAttachedCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)
• type DataprocIsClusterRunningCollector
  • func (e *DataprocIsClusterRunningCollector) Update(ch chan<- prometheus.Metric) error
• type GCEDiskSnapshotCollector
  • func (e *GCEDiskSnapshotCollector) Update(ch chan<- prometheus.Metric) error
• type GCEIsDiskAttachedCollector
  • func (e *GCEIsDiskAttachedCollector) Update(ch chan<- prometheus.Metric) error
• type GCEIsMachineRunningCollector
  • func (e *GCEIsMachineRunningCollector) Update(ch chan<- prometheus.Metric) error
• type GCPCollector
  • func NewGCPCollector(ctx context.Context, logger log.Logger, project string, ...) (*GCPCollector, error)
  • func (n GCPCollector) Collect(ch chan<- prometheus.Metric)
  • func (n GCPCollector) Describe(ch chan<- *prometheus.Desc)

Variables

var (
	GCPHttpTimeout        time.Duration
	GCPMaxRetries         int
	GCPRetryStatuses      []int
	GCPBackoffJitterBase  time.Duration
	GCPMaxBackoffDuration time.Duration
)

var ErrNoData = errors.New("collector returned no data")

ErrNoData indicates the collector found no data to collect, but had no other error.

Functions

func DisableDefaultCollectors

func DisableDefaultCollectors()

DisableDefaultCollectors sets the collector state to false for all collectors which have not been explicitly enabled on the command line.

func GetDiskNameFromURL

func GetDiskNameFromURL(logger log.Logger, z string) string

func GetGCPZoneFromURL

func GetGCPZoneFromURL(logger log.Logger, z string) string

func IsNoDataError

func IsNoDataError(err error) bool

func NewGCPClient

func NewGCPClient(ctx context.Context, scope string) (client *http.Client, err error)

Types

type Collector

type Collector interface {
	// Get new metrics and expose them via prometheus registry.
	Update(ch chan<- prometheus.Metric) error
}

Collector is the interface a collector has to implement.

func NewDataprocIsClusterRunningCollector

func NewDataprocIsClusterRunningCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)

func NewGCEDiskSnapshotCollector

func NewGCEDiskSnapshotCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)

func NewGCEIsMachineRunningCollector

func NewGCEIsMachineRunningCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)

func NewIsDiskAttachedCollector

func NewIsDiskAttachedCollector(logger log.Logger, project string, monitoredRegions []string) (Collector, error)

type DataprocIsClusterRunningCollector

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

func (*DataprocIsClusterRunningCollector) Update

func (e *DataprocIsClusterRunningCollector) Update(ch chan<- prometheus.Metric) error

type GCEDiskSnapshotCollector

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

func (*GCEDiskSnapshotCollector) Update

func (e *GCEDiskSnapshotCollector) Update(ch chan<- prometheus.Metric) error

type GCEIsDiskAttachedCollector

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

func (*GCEIsDiskAttachedCollector) Update

func (e *GCEIsDiskAttachedCollector) Update(ch chan<- prometheus.Metric) error

type GCEIsMachineRunningCollector

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

func (*GCEIsMachineRunningCollector) Update

func (e *GCEIsMachineRunningCollector) Update(ch chan<- prometheus.Metric) error

type GCPCollector

type GCPCollector struct {
	Collectors map[string]Collector
	// contains filtered or unexported fields
}

GCPCollector implements the prometheus.Collector interface.

func NewGCPCollector

func NewGCPCollector(ctx context.Context, logger log.Logger, project string, monitoredRedgions []string) (*GCPCollector, error)

NewGCPCollector creates a new GCPCollector.

func (GCPCollector) Collect

func (n GCPCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (GCPCollector) Describe

func (n GCPCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.