statistics

Documentation

Index

• type PrometheusServer
  • func GetPrometheusServer() PrometheusServer
  • func NewPrometheusServer(address string) PrometheusServer
  • func (s PrometheusServer) Stop()
  • func (s PrometheusServer) WatchResultQueueLength(channels map[data.Datatype]chan collector.Printable)

Types

type PrometheusServer

type PrometheusServer struct {
	SpoolFilesOnDisk         prometheus.Gauge
	SpoolFilesInQueue        prometheus.Gauge
	SpoolFilesParsedDuration prometheus.Counter
	SpoolFilesParsed         prometheus.Counter
	SpoolFilesLines          prometheus.Counter
	BytesSend                *prometheus.CounterVec
	SendDuration             *prometheus.CounterVec
	// contains filtered or unexported fields
}

PrometheusServer stores all prometheus metrics

func GetPrometheusServer

func GetPrometheusServer() PrometheusServer

GetPrometheusServer returns the single Prometheusserver

func NewPrometheusServer

func NewPrometheusServer(address string) PrometheusServer

NewPrometheusServer creates a new PrometheusServer

func (PrometheusServer) Stop

func (s PrometheusServer) Stop()

Stop stops the Server

func (PrometheusServer) WatchResultQueueLength

func (s PrometheusServer) WatchResultQueueLength(channels map[data.Datatype]chan collector.Printable)

WatchResultQueueLength continually monitors the global queue