metric

Documentation

Index

• type BaseMetrics
  • func NewBaseMetrics(service types.Service) *BaseMetrics
  • func (m *BaseMetrics) ExportMetrics(ctx context.Context)
  • func (m *BaseMetrics) GetPowerMaxClient(arrayID string) (types.PowerMaxClient, error)
  • func (m *BaseMetrics) TimeSince(start time.Time, fName string)
• type CapacityMetrics
  • func CreateCapacityMetricsInstance(service types.Service) *CapacityMetrics
  • func (m *CapacityMetrics) Collect(ctx context.Context) error
• type MetricsCollector
• type MetricsRecorderWrapper
  • func (mrw *MetricsRecorderWrapper) RecordNumericMetrics(ctx context.Context, metrics []types.NumericMetric) error
• type PerformanceMetrics
  • func CreatePerformanceMetricsInstance(service types.Service) *PerformanceMetrics
  • func (m *PerformanceMetrics) Collect(ctx context.Context) error

Types

type BaseMetrics

type BaseMetrics struct {
	Collector              MetricsCollector
	Logger                 *logrus.Logger
	VolumeFinder           types.VolumeFinder
	PowerMaxClients        map[string][]types.PowerMaxArray
	MetricsRecorder        types.MetricsRecorder
	MaxPowerMaxConnections int
}

BaseMetrics presents the base class of concrete metric classes

func NewBaseMetrics

func NewBaseMetrics(service types.Service) *BaseMetrics

NewBaseMetrics return BaseMetrics instance.

func (*BaseMetrics) ExportMetrics

func (m *BaseMetrics) ExportMetrics(ctx context.Context)

ExportMetrics collect and export metrics to Otel

func (*BaseMetrics) GetPowerMaxClient

func (m *BaseMetrics) GetPowerMaxClient(arrayID string) (types.PowerMaxClient, error)

GetPowerMaxClient return the first live PowerMaxClient based on the given arrayID

func (*BaseMetrics) TimeSince

func (m *BaseMetrics) TimeSince(start time.Time, fName string)

TimeSince will log the amount of time spent in a given function

type CapacityMetrics

type CapacityMetrics struct {
	*BaseMetrics
}

CapacityMetrics CapacityMetrics

func CreateCapacityMetricsInstance

func CreateCapacityMetricsInstance(service types.Service) *CapacityMetrics

CreateCapacityMetricsInstance return a singleton instance of CapacityMetrics.

func (*CapacityMetrics) Collect

func (m *CapacityMetrics) Collect(ctx context.Context) error

Collect metric collection and processing

type MetricsCollector

type MetricsCollector interface {
	Collect(ctx context.Context) error
}

MetricsCollector interface for metric collect

type MetricsRecorderWrapper

type MetricsRecorderWrapper struct {
	Meter types.AsyncMetricCreator
}

MetricsRecorderWrapper contains data used for pushing metrics data

func (*MetricsRecorderWrapper) RecordNumericMetrics

func (mrw *MetricsRecorderWrapper) RecordNumericMetrics(ctx context.Context, metrics []types.NumericMetric) error

RecordNumericMetrics record metrics using Otel's InstrumentProvider

type PerformanceMetrics

type PerformanceMetrics struct {
	*BaseMetrics
}

PerformanceMetrics performance metrics

func CreatePerformanceMetricsInstance

func CreatePerformanceMetricsInstance(service types.Service) *PerformanceMetrics

CreatePerformanceMetricsInstance return a singleton instance of PerformanceMetrics.

func (*PerformanceMetrics) Collect

func (m *PerformanceMetrics) Collect(ctx context.Context) error

Collect performance metric collection and processing