Documentation
¶
Index ¶
- func InitMetrics(registry prometheus.Registerer)
- func RecordBackup(catalog, status string, duration float64)
- func RecordCircuitOpen(poolName, namespace string)
- func RecordJobDuration(jobType, status string, duration float64)
- func RecordJobExecution(status string, duration float64, operation string)
- func RecordPodAcquired(poolName, namespace string)
- func RecordPodCreated(poolName, namespace string)
- func RecordPodDeleted(poolName, namespace string)
- func RecordPodReleased(poolName, namespace string)
- func RecordPoolQueueLength(poolName, namespace string, length int)
- func RecordQueryDuration(poolName, namespace string, seconds float64)
- func RecordQueryTimeout(poolName, namespace string)
- func RecordQueueWaitDuration(poolName, namespace string, seconds float64)
- func RecordReconciliation(resource, result string, duration float64)
- func RecordReconciliationError(resource, errorType string)
- func RecordRetry(poolName, namespace string)
- func RecordS3Operation(operation, status string, duration float64)
- func RecordScalingEvent(poolName, namespace, direction string)
- func RecordTableOperation(operation, status string)
- func RecordWaitDuration(poolName, namespace string, seconds float64)
- func UpdateCatalogSize(catalog string, sizeBytes float64)
- func UpdatePoolMetrics(poolName, namespace string, current, desired, idle, busy int32)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitMetrics ¶
func InitMetrics(registry prometheus.Registerer)
InitMetrics initializes all metrics - should be called once at startup
func RecordBackup ¶
RecordBackup records backup metrics
func RecordCircuitOpen ¶
func RecordCircuitOpen(poolName, namespace string)
RecordCircuitOpen increments circuit breaker counter
func RecordJobDuration ¶
RecordJobDuration records job duration metric
func RecordJobExecution ¶
RecordJobExecution records job execution metric
func RecordPodAcquired ¶
func RecordPodAcquired(poolName, namespace string)
RecordPodAcquired records a pod acquisition
func RecordPodCreated ¶
func RecordPodCreated(poolName, namespace string)
RecordPodCreated records a pod creation
func RecordPodDeleted ¶
func RecordPodDeleted(poolName, namespace string)
RecordPodDeleted records a pod deletion
func RecordPodReleased ¶
func RecordPodReleased(poolName, namespace string)
RecordPodReleased records a pod release
func RecordPoolQueueLength ¶
RecordPoolQueueLength records the current queue length
func RecordQueryDuration ¶
RecordQueryDuration records query execution time
func RecordQueryTimeout ¶
func RecordQueryTimeout(poolName, namespace string)
RecordQueryTimeout increments the query timeout counter
func RecordQueueWaitDuration ¶
RecordQueueWaitDuration observes queue wait time
func RecordReconciliation ¶
RecordReconciliation records reconciliation metrics
func RecordReconciliationError ¶
func RecordReconciliationError(resource, errorType string)
RecordReconciliationError records reconciliation error metrics
func RecordRetry ¶
func RecordRetry(poolName, namespace string)
RecordRetry increments the retry counter
func RecordS3Operation ¶
RecordS3Operation records S3 operation metrics
func RecordScalingEvent ¶
func RecordScalingEvent(poolName, namespace, direction string)
RecordScalingEvent records a scaling event
func RecordTableOperation ¶
func RecordTableOperation(operation, status string)
RecordTableOperation records a table operation metric
func RecordWaitDuration ¶
RecordWaitDuration records time waiting for a pod
func UpdateCatalogSize ¶
UpdateCatalogSize updates catalog size metric
func UpdatePoolMetrics ¶
UpdatePoolMetrics updates pool size metrics
Types ¶
This section is empty.
Source Files