Reproduce blocking breaker (https://github.com/rubyist/circuitbreaker/)

breakerbreaker.go

package main

import (
	"time"
	"math/rand"
	"log"

	circuit "github.com/rubyist/circuitbreaker"
)

func consume(c <-chan circuit.ListenerEvent) {
	for {
		select {
		case e := <-c:
			log.Println(e)
		case <-time.After(time.Second):
			panic("events blocked")
		}
	}
}

func produce(b *circuit.Breaker) {
	for {
		time.Sleep(time.Duration(rand.Intn(42000)) * time.Nanosecond)
		if b.Tripped() {
			b.Reset()
		} else {
			b.Trip()
		}
	}
}

func main() {
	c := make(chan circuit.ListenerEvent, 1)
	b := circuit.NewBreaker()
	b.AddListener(c)

	go consume(c)
	go produce(b)
	select {}
}