event-limiter

eventlimiter.go

type EventLimiter struct {
	ticker           time.Ticker
	trigger          chan bool
	timePassed       chan bool
}

func NewLimiter() *EventLimiter {
	ticker := time.NewTicker(60 * time.Second)
	trigger := make(chan bool, 1)
	timePassed := make(chan bool, 1)
	return EventLimiter{ticker, trigger, timePassed}
}

func (l EventLimiter) maintainLimiter() {
	//goroutine for both fors
	for {
		<- l.ticker.C
		select {
		case l.timePassed <- true:
		default:
		}
	}
}

func (l EventLimiter) limit(f func()) {
	<- l.timePassed
	<- l.trigger
	f()
}