Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + const DefaultDisruptorBufferSize + const DefaultDisruptorConcurrency + type AckConsumer struct + func (c AckConsumer) Consume(lower, upper int64) + type DisruptorEvent struct + type DisruptorPipeline struct + func NewDisruptorPipeline() *DisruptorPipeline + func (p *DisruptorPipeline) Ack(msg *core.Message, err error) + func (p *DisruptorPipeline) Configure(config core.StringMap) (err error) + func (p *DisruptorPipeline) Process(msg *core.Message) + func (p *DisruptorPipeline) StartPipeline() (err error) + func (p *DisruptorPipeline) StopPipeline() + type DisruptorPipelineConfig struct + BufferSize int + Concurrency int + type ProcessConsumer struct + func (c ProcessConsumer) Consume(lower, upper int64) + type SendConsumer struct + func (c SendConsumer) Consume(lower, upper int64)
Go to main page