metrics

Documentation

Index

• func NewMetrics(config types.MonitoringConfig, source string) (repository.MetricsRepository, error)
• func NewOpenMeterMetricsRepository(omConfig types.OpenMeterConfig) repository.MetricsRepository
• func NewPrometheusMetricsRepository(promConfig types.PrometheusConfig) repository.MetricsRepository
• type MetricsSource
• type OpenMeterMetricsRepository
  • func (o *OpenMeterMetricsRepository) IncrementCounter(name string, data map[string]interface{}, value float64) error
  • func (o *OpenMeterMetricsRepository) Init(source string) error
  • func (o *OpenMeterMetricsRepository) SetGauge(name string, data map[string]interface{}, value float64) error
• type PrometheusMetricsRepository
  • func (pr *PrometheusMetricsRepository) IncrementCounter(name string, metadata map[string]interface{}, value float64) error
  • func (r *PrometheusMetricsRepository) Init(source string) error
  • func (pr *PrometheusMetricsRepository) SetGauge(name string, metadata map[string]interface{}, value float64) error

Functions

func NewMetrics

func NewMetrics(config types.MonitoringConfig, source string) (repository.MetricsRepository, error)

func NewOpenMeterMetricsRepository

func NewOpenMeterMetricsRepository(omConfig types.OpenMeterConfig) repository.MetricsRepository

func NewPrometheusMetricsRepository

func NewPrometheusMetricsRepository(promConfig types.PrometheusConfig) repository.MetricsRepository

Types

type MetricsSource

type MetricsSource string

var (
	MetricsSourceGateway MetricsSource = "gateway"
	MetricsSourceWorker  MetricsSource = "worker"
)

type OpenMeterMetricsRepository

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

func (*OpenMeterMetricsRepository) IncrementCounter

func (o *OpenMeterMetricsRepository) IncrementCounter(name string, data map[string]interface{}, value float64) error

func (*OpenMeterMetricsRepository) Init

func (o *OpenMeterMetricsRepository) Init(source string) error

func (*OpenMeterMetricsRepository) SetGauge

func (o *OpenMeterMetricsRepository) SetGauge(name string, data map[string]interface{}, value float64) error

type PrometheusMetricsRepository

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

func (*PrometheusMetricsRepository) IncrementCounter

func (pr *PrometheusMetricsRepository) IncrementCounter(name string, metadata map[string]interface{}, value float64) error

func (*PrometheusMetricsRepository) Init

func (r *PrometheusMetricsRepository) Init(source string) error

func (*PrometheusMetricsRepository) SetGauge

func (pr *PrometheusMetricsRepository) SetGauge(name string, metadata map[string]interface{}, value float64) error