metrics

Documentation

Index

• type Metrics
  • func New(errorRegexes []string, trackedResourceNames []v1.ResourceName, ...) (*Metrics, error)
  • func (m *Metrics) Collect(ch chan<- prometheus.Metric)
  • func (m *Metrics) Describe(ch chan<- *prometheus.Desc)
  • func (m *Metrics) DisableJobStateMetrics()
  • func (m *Metrics) EnableJobStateMetrics()
  • func (m *Metrics) JobStateMetricsEnabled() bool
  • func (m Metrics) ReportJobLeased(job *jobdb.Job)
  • func (m Metrics) ReportReconcileCycleTime(cycleTime time.Duration)
  • func (m Metrics) ReportScheduleCycleTime(cycleTime time.Duration)
  • func (m Metrics) ReportSchedulerResult(result schedulerresult.SchedulerResult)
  • func (m Metrics) ReportStateTransitions(jsts []jobdb.JobStateTransitions, ...)

Types

type Metrics

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

Metrics is the top level scheduler metrics.

func New

func New(errorRegexes []string, trackedResourceNames []v1.ResourceName, jobStateMetricsResetInterval time.Duration) (*Metrics, error)

func (*Metrics) Collect

func (m *Metrics) Collect(ch chan<- prometheus.Metric)

Collect is necessary to implement the prometheus.Collector interface

func (*Metrics) Describe

func (m *Metrics) Describe(ch chan<- *prometheus.Desc)

Describe is necessary to implement the prometheus.Collector interface

func (*Metrics) DisableJobStateMetrics

func (m *Metrics) DisableJobStateMetrics()

DisableJobStateMetrics stops the jobStateMetrics from being produced. This is necessary because we only produce these metrics when we are leader in order to avoid double counting

func (*Metrics) EnableJobStateMetrics

func (m *Metrics) EnableJobStateMetrics()

EnableJobStateMetrics starts the jobStateMetrics

func (*Metrics) JobStateMetricsEnabled

func (m *Metrics) JobStateMetricsEnabled() bool

JobStateMetricsEnabled returns true if job state metrics are enabled

func (Metrics) ReportJobLeased

func (m Metrics) ReportJobLeased(job *jobdb.Job)

ReportJobLeased reports the job as being leasedJob. This has to be reported separately because the state transition logic does work for job leased!

func (Metrics) ReportReconcileCycleTime

func (m Metrics) ReportReconcileCycleTime(cycleTime time.Duration)

func (Metrics) ReportScheduleCycleTime

func (m Metrics) ReportScheduleCycleTime(cycleTime time.Duration)

func (Metrics) ReportSchedulerResult

func (m Metrics) ReportSchedulerResult(result schedulerresult.SchedulerResult)

func (Metrics) ReportStateTransitions

func (m Metrics) ReportStateTransitions(
	jsts []jobdb.JobStateTransitions,
	jobRunErrorsByRunId map[string]*armadaevents.Error,
)