metrics

Documentation

Index

• func RegisterAll(sub event.Subscriber, operationStatsGetter OperationsStatsGetter, ...)
• type InstancesCollector
  • func NewInstancesCollector(statsGetter InstancesStatsGetter) *InstancesCollector
  • func (c *InstancesCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *InstancesCollector) Describe(ch chan<- *prometheus.Desc)
• type InstancesStatsGetter
• type OperationDurationCollector
  • func NewOperationDurationCollector() *OperationDurationCollector
  • func (c *OperationDurationCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *OperationDurationCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *OperationDurationCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error
  • func (c *OperationDurationCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error
• type OperationResultCollector
  • func NewOperationResultCollector() *OperationResultCollector
  • func (c *OperationResultCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *OperationResultCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *OperationResultCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error
  • func (c *OperationResultCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error
• type OperationsCollector
  • func NewOperationsCollector(statsGetter OperationsStatsGetter) *OperationsCollector
  • func (c *OperationsCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *OperationsCollector) Describe(ch chan<- *prometheus.Desc)
• type OperationsStatsGetter
• type StepResultCollector
  • func NewStepResultCollector() *StepResultCollector
  • func (c *StepResultCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *StepResultCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *StepResultCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error
  • func (c *StepResultCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error

Functions

func RegisterAll

func RegisterAll(sub event.Subscriber, operationStatsGetter OperationsStatsGetter, instanceStatsGetter InstancesStatsGetter)

Types

type InstancesCollector

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

func NewInstancesCollector

func NewInstancesCollector(statsGetter InstancesStatsGetter) *InstancesCollector

func (*InstancesCollector) Collect

func (c *InstancesCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (*InstancesCollector) Describe

func (c *InstancesCollector) Describe(ch chan<- *prometheus.Desc)

type InstancesStatsGetter

type InstancesStatsGetter interface {
	GetInstanceStats() (internal.InstanceStats, error)
}

InstancesStatsGetter provides number of all instances failed, succeeded or orphaned

(instance exists but the cluster was removed manually from the gardener):

- compass_keb_instances_total - total number of all instances - compass_keb_global_account_id_instances_total - total number of all instances per global account

type OperationDurationCollector

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

OperationDurationCollector provides histograms which describes the time of provisioning/deprovisioning operations: - compass_keb_provisioning_duration_minutes - compass_keb_deprovisioning_duration_minutes

func NewOperationDurationCollector

func NewOperationDurationCollector() *OperationDurationCollector

func (*OperationDurationCollector) Collect

func (c *OperationDurationCollector) Collect(ch chan<- prometheus.Metric)

func (*OperationDurationCollector) Describe

func (c *OperationDurationCollector) Describe(ch chan<- *prometheus.Desc)

func (*OperationDurationCollector) OnDeprovisioningStepProcessed

func (c *OperationDurationCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error

func (*OperationDurationCollector) OnProvisioningStepProcessed

func (c *OperationDurationCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error

type OperationResultCollector

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

OperationResultCollector provides the following metrics: - compass_keb_provisioning_result{"operation_id", "runtime_id", "instance_id"} - compass_keb_deprovisioning_result{"operation_id", "runtime_id", "instance_id"} These gauges show the status of the operation. The value of the gauge could be: 0 - Failed 1 - Succeeded 2 - In progress

func NewOperationResultCollector

func NewOperationResultCollector() *OperationResultCollector

func (*OperationResultCollector) Collect

func (c *OperationResultCollector) Collect(ch chan<- prometheus.Metric)

func (*OperationResultCollector) Describe

func (c *OperationResultCollector) Describe(ch chan<- *prometheus.Desc)

func (*OperationResultCollector) OnDeprovisioningStepProcessed

func (c *OperationResultCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error

func (*OperationResultCollector) OnProvisioningStepProcessed

func (c *OperationResultCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error

type OperationsCollector

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

func NewOperationsCollector

func NewOperationsCollector(statsGetter OperationsStatsGetter) *OperationsCollector

func (*OperationsCollector) Collect

func (c *OperationsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (*OperationsCollector) Describe

func (c *OperationsCollector) Describe(ch chan<- *prometheus.Desc)

type OperationsStatsGetter

type OperationsStatsGetter interface {
	GetOperationStats() (internal.OperationStats, error)
}

OperationsStatsGetter provides metrics, which shows how many operations were done: - compass_keb_operations_provisioning_failed_total - compass_keb_operations_provisioning_in_progress_total - compass_keb_operations_provisioning_succeeded_total - compass_keb_operations_deprovisioning_failed_total - compass_keb_operations_deprovisioning_in_progress_total - compass_keb_operations_deprovisioning_secceeded_total

type StepResultCollector

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

StepResultCollector provides the following metrics: - compass_keb_provisioning_step_result{"operation_id", "runtime_id", "instance_id", "step_name"} - compass_keb_deprovisioning_step_result{"operation_id", "runtime_id", "instance_id", "step_name"} These gauges show the status of the operation step. The value of the gauge could be: 0 - Failed 1 - Succeeded 2 - In progress

func NewStepResultCollector

func NewStepResultCollector() *StepResultCollector

func (*StepResultCollector) Collect

func (c *StepResultCollector) Collect(ch chan<- prometheus.Metric)

func (*StepResultCollector) Describe

func (c *StepResultCollector) Describe(ch chan<- *prometheus.Desc)

func (*StepResultCollector) OnDeprovisioningStepProcessed

func (c *StepResultCollector) OnDeprovisioningStepProcessed(ctx context.Context, ev interface{}) error

func (*StepResultCollector) OnProvisioningStepProcessed

func (c *StepResultCollector) OnProvisioningStepProcessed(ctx context.Context, ev interface{}) error