reconcile.go

// To execute Go code, please declare a func main() in a package "main"

package main

import (
	"fmt"
	"math/rand"
	"time"
)

type event string

var MAX_QUEUE_SIZE int = 2000

func main() {
	eventCh := make(chan event)

	go func() {
		for {
			fmt.Println("Sending event!")
			eventCh <- "hi"
			dur := time.Duration(rand.Intn(1000))
			time.Sleep(dur * time.Millisecond)
		}
	}()

	reconcile := func() {
		fmt.Println("Reconciling...")
		time.Sleep(750 * time.Millisecond)
	}

	inbox := make(chan event, 1)
	go func() {
		for {
			e := <-eventCh
			select {
			case inbox <- e:
				// Event is now in the inbox
				fmt.Println("Event queued in inbox")
			default:
				// Overflow event gets dropped
				fmt.Println("Discarded overflow event")
			}
		}
	}()

	for {
		<-inbox
		reconcile()
	}
}