code: func newBulkWorker(p *BulkProcessor, i int) *bulkWorker {
  	return &bulkWorker{
  		p:           p,
  		i:           i,
  		bulkActions: p.bulkActions,
  		bulkSize:    p.bulkSize,
  		service:     NewBulkService(p.c),
  		flushC:      make(chan struct{}),
  		flushAckC:   make(chan struct{}),
  	}
  }
docs: // newBulkWorker creates a new bulkWorker instance.