batch

type Consumer interface {
	// must be reentrancy
	Consume([]interface{})
}

type KeyBatchProcessor interface {
	TryPut(string, interface{}) bool

	Run()
	Shutdown()

	KeyNum() int
	BufferNum() int

	AdjustBatchMaxSize(int)
	AdjustBatchMaxWait(duration int)
	// contains filtered or unexported methods
}

type KeyConsumer interface {
	// must be reentrancy
	Consume(string, []interface{})
}

type OptionFunc func(*options)

type Processor interface {
	Put(interface{})
	TryPut(interface{}) bool

	Run()
	Shutdown()

	Num() int

	AdjustBatchMaxSize(int)
	AdjustBatchMaxWait(duration int)
	// contains filtered or unexported methods
}