Documentation
¶
Index ¶
- type ExporterOptions
- type MetricsExporter
- func (m *MetricsExporter) RecordQueueDepth(runnerName string, depth int)
- func (m *MetricsExporter) RecordTaskDuration(runnerName string, priority core.TaskPriority, duration time.Duration)
- func (m *MetricsExporter) RecordTaskPanic(runnerName string, panicInfo any)
- func (m *MetricsExporter) RecordTaskRejected(runnerName string, reason string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExporterOptions ¶
type ExporterOptions struct {
DurationBuckets []float64
}
ExporterOptions controls collector configuration.
type MetricsExporter ¶
type MetricsExporter struct {
// contains filtered or unexported fields
}
MetricsExporter adapts core.Metrics to Prometheus collectors.
func NewMetricsExporter ¶
func NewMetricsExporter(namespace string, reg prom.Registerer, opts ExporterOptions) (*MetricsExporter, error)
NewMetricsExporter creates and registers Prometheus collectors for core.Metrics.
func (*MetricsExporter) RecordQueueDepth ¶
func (m *MetricsExporter) RecordQueueDepth(runnerName string, depth int)
RecordQueueDepth records queue depth.
func (*MetricsExporter) RecordTaskDuration ¶
func (m *MetricsExporter) RecordTaskDuration(runnerName string, priority core.TaskPriority, duration time.Duration)
RecordTaskDuration records task execution duration.
func (*MetricsExporter) RecordTaskPanic ¶
func (m *MetricsExporter) RecordTaskPanic(runnerName string, panicInfo any)
RecordTaskPanic records task panic events.
func (*MetricsExporter) RecordTaskRejected ¶
func (m *MetricsExporter) RecordTaskRejected(runnerName string, reason string)
RecordTaskRejected records task rejection events.
Source Files
Click to show internal directories.
Click to hide internal directories.