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 LastOperationState
• 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
  • func (c *OperationResultCollector) OnUpgradeClusterStepProcessed(ctx context.Context, ev interface{}) error
  • func (c *OperationResultCollector) OnUpgradeKymaStepProcessed(ctx context.Context, ev interface{}) error
• type OperationStat
  • func (c *OperationStat) Describe(ch chan<- *prometheus.Desc)
• 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 LastOperationState

type LastOperationState = domain.LastOperationState

const (
	Pending   LastOperationState = "pending"
	Canceling LastOperationState = "canceling"
	Canceled  LastOperationState = "canceled"
)

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", "global_account_id", "plan_id"} - compass_keb_deprovisioning_result{"operation_id", "runtime_id", "instance_id", "global_account_id", "plan_id"} - compass_keb_upgrade_result{"operation_id", "runtime_id", "instance_id", "global_account_id", "plan_id"} These gauges show the status of the operation. The value of the gauge could be: 0 - Failed 1 - Succeeded 2 - In progress 3 - Pending 4 - Canceling 5 - Canceled

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

func (*OperationResultCollector) OnUpgradeClusterStepProcessed

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

func (*OperationResultCollector) OnUpgradeKymaStepProcessed

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

type OperationStat

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

func (*OperationStat) Describe

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

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 {
	GetOperationStatsByPlan() (map[string]internal.OperationStats, error)
}

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", "global_account_id", "plan_id"} - compass_keb_deprovisioning_step_result{"operation_id", "runtime_id", "instance_id", "step_name", "global_account_id", "plan_id"} 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