batch

Documentation

Index

• Variables
• type Options
• type Queue
  • func NewQueue(opts Options, mf metrics.Factory, writer Writer) *Queue
  • func (w *Queue) Add(item interface{}) error
  • func (w *Queue) Close()
• type Writer

Variables

var ErrOverflow = errors.New("writer buffer overflow")

Types

type Options

type Options struct {
	BufferSize   int
	BatchSize    int
	BatchWorkers int
}

type Queue

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

Queue represents queue of message batches

func NewQueue

func NewQueue(opts Options, mf metrics.Factory, writer Writer) *Queue

func (*Queue) Add

func (w *Queue) Add(item interface{}) error

func (*Queue) Close

func (w *Queue) Close()

type Writer

type Writer interface {
	WriteItems(_ []interface{})
}