prometheus_exporter

Documentation

Index

• Constants
• func AcquirePrompbTimeSeries() *prompb.TimeSeries
• func ReleasePrompbTimeSeries(t *prompb.TimeSeries)
• type Counter
• type PrometheusExporter
  • func NewPrometheusExporter(index int, config *exporters_cfg.ExporterCfg, ...) *PrometheusExporter
  • func (e *PrometheusExporter) Close()
  • func (e *PrometheusExporter) GetCounter() interface{}
  • func (e *PrometheusExporter) HandleSimpleCommand(op uint16, arg string) string
  • func (e *PrometheusExporter) Put(items ...interface{})
  • func (e *PrometheusExporter) Start()

Constants

const (
	QUEUE_BATCH_COUNT = 1024
)

Functions

func AcquirePrompbTimeSeries

func AcquirePrompbTimeSeries() *prompb.TimeSeries

func ReleasePrompbTimeSeries

func ReleasePrompbTimeSeries(t *prompb.TimeSeries)

Types

type Counter

type Counter struct {
	RecvCounter      int64 `statsd:"recv-count"`
	SendCounter      int64 `statsd:"send-count"`
	SendBatchCounter int64 `statsd:"send-batch-count"`
	DropCounter      int64 `statsd:"drop-count"`
	DropBatchCounter int64 `statsd:"drop-batch-count"`
	ExportUsedTimeNs int64 `statsd:"export-used-time-ns"`
}

type PrometheusExporter

type PrometheusExporter struct {
	Addr string

	utils.Closable
	// contains filtered or unexported fields
}

func NewPrometheusExporter

func NewPrometheusExporter(index int, config *exporters_cfg.ExporterCfg, universalTagsManager *utag.UniversalTagsManager) *PrometheusExporter

func (*PrometheusExporter) Close

func (e *PrometheusExporter) Close()

func (*PrometheusExporter) GetCounter

func (e *PrometheusExporter) GetCounter() interface{}

func (*PrometheusExporter) HandleSimpleCommand

func (e *PrometheusExporter) HandleSimpleCommand(op uint16, arg string) string

func (*PrometheusExporter) Put

func (e *PrometheusExporter) Put(items ...interface{})

func (*PrometheusExporter) Start

func (e *PrometheusExporter) Start()