bulk_indexing

type BulkIndexingProcessor struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Config struct {
	NumOfSlices          int   `config:"num_of_slices"`
	Slices               []int `config:"slices"`
	DocumentLevelSlicing bool  `config:"document_level_slicing"`

	IdleTimeoutInSecond  int `config:"idle_timeout_in_seconds"`
	MaxConnectionPerHost int `config:"max_connection_per_node"`

	QueueLabels map[string]interface{} `config:"queues,omitempty"`

	Selector queue.QueueSelector `config:"queue_selector"`

	Consumer queue.ConsumerConfig `config:"consumer"`

	MaxWorkers int `config:"max_worker_size"`

	DetectActiveQueue bool `config:"detect_active_queue"`

	VerboseBulkResult bool `config:"verbose_bulk_result"`

	DetectIntervalInMs int `config:"detect_interval"`

	ValidateRequest   bool `config:"valid_request"`
	SkipEmptyQueue    bool `config:"skip_empty_queue"`
	SkipOnMissingInfo bool `config:"skip_info_missing"`
	LogBulkError      bool `config:"log_bulk_error"`

	BulkConfig elastic.BulkProcessorConfig `config:"bulk"`

	Elasticsearch       string                       `config:"elasticsearch,omitempty"`
	ElasticsearchConfig *elastic.ElasticsearchConfig `config:"elasticsearch_config"`

	WaitingAfter           []string `config:"waiting_after"`
	RetryDelayIntervalInMs int      `config:"retry_delay_interval"`
	// contains filtered or unexported fields
}