indexer

package
Version: v0.22.3 Latest Latest
Warning

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

Go to latest
Published: Oct 14, 2021 License: MIT Imports: 20 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 {
	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
}

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

Jump to

Keyboard shortcuts

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