ingester

Documentation

Index

• type Config
• type Ingester
  • func NewIngester(config *Config) *Ingester
  • func (i *Ingester) Collect(ch chan<- prometheus.Metric)
  • func (i *Ingester) Describe(ch chan<- *prometheus.Desc)
  • func (i *Ingester) Run() error

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.