batcher

type Batch struct {
	Group        string
	Deflate      bool
	Message      *utils.Message
	Buf          *bytes.Buffer
	Writer       io.Writer
	MessageCount uint64     // Current number of messages in the buffer
	Done         utils.Done // Call to pass the message to the next handler
	Timer        *clock.Timer
	Sent         bool
}

type Batcher struct {
	Config
	// contains filtered or unexported fields
}

type Config struct {
	Workers           int
	Deflate           bool
	TimeoutMillis     uint
	Limit             uint64
	MaxPendingBatches uint
}