timebatch is a package for batching messages over a time interval.
This can be useful for receiving messages that occur “quickly” and sending them on a slower (constant) interval in batches.

b := timebatch.New(3 * time.Second) // creates a new batcher

// register a receiver to listen for batches of messages
go func() {
	for _, b := range batches {
		fmt.Println(b) // this is a batch of messages

// register a producer to send messages
go func() {
    b.Close() // must be closed once all messages are sent to clean up

// output will look something like: [1, 2, 3]
// as there were only 3 messages sent within the first time interval


View Github