Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 RecordVolumeOperationErrorMetric ¶
func RecordVolumeOperationErrorMetric(pluginName, opName string)
RecordVolumeOperationErrorMetric records error count into metric volume_operation_total_errors for provisioning/deletion operations
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
Source Files