Documentation
¶
Index ¶
- func DecrementQueuesTotal()
- func HTTPMetricsMiddleware(handler http.Handler) http.Handler
- func IncrementMessagesDequeued(queueName string)
- func IncrementMessagesEnqueued(queueName string)
- func IncrementQueuesTotal()
- func RecordGRPCMetrics(method string, duration time.Duration, err error)
- func RecordRedisOperation(operation string, duration time.Duration, err error)
- func SetMessagesPending(queueName string, count float64)
- func SetQueuesTotal(count float64)
- type MetricsRegistry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecrementQueuesTotal ¶
func DecrementQueuesTotal()
DecrementQueuesTotal decrements the total queue count
func HTTPMetricsMiddleware ¶
HTTPMetricsMiddleware wraps an HTTP handler with Prometheus metrics
func IncrementMessagesDequeued ¶
func IncrementMessagesDequeued(queueName string)
IncrementMessagesDequeued increments dequeued message count for a queue
func IncrementMessagesEnqueued ¶
func IncrementMessagesEnqueued(queueName string)
IncrementMessagesEnqueued increments enqueued message count for a queue
func IncrementQueuesTotal ¶
func IncrementQueuesTotal()
IncrementQueuesTotal increments the total queue count
func RecordGRPCMetrics ¶
RecordGRPCMetrics records gRPC request metrics (called from the interceptor)
func RecordRedisOperation ¶
RecordRedisOperation records a Redis operation with duration and status
func SetMessagesPending ¶
SetMessagesPending sets the pending message count for a queue
Types ¶
type MetricsRegistry ¶
type MetricsRegistry struct {
// contains filtered or unexported fields
}
MetricsRegistry holds the Prometheus registry and provides methods for metrics
func NewMetricsRegistry ¶
func NewMetricsRegistry() *MetricsRegistry
NewMetricsRegistry creates a new metrics registry with all ChronoQueue metrics
func (*MetricsRegistry) Handler ¶
func (m *MetricsRegistry) Handler() http.Handler
Handler returns an HTTP handler for Prometheus metrics
Source Files