batchqueue

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

type BatchSink interface {
	Send(ctx context.Context, msg interface{}) error
	Flush(ctx context.Context) error
	Close()
}

type BlockingQueue interface {
	// Put enqueue one item, block if the queue is full.
	Put(item interface{})

	// Take dequeue one item, block until it's available.
	Take() interface{}

	// Poll dequeue one item, return nil if queue is empty.
	Poll() interface{}

	// Peek return the first item without dequeing, return nil if queue is empty.
	Peek() interface{}

	// PeekLast return last item in queue without dequeing, return nil if queue is empty.
	PeekLast() interface{}

	// Size return the current size of the queue.
	Size() int

	// Iterator return an iterator for the queue.
	Iterator() BlockingQueueIterator
}

type BlockingQueueIterator interface {
	HasNext() bool
	Next() interface{}
}

type CallbackFn func(sequenceID uint64, e error)

type Config struct {
	Name     string
	DoSinkFn ProcessFn
	// BatchingMaxMessages set the maximum number of messages permitted in a batch. (default: 1000)
	MaxBatching int
	// MaxPendingMessages set the max size of the queue.
	MaxPendingMessages uint
	// BatchingMaxFlushDelay set the time period within which the messages sent will be batched (default: 10ms)
	BatchingMaxFlushDelay time.Duration
}

type ProcessFn func(msgs []interface{}) (err error)