batcher

Documentation

Overview

Package batcher provides retriable batch queue: all succeed or rollback for all. In kafka it is called RecordAccumulator.

Package batcher provides retriable batch queue: all succeed or rollback for all. In kafka it is called RecordAccumulator.

Index

• Variables
• type Batcher
  • func NewDisruptor(capacity int) Batcher
  • func NewDryrun(capacity int) Batcher

Variables

var (
	ErrStopping = errors.New("batcher stopping")
)

Types

type Batcher

type Batcher interface {

	// Close closes the batcher from R/W.
	Close()

	// Put writes an item to the batcher. If queue is full, it will block till
	// all inflight items marked success.
	Put(item interface{}) error

	// Get reads an item from the batcher.
	Get() (interface{}, error)

	// Succeed marks an item handling success.
	Succeed()

	// Fail marks an item handling failure.
	Fail() (rewind bool)
}

Batcher is a batched queue with the sematics of all succeed and advance or any fails and retry.

func NewDisruptor

func NewDisruptor(capacity int) Batcher

NewDisruptor create a new smart disruptor batcher instance.

func NewDryrun

func NewDryrun(capacity int) Batcher

NewDryrun creates a dryrun batcher. Used for debugging.