metrics

Documentation

Index

• func JobStatusCounter(kind string, reader client.Reader, filter func(status v1.JobStatus) bool) (result int32, err error)
• func StartMonitoringForDefaultRegistry(metricsPort int)
• type JobMetrics
  • func NewJobMetrics(kind string, client client.Client) *JobMetrics
  • func (m *JobMetrics) AllPodsLaunchDelaySeconds(pods []*corev1.Pod, job metav1.Object, status v1.JobStatus)
  • func (m *JobMetrics) CreatedInc()
  • func (m *JobMetrics) DeletedInc()
  • func (m *JobMetrics) FailureInc()
  • func (m *JobMetrics) FirstPodLaunchDelaySeconds(activePods []*corev1.Pod, job metav1.Object, status v1.JobStatus)
  • func (m *JobMetrics) RestartInc()
  • func (m *JobMetrics) SuccessInc()

Functions

func JobStatusCounter

func JobStatusCounter(kind string, reader client.Reader, filter func(status v1.JobStatus) bool) (result int32, err error)

func StartMonitoringForDefaultRegistry

func StartMonitoringForDefaultRegistry(metricsPort int)

Types

type JobMetrics

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

JobMetrics holds the kinds of metrics counter for some type of job workload.

func NewJobMetrics

func NewJobMetrics(kind string, client client.Client) *JobMetrics

func (*JobMetrics) AllPodsLaunchDelaySeconds

func (m *JobMetrics) AllPodsLaunchDelaySeconds(pods []*corev1.Pod, job metav1.Object, status v1.JobStatus)

func (*JobMetrics) CreatedInc

func (m *JobMetrics) CreatedInc()

func (*JobMetrics) DeletedInc

func (m *JobMetrics) DeletedInc()

func (*JobMetrics) FailureInc

func (m *JobMetrics) FailureInc()

func (*JobMetrics) FirstPodLaunchDelaySeconds

func (m *JobMetrics) FirstPodLaunchDelaySeconds(activePods []*corev1.Pod, job metav1.Object, status v1.JobStatus)

func (*JobMetrics) RestartInc

func (m *JobMetrics) RestartInc()

func (*JobMetrics) SuccessInc

func (m *JobMetrics) SuccessInc()