json_indexing

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"`
	IndexPrefix          string `config:"index_prefix"`
	IndexName            string `config:"index_name"`
	TypeName             string `config:"type_name"`
	Elasticsearch        string `config:"elasticsearch"`
	InputQueue           string `config:"input_queue"`
	FailureQueue         string `config:"failure_queue"`
	InvalidQueue         string `config:"invalid_queue"`
	CheckESAvailable     bool   `config:"check_available"`
}

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