indexer

Documentation

Index

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

Types

type Config

type Config struct {
	Source        bus.AckSource
	SampleIndexer storage.SampleIndexer
}

Config represents the configuration of an Indexer. It takes an implmenter Acksource of the target message bus and an implmenter of SampleIndexer of the target indexing system.

type Indexer

type Indexer struct {
	prometheus.Collector
	Source        bus.AckSource
	SampleIndexer storage.SampleIndexer
	// contains filtered or unexported fields
}

Indexer represents an object that consumes metrics from a message bus and writes them to indexing system.

func NewIndexer

func NewIndexer(config *Config) *Indexer

NewIndexer creates a new instance of an Indexer.

func (*Indexer) Collect

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

Collect implements prometheus.Collector. Sends metrics collected by the instance's indexDurations, SampleIndexer, and errorsTotal to the parameter ch.

func (*Indexer) Describe

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

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

func (*Indexer) Run

func (i *Indexer) Run() error

Run starts the indexer process of consuming from the bus and indexing to the target indexing system.