channel

Channel queue, is a memory buffer queue implemented based on go chan.

Example

  1. queue:
  2.   type: channel

batchSize

fieldtyperequireddefaultdescription
batchSizeintfalse2048The number of events contained in a batch.

batchBytes

fieldtyperequireddefaultdescription
batchBytesint64false33554432(32MB)The maximum number of bytes of data contained in a batch.

batchAggTimeout

fieldtyperequireddefaultdescription
batchAggTimeouttime.Durationfalse1sTimeout time for Assembling and aggregating multiple events into one batch.