metric_service

Documentation

Index

• type MetricsService
  • func NewMetricService(promClient *prometheus.PrometheusClient, ...) *MetricsService
  • func (self *MetricsService) GetMetrics(ctx context.Context, requesterUserID uuid.UUID, ...) (*models.MetricsResult, error)
  • func (self *MetricsService) GetNodeMetrics(ctx context.Context, requesterUserID uuid.UUID, ...) (*models.NodeMetricsResult, error)
  • func (self *MetricsService) GetVolumeMetrics(ctx context.Context, requesterUserID uuid.UUID, ...) (*models.VolumeMetricsResult, error)

Types

type MetricsService

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

Integrate metrics management with internal permissions and kubernetes RBAC

func NewMetricService

func NewMetricService(promClient *prometheus.PrometheusClient, repo repositories.RepositoriesInterface, k8s *k8s.KubeClient) *MetricsService

func (*MetricsService) GetMetrics

func (self *MetricsService) GetMetrics(ctx context.Context, requesterUserID uuid.UUID, input *models.MetricsQueryInput) (*models.MetricsResult, error)

func (*MetricsService) GetNodeMetrics

func (self *MetricsService) GetNodeMetrics(ctx context.Context, requesterUserID uuid.UUID, input *models.NodeMetricsQueryInput) (*models.NodeMetricsResult, error)

New method for getting node metrics

func (*MetricsService) GetVolumeMetrics

func (self *MetricsService) GetVolumeMetrics(ctx context.Context, requesterUserID uuid.UUID, input *models.MetricsVolumeQueryInput) (*models.VolumeMetricsResult, error)