Batch Send With Timeout
Golang
Snippets
idleDuration := 10 * time.Second
idleDelay := time.NewTimer(idleDuration)
for {
idleDelay.Reset(idleDuration)
msgQueue := make([]model.MinIOEvent, 0, BatchSize)
var needToSend bool
for !needToSend {
select {
case msg := <-k.ms...
