indexer

Documentation

Index

• type BulkIndexDoc
• type IndexFunc
• type Indexer
  • func New(esHosts []string, ...) *Indexer

Types

type BulkIndexDoc

type BulkIndexDoc struct {
	DocumentId    string
	BulkOperation string
}

type IndexFunc

type IndexFunc func(*changestream.ChangeMessage) (*BulkIndexDoc, error)

IndexFunc is the type for the functions which will insert data into elasticsearch

type Indexer

type Indexer struct {
	*worker.Worker
	// contains filtered or unexported fields
}

Indexer is the type definition of the esInserter

func New

func New(esHosts []string, esIndex, esMapping, kafkaAddress, changesTopic, kafkaGroupID string, indexFunc IndexFunc, bulkChunkSize int, bulkFetchTimeout int) *Indexer

New returns an initialised Indexer