metrics

Documentation

Index

• type MetricRecorder
• type QueueInfoCollector
  • func ExposeDataMetrics(queueRepository repository.QueueRepository, ...) *QueueInfoCollector
  • func (c *QueueInfoCollector) Collect(metrics chan<- prometheus.Metric)
  • func (c *QueueInfoCollector) Describe(desc chan<- *prometheus.Desc)
  • func (c *QueueInfoCollector) RecordQueuePriorities(priorities map[*api.Queue]scheduling.QueuePriorityInfo)

Types

type MetricRecorder

type MetricRecorder interface {
	RecordQueuePriorities(priorities map[*api.Queue]scheduling.QueuePriorityInfo)
}

type QueueInfoCollector

type QueueInfoCollector struct {
	// contains filtered or unexported fields
}

func ExposeDataMetrics

func ExposeDataMetrics(queueRepository repository.QueueRepository, jobRepository repository.JobRepository) *QueueInfoCollector

func (*QueueInfoCollector) Collect

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

func (*QueueInfoCollector) Describe

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

func (*QueueInfoCollector) RecordQueuePriorities

func (c *QueueInfoCollector) RecordQueuePriorities(priorities map[*api.Queue]scheduling.QueuePriorityInfo)