- params := &es.BulkProcessorParameters{
- Name: processorName,
- NumOfWorkers: config.ESProcessorNumOfWorkers(),
- BulkActions: config.ESProcessorBulkActions(),
- BulkSize: config.ESProcessorBulkSize(),
- FlushInterval: config.ESProcessorFlushInterval(),
- Backoff: elastic.NewExponentialBackoff(esProcessorInitialRetryInterval, esProcessorMaxRetryInterval),
- BeforeFunc: p.bulkBeforeAction,
- AfterFunc: p.bulkAfterAction,
- }