metrics

Documentation

Index

• func RecordMetric(key string, c *OperationStartTimeCache, err error)
• func RecordRetroactiveStorageClassMetric(success bool)
• func RecordVolumeOperationErrorMetric(pluginName, opName string)
• func Register(pvLister PVLister, pvcLister PVCLister, pluginMgr *volume.VolumePluginMgr)
• type OperationStartTimeCache
  • func NewOperationStartTimeCache() OperationStartTimeCache
  • func (c *OperationStartTimeCache) AddIfNotExist(key, pluginName, operationName string)
  • func (c *OperationStartTimeCache) Delete(key string)
  • func (c *OperationStartTimeCache) Has(key string) bool
• type PVCLister
• type PVLister

Functions

func RecordMetric

func RecordMetric(key string, c *OperationStartTimeCache, err error)

RecordMetric records either an error count metric or a latency metric if there exists a start timestamp entry in the cache. For a successful operation, i.e., err == nil, the corresponding timestamp entry will be removed from cache

func RecordRetroactiveStorageClassMetric

func RecordRetroactiveStorageClassMetric(success bool)

RecordRetroactiveStorageClassMetric increments only retroactive_storageclass_total metric or both retroactive_storageclass_total and retroactive_storageclass_errors_total if success is false.

func RecordVolumeOperationErrorMetric

func RecordVolumeOperationErrorMetric(pluginName, opName string)

RecordVolumeOperationErrorMetric records error count into metric volume_operation_total_errors for provisioning/deletion operations

func Register

func Register(pvLister PVLister, pvcLister PVCLister, pluginMgr *volume.VolumePluginMgr)

Register all metrics for pv controller.

Types

type OperationStartTimeCache

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

OperationStartTimeCache concurrent safe cache for operation start timestamps

func NewOperationStartTimeCache

func NewOperationStartTimeCache() OperationStartTimeCache

NewOperationStartTimeCache creates a operation timestamp cache

func (*OperationStartTimeCache) AddIfNotExist

func (c *OperationStartTimeCache) AddIfNotExist(key, pluginName, operationName string)

AddIfNotExist returns directly if there exists an entry with the key. Otherwise, it creates a new operation timestamp using operationName, pluginName, and current timestamp and stores the operation timestamp with the key

func (*OperationStartTimeCache) Delete

func (c *OperationStartTimeCache) Delete(key string)

Delete deletes a value for a key.

func (*OperationStartTimeCache) Has

func (c *OperationStartTimeCache) Has(key string) bool

Has returns a bool value indicates the existence of a key in the cache

type PVCLister

type PVCLister interface {
	List() []interface{}
}

PVCLister used to list persistent volume claims.

type PVLister

type PVLister interface {
	List() []interface{}
}

PVLister used to list persistent volumes.