collector

package
v0.0.0-...-2119b44 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2024 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetricType

type MetricType string
const (
	MetricUnkown    MetricType = "unavailable"
	MetricGuage     MetricType = "guage"
	MetricCounter   MetricType = "counter"
	MetricHistogram MetricType = "histogram"
	MetricSummary   MetricType = "summary"
)

func MetricTypeFromString

func MetricTypeFromString(s string) MetricType

type Metrics

type Metrics struct {
	Name string
	Type MetricType

	Labels prometheus.Labels
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(name string, mtype string) *Metrics

func SetUpMetric

func SetUpMetric(mc *MetricsCollector, ms pkg.MetricSchema) (*Metrics, error)

func (*Metrics) InitializeMetric

func (m *Metrics) InitializeMetric(ms pkg.MetricSchema) error

func (*Metrics) RegisterMetric

func (m *Metrics) RegisterMetric(registry *prometheus.Registry) error

func (*Metrics) SetLabels

func (m *Metrics) SetLabels(clabels map[string]string)

func (*Metrics) SetMetric

func (m *Metrics) SetMetric(value float64, labels prometheus.Labels) error

type MetricsCollector

type MetricsCollector struct {
	MetricsMap map[string]Metrics
	Config     map[string]pkg.MetricConfig
	// contains filtered or unexported fields
}

func NewMetricsCollector

func NewMetricsCollector(orgName string, config []pkg.MetricConfig) *MetricsCollector

func (*MetricsCollector) AddMetrics

func (c *MetricsCollector) AddMetrics(name string, m Metrics) error

func (*MetricsCollector) GetConfigForEvent

func (c *MetricsCollector) GetConfigForEvent(event string) (*pkg.MetricConfig, error)

func (*MetricsCollector) GetMetric

func (c *MetricsCollector) GetMetric(name string) (*Metrics, error)

func (*MetricsCollector) RegisterGrpcService

func (c *MetricsCollector) RegisterGrpcService(s *grpc.Server)

func (*MetricsCollector) StartMetricServer

func (c *MetricsCollector) StartMetricServer(metrics *config.Metrics)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL