metrics

Jan 23, 2023

Changes in this version

+ const MetricPrefix

+ type FloatMetrics struct

+ func (d *FloatMetrics) GetBuckets() map[float64]uint64

+ func (d *FloatMetrics) GetCount() uint64

+ func (d *FloatMetrics) GetMax() float64

+ func (d *FloatMetrics) GetMedian() float64

+ func (d *FloatMetrics) GetMin() float64

+ func (d *FloatMetrics) GetSum() float64

+ type FloatMetricsRecorder struct

+ func NewDefaultJobDurationMetricsRecorder() *FloatMetricsRecorder

+ func NewFloatMetricsRecorder(buckets ...float64) *FloatMetricsRecorder

+ func (d *FloatMetricsRecorder) GetMetrics() *FloatMetrics

+ func (d *FloatMetricsRecorder) Record(value float64)

+ type JobMetricsRecorder struct

+ func NewJobMetricsRecorder() *JobMetricsRecorder

+ func (r *JobMetricsRecorder) Metrics() []*QueueMetrics

+ func (r *JobMetricsRecorder) RecordJobRuntime(pool string, priorityClass string, jobRuntime time.Duration)

+ func (r *JobMetricsRecorder) RecordResources(pool string, priorityClass string, resources common.ComputeResourcesFloat)

+ type QueueInfoCollector struct

+ func ExposeDataMetrics(queueRepository repository.QueueRepository, ...) *QueueInfoCollector

+ func (c *QueueInfoCollector) Collect(metrics chan<- prometheus.Metric)

+ func (c *QueueInfoCollector) Describe(desc chan<- *prometheus.Desc)

+ type QueueMetricProvider interface

+ GetQueuedJobMetrics func(queueName string) []*QueueMetrics

+ GetRunningJobMetrics func(queueName string) []*QueueMetrics

+ type QueueMetrics struct

+ Durations *FloatMetrics

+ Pool string

+ PriorityClass string

+ Resources ResourceMetrics

+ type QueueMetricsRecorder struct

+ Pool string

+ PriorityClass string

+ type ResourceMetrics map[string]*FloatMetrics

+ type ResourceMetricsRecorder struct

+ func NewResourceMetricsRecorder() *ResourceMetricsRecorder

+ func (d *ResourceMetricsRecorder) GetMetrics() ResourceMetrics

+ func (d *ResourceMetricsRecorder) Record(value common.ComputeResourcesFloat)