ingester

package
v0.1.0-alpha.3 Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2016 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	SampleWriter storage.SampleWriter
	AckSource    bus.AckSource
}

Config represents the configuration of an Ingester. It requires an AckSource implementer for the target message bus and a SampleWriter implementer of the data storage system.

type Ingester

type Ingester struct {
	prometheus.Collector
	// contains filtered or unexported fields
}

Ingester represents an object that consumes metrics from a bus and writes them to a data storage.

func NewIngester

func NewIngester(config *Config) *Ingester

NewIngester creates a new instance of Ingester.

func (*Ingester) Collect

func (i *Ingester) Collect(ch chan<- prometheus.Metric)

Collect implements Collector. Sends metrics collected by ingesterDurations and errorsTotal to the parameter ch.

func (*Ingester) Describe

func (i *Ingester) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector. Sends decriptors of the instance's ingesterDurations and errorsTotal to the parameter ch.

func (*Ingester) Run

func (i *Ingester) Run() error

Run starts the ingesting process by consuming from the message bus and writing to the data storage system.

Jump to

Keyboard shortcuts

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