metrics

Documentation

Index

• Constants
• type ErrorEvent
• type MetricsCollector
  • func NewPrometheusMetricsCollector(r prometheus.Registerer) MetricsCollector
• type OrchestratorMetrics
  • func NewOrchestratorMetrics(r prometheus.Registerer) *OrchestratorMetrics
  • func (o *OrchestratorMetrics) RecordJobDispatched(requestCount int)
  • func (o *OrchestratorMetrics) ResetTargetPodUsage()
  • func (o *OrchestratorMetrics) SetRegisteredExecutors(count int)
  • func (o *OrchestratorMetrics) SetTargetPodUsage(namespace string, podName string, cpuMillicores int64, memoryBytes int64)
• type PrometheusMetricsCollector
  • func (b *PrometheusMetricsCollector) PostFailure(event ErrorEvent)
  • func (b *PrometheusMetricsCollector) PostSuccess(event SuccessEvent)
  • func (b *PrometheusMetricsCollector) RecordJobPickedUp(requestCount int)
• type SuccessEvent

Constants

const MB = 1 << 20

Types

type ErrorEvent

type ErrorEvent struct {
	Status   int
	ErrMsg   string
	Duration time.Duration
}

type MetricsCollector

type MetricsCollector interface {
	PostSuccess(event SuccessEvent)
	PostFailure(event ErrorEvent)
	RecordJobPickedUp(requestCount int)
}

func NewPrometheusMetricsCollector

func NewPrometheusMetricsCollector(r prometheus.Registerer) MetricsCollector

type OrchestratorMetrics

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

func NewOrchestratorMetrics

func NewOrchestratorMetrics(r prometheus.Registerer) *OrchestratorMetrics

func (*OrchestratorMetrics) RecordJobDispatched

func (o *OrchestratorMetrics) RecordJobDispatched(requestCount int)

func (*OrchestratorMetrics) ResetTargetPodUsage

func (o *OrchestratorMetrics) ResetTargetPodUsage()

func (*OrchestratorMetrics) SetRegisteredExecutors

func (o *OrchestratorMetrics) SetRegisteredExecutors(count int)

func (*OrchestratorMetrics) SetTargetPodUsage

func (o *OrchestratorMetrics) SetTargetPodUsage(namespace string, podName string, cpuMillicores int64, memoryBytes int64)

type PrometheusMetricsCollector

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

func (*PrometheusMetricsCollector) PostFailure

func (b *PrometheusMetricsCollector) PostFailure(event ErrorEvent)

func (*PrometheusMetricsCollector) PostSuccess

func (b *PrometheusMetricsCollector) PostSuccess(event SuccessEvent)

func (*PrometheusMetricsCollector) RecordJobPickedUp

func (b *PrometheusMetricsCollector) RecordJobPickedUp(requestCount int)

type SuccessEvent

type SuccessEvent struct {
	Status        int
	ResponseSize  int64
	Duration      time.Duration
	FirstByteTime time.Duration
}