simple

Documentation

Index

• Constants
• type AckConsumer
  • func (c AckConsumer) Consume(lower, upper int64)
• type DisruptorEvent
• type DisruptorPipeline
  • 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
• type ProcessConsumer
  • func (c ProcessConsumer) Consume(lower, upper int64)
• type SendConsumer
  • func (c SendConsumer) Consume(lower, upper int64)

Constants

const (
	DefaultDisruptorBufferSize  = 8192
	DefaultDisruptorConcurrency = 4
)

Types

type AckConsumer

type AckConsumer struct {
	// contains filtered or unexported fields
}

func (AckConsumer) Consume

func (c AckConsumer) Consume(lower, upper int64)

type DisruptorEvent

type DisruptorEvent struct {
	// contains filtered or unexported fields
}

type DisruptorPipeline

type DisruptorPipeline struct {
	*pipeline.BasePipeline
	// contains filtered or unexported fields
}

DisruptorPipeline gets events from input and sends them to output through disruptor.

func NewDisruptorPipeline

func NewDisruptorPipeline() *DisruptorPipeline

func (*DisruptorPipeline) Ack

func (p *DisruptorPipeline) Ack(msg *core.Message, err error)

func (*DisruptorPipeline) Configure

func (p *DisruptorPipeline) Configure(config core.StringMap) (err error)

func (*DisruptorPipeline) Process

func (p *DisruptorPipeline) Process(msg *core.Message)

func (*DisruptorPipeline) StartPipeline

func (p *DisruptorPipeline) StartPipeline() (err error)

func (*DisruptorPipeline) StopPipeline

func (p *DisruptorPipeline) StopPipeline()

type DisruptorPipelineConfig

type DisruptorPipelineConfig struct {
	Concurrency int
	BufferSize  int
}

type ProcessConsumer

type ProcessConsumer struct {
	// contains filtered or unexported fields
}

func (ProcessConsumer) Consume

func (c ProcessConsumer) Consume(lower, upper int64)

type SendConsumer

type SendConsumer struct {
	// contains filtered or unexported fields
}

func (SendConsumer) Consume

func (c SendConsumer) Consume(lower, upper int64)