diff --git a/pkg/metrics/queue.go b/pkg/metrics/queue.go index c65ec761a..e7316ad49 100644 --- a/pkg/metrics/queue.go +++ b/pkg/metrics/queue.go @@ -317,15 +317,6 @@ func (m *QueueMetrics) SetQueueNilResourceMetrics(state string) { } } -func (m *QueueMetrics) GetQueueMaxResourceMetrics(resourceName string) (float64, error) { - metricDto := &dto.Metric{} - err := m.resourceMetricsLabel.WithLabelValues(QueueMax, resourceName).Write(metricDto) - if err == nil { - return *metricDto.Gauge.Value, nil - } - return -1, err -} - func (m *QueueMetrics) GetAllQueueStateMetrics(state string) (map[string]float64, error) { metrics := make(map[string]float64) metricFamilies, err := prometheus.DefaultGatherer.Gather() @@ -352,15 +343,6 @@ func (m *QueueMetrics) GetAllQueueStateMetrics(state string) (map[string]float64 return metrics, nil } -func (m *QueueMetrics) GetQueueGuaranteedResourceMetrics(resourceName string) (float64, error) { - metricDto := &dto.Metric{} - err := m.resourceMetricsLabel.WithLabelValues(QueueGuaranteed, resourceName).Write(metricDto) - if err == nil { - return *metricDto.Gauge.Value, nil - } - return -1, err -} - func (m *QueueMetrics) SetQueueAllocatedResourceMetrics(resourceName string, value float64) { m.setQueueResource(ContainerAllocated, resourceName, value) }