Versions in this module Expand all Collapse all v6 v6.4.2 Aug 17, 2020 Changes in this version + func DoGarbageCollection(emitter PrometheusGarbageCollectable, worker string) + type DogstatsDBConfig struct + Host string + Port string + Prefix string + func (config *DogstatsDBConfig) Description() string + func (config *DogstatsDBConfig) IsConfigured() bool + func (config *DogstatsDBConfig) NewEmitter() (metric.Emitter, error) + type DogstatsdEmitter struct + func (emitter *DogstatsdEmitter) Emit(logger lager.Logger, event metric.Event) + type InfluxDBClient interface + Close func() error + Ping func(timeout time.Duration) (time.Duration, string, error) + Query func(q influxclient.Query) (*influxclient.Response, error) + QueryAsChunk func(q influxclient.Query) (*influxclient.ChunkedResponse, error) + Write func(bp influxclient.BatchPoints) error + type InfluxDBConfig struct + BatchDuration time.Duration + BatchSize uint32 + Database string + InsecureSkipVerify bool + Password string + URL string + Username string + func (config *InfluxDBConfig) Description() string + func (config *InfluxDBConfig) IsConfigured() bool + func (config *InfluxDBConfig) NewEmitter() (metric.Emitter, error) + type InfluxDBEmitter struct + BatchDuration time.Duration + BatchSize int + Client influxclient.Client + Database string + func (emitter *InfluxDBEmitter) Emit(logger lager.Logger, event metric.Event) + func (emitter *InfluxDBEmitter) SubmitBatch(logger lager.Logger) + type LagerConfig struct + Enabled bool + func (config *LagerConfig) Description() string + func (config *LagerConfig) IsConfigured() bool + func (config *LagerConfig) NewEmitter() (metric.Emitter, error) + type LagerEmitter struct + func (emitter *LagerEmitter) Emit(logger lager.Logger, event metric.Event) + type NewRelicConfig struct + APIKey string + AccountID string + BatchDuration time.Duration + BatchSize uint64 + DisableCompression bool + ServicePrefix string + Url string + func (config *NewRelicConfig) Description() string + func (config *NewRelicConfig) IsConfigured() bool + func (config *NewRelicConfig) NewEmitter() (metric.Emitter, error) + type NewRelicEmitter struct + BatchDuration time.Duration + BatchSize int + Client *http.Client + DisableCompression bool + LastEmitTime time.Time + NewRelicBatch []NewRelicEvent + Url string + func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event) + type NewRelicEvent map[string]interface + type PrometheusConfig struct + BindIP string + BindPort string + func (config *PrometheusConfig) Description() string + func (config *PrometheusConfig) IsConfigured() bool + func (config *PrometheusConfig) NewEmitter() (metric.Emitter, error) + type PrometheusEmitter struct + func (emitter *PrometheusEmitter) Emit(logger lager.Logger, event metric.Event) + func (emitter *PrometheusEmitter) WorkerContainers() *prometheus.GaugeVec + func (emitter *PrometheusEmitter) WorkerContainersLabels() map[string]map[string]prometheus.Labels + func (emitter *PrometheusEmitter) WorkerTasks() *prometheus.GaugeVec + func (emitter *PrometheusEmitter) WorkerTasksLabels() map[string]map[string]prometheus.Labels + func (emitter *PrometheusEmitter) WorkerVolumes() *prometheus.GaugeVec + func (emitter *PrometheusEmitter) WorkerVolumesLabels() map[string]map[string]prometheus.Labels + type PrometheusGarbageCollectable interface + WorkerContainers func() *prometheus.GaugeVec + WorkerContainersLabels func() map[string]map[string]prometheus.Labels + WorkerTasks func() *prometheus.GaugeVec + WorkerTasksLabels func() map[string]map[string]prometheus.Labels + WorkerVolumes func() *prometheus.GaugeVec + WorkerVolumesLabels func() map[string]map[string]prometheus.Labels
Go to main page