indexer

Documentation

Index

• type Config
• type Indexer
  • func NewIndexer(config *Config, client messaging.Client, esClient es.GenericClient, ...) *Indexer
  • func (x *Indexer) Start() error
  • func (x *Indexer) Stop()

Types

type Config

type Config struct {
	IndexerConcurrency             dynamicconfig.IntPropertyFn
	ESProcessorNumOfWorkers        dynamicconfig.IntPropertyFn
	ESProcessorBulkActions         dynamicconfig.IntPropertyFn // max number of requests in bulk
	ESProcessorBulkSize            dynamicconfig.IntPropertyFn // max total size of bytes in bulk
	ESProcessorFlushInterval       dynamicconfig.DurationPropertyFn
	ValidSearchAttributes          dynamicconfig.MapPropertyFn
	EnableQueryAttributeValidation dynamicconfig.BoolPropertyFn
}

Config contains all configs for indexer

type Indexer

type Indexer struct {
	// contains filtered or unexported fields
}

Indexer used to consumer data from kafka then send to ElasticSearch

func NewIndexer

func NewIndexer(
	config *Config,
	client messaging.Client,
	esClient es.GenericClient,
	esConfig *config.ElasticSearchConfig,
	logger log.Logger,
	metricsClient metrics.Client,
) *Indexer

NewIndexer create a new Indexer

func (*Indexer) Start

func (x *Indexer) Start() error

Start indexer

func (*Indexer) Stop

func (x *Indexer) Stop()

Stop indexer