executors

Documentation

Index

• Constants
• func GetExecutors() map[string]Executor
• func NormalizeDesc(s string) string
• func NormalizeMetric(s string) string
• func PushToPrometheus(asMetric statprocessors.AerospikeStat, ch chan<- prometheus.Metric)
• type Executor
• type OtelExecutor
  • func (oe OtelExecutor) Initialize() error
• type PrometheusHttpExecutor
  • func (pm PrometheusHttpExecutor) Initialize() error
• type PrometheusImpl
  • func NewPrometheusImpl() (o *PrometheusImpl)
  • func (o *PrometheusImpl) Collect(ch chan<- prometheus.Metric)
  • func (o *PrometheusImpl) Describe(ch chan<- *prometheus.Desc)

Constants

const (
	PROMETHEUS = "prometheus"
	OTELGRPC   = "otel"
)

Functions

func GetExecutors

func GetExecutors() map[string]Executor

func NormalizeDesc

func NormalizeDesc(s string) string

func NormalizeMetric

func NormalizeMetric(s string) string

func PushToPrometheus

func PushToPrometheus(asMetric statprocessors.AerospikeStat, ch chan<- prometheus.Metric)

This is a common utility, used by all the statprocessors to push metric to prometheus

Types

type Executor

type Executor interface {
	Initialize() error
}

type OtelExecutor

type OtelExecutor struct {
}

func (OtelExecutor) Initialize

func (oe OtelExecutor) Initialize() error

Exporter interface implementation

type PrometheusHttpExecutor

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

func (PrometheusHttpExecutor) Initialize

func (pm PrometheusHttpExecutor) Initialize() error

type PrometheusImpl

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

PrometheusImpl communicates with Aerospike and helps collecting metrices

func NewPrometheusImpl

func NewPrometheusImpl() (o *PrometheusImpl)

func (*PrometheusImpl) Collect

func (o *PrometheusImpl) Collect(ch chan<- prometheus.Metric)

Collect function of Prometheus' Collector interface

func (*PrometheusImpl) Describe

func (o *PrometheusImpl) Describe(ch chan<- *prometheus.Desc)

Describe function of Prometheus' Collector interface