make loop interval configurable

1 files changed, 9 insertions, 1 deletions

diff --git a/internal/quorum/quorum.go b/internal/quorum/quorum.go
index 52cf6ee..dfeabe6 100644
--- a/internal/quorum/quorum.go
+++ b/internal/quorum/quorum.go
@@ -36,17 +36,25 @@ func New(conf config.Config) Quorum {
 func (quo Quorum) Start(ctx context.Context) <-chan vote.Vote {
 	ch := make(chan vote.Vote)
 
+	interval := time.Second * time.Duration(quo.conf.LoopIntervalS)
+	if vote.Expiry <= interval {
+		log.Fatal("quorum: LoopIntervalS ", quo.conf.LoopIntervalS,
+			" should be less than the vote expiry of ", vote.Expiry)
+	}
+
 	go func() {
 		defer close(ch)
 
 		for {
 			select {
-			case <-time.After(vote.Expiry):
+			case <-time.After(interval):
 				myVote, _ := quo.makeMyVote()
+				log.Println("quorum: made my vote:", myVote)
 				ch <- myVote
 			case v := <-quo.voteCh:
 				quo.vote(v)
 				if myVote, changed := quo.makeMyVote(); changed {
+					log.Println("quorum: changed my vote:", myVote)
 					ch <- myVote
 				}
 				quo.score()