indexing_merge

type Config struct {
	NumOfWorkers         int `config:"worker_size"`
	IdleTimeoutInSeconds int `config:"idle_timeout_in_seconds"`
	BulkSizeInKB         int `config:"bulk_size_in_kb"`
	BulkSizeInMB         int `config:"bulk_size_in_mb"`

	IndexName string `config:"index_name"`
	TypeName  string `config:"type_name"`

	KeyField string `config:"key_field"` //the field name used as document's primary key aka `_id

	Elasticsearch string `config:"elasticsearch"`

	InputQueue string `config:"input_queue"`

	OutputQueue struct {
		Name   string                 `config:"name"`
		Labels map[string]interface{} `config:"label" json:"label,omitempty"`
	} `config:"output_queue"`

	FailureQueue string `config:"failure_queue"`
	InvalidQueue string `config:"invalid_queue"`
}

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