elasticsearch

Documentation

Index

• func SetupMatchTemplate(base string) error
• type SampleIndexer
  • func NewSampleIndexer(config *SampleIndexerConfig) *SampleIndexer
  • func (si *SampleIndexer) Collect(ch chan<- prometheus.Metric)
  • func (si *SampleIndexer) Describe(ch chan<- *prometheus.Desc)
  • func (si *SampleIndexer) IndexSample(s *bus.Sample) error
• type SampleIndexerConfig

Functions

func SetupMatchTemplate

func SetupMatchTemplate(base string) error

SetupMatchTemplate sets up elastic search templates for the type of text query we need to run

Types

type SampleIndexer

type SampleIndexer struct {
	prometheus.Collector
	Client *elastic.Client
	Index  string
	// contains filtered or unexported fields
}

SampleIndexer represents an object that takes bus messages and makes indexing decisions on the target ElasticSearch cluster.

func NewSampleIndexer

func NewSampleIndexer(config *SampleIndexerConfig) *SampleIndexer

NewSampleIndexer creates a new instance of SampleIndexer.

func (*SampleIndexer) Collect

func (si *SampleIndexer) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector. Sends metrics collected bu the instance's indexDurations to the parameter ch.

func (*SampleIndexer) Describe

func (si *SampleIndexer) Describe(ch chan<- *prometheus.Desc)

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

func (*SampleIndexer) IndexSample

func (si *SampleIndexer) IndexSample(s *bus.Sample) error

IndexSample implements the SampleIndexer interface.

type SampleIndexerConfig

type SampleIndexerConfig struct {
	Client *elastic.Client
	Index  string
}

SampleIndexerConfig represents the configuration of a SampleIndexer.