我的书签
添加书签
移除书签memory
memory queue,是基于go-disruptor实现的内存缓冲queue。
Note
由于go-disruptor版本还未release，memory queue还属于实验阶段。生产环境不建议使用！
Example
queue:type: memory
batchSize
字段 | 类型 | 是否必填 | 默认值 | 含义 |
|---|---|---|---|---|
| batchSize | int | 不必填 | 2048 | 一个批次包含的event数量 |
batchBufferFactor
字段 | 类型 | 是否必填 | 默认值 | 含义 |
|---|---|---|---|---|
| batchBufferFactor | int | 不必填 | 2 | queue缓冲区的大小(channel的容量)=batchSize*batchBufferFactor |
batchBytes
字段 | 类型 | 是否必填 | 默认值 | 含义 |
|---|---|---|---|---|
| batchBytes | int64 | 不必填 | 33554432(32MB) | 一个批次包含的数据最大字节数 |
batchAggTimeout
字段 | 类型 | 是否必填 | 默认值 | 含义 |
|---|---|---|---|---|
| batchAggTimeout | time.Duration | 不必填 | 1s | 组装聚合多个event成一个batch等待的超时时间 |
