metricsstore

Documentation

Index

• type MetricsReader
  • func NewMetricsReader(logger *zap.Logger, hostPort string, connectTimeout time.Duration) (*MetricsReader, error)
  • func (m *MetricsReader) GetCallRates(ctx context.Context, requestParams *metricsstore.CallRateQueryParameters) (*metrics.MetricFamily, error)
  • func (m *MetricsReader) GetErrorRates(ctx context.Context, requestParams *metricsstore.ErrorRateQueryParameters) (*metrics.MetricFamily, error)
  • func (m *MetricsReader) GetLatencies(ctx context.Context, requestParams *metricsstore.LatenciesQueryParameters) (*metrics.MetricFamily, error)
  • func (m *MetricsReader) GetMinStepDuration(_ context.Context, _ *metricsstore.MinStepDurationQueryParameters) (time.Duration, error)

Types

type MetricsReader

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

MetricsReader is a Prometheus metrics reader.

func NewMetricsReader

func NewMetricsReader(logger *zap.Logger, hostPort string, connectTimeout time.Duration) (*MetricsReader, error)

NewMetricsReader returns a new MetricsReader.

func (*MetricsReader) GetCallRates

func (m *MetricsReader) GetCallRates(ctx context.Context, requestParams *metricsstore.CallRateQueryParameters) (*metrics.MetricFamily, error)

GetCallRates gets the call rate metrics for the given set of call rate query parameters.

func (*MetricsReader) GetErrorRates

func (m *MetricsReader) GetErrorRates(ctx context.Context, requestParams *metricsstore.ErrorRateQueryParameters) (*metrics.MetricFamily, error)

GetErrorRates gets the error rate metrics for the given set of error rate query parameters.

func (*MetricsReader) GetLatencies

func (m *MetricsReader) GetLatencies(ctx context.Context, requestParams *metricsstore.LatenciesQueryParameters) (*metrics.MetricFamily, error)

GetLatencies gets the latency metrics for the given set of latency query parameters.

func (*MetricsReader) GetMinStepDuration

func (m *MetricsReader) GetMinStepDuration(_ context.Context, _ *metricsstore.MinStepDurationQueryParameters) (time.Duration, error)

GetMinStepDuration gets the minimum step duration (the smallest possible duration between two data points in a time series) supported.