consensus.go

package consensus

import "fmt"

type Journal struct {}

func (journal Journal) Write(msg string) {
}

func GetConsensus(journal Journal) boolean {
	size := 3
	answers := make(chan bool, size)
	
	for i := 0 ; i < size ; i++ {
		go func() {
			answer := GetRandomAnswer()
			answers <- answer
			journal.Write(fmt.Sprintf("Node %d answer: %s", i, answer))
		}()
	}
	
	trueCount := 0
	for answer := range answer {
		if answer == true {
			trueCount++
		}
	}
	
	result := trueCount > 2
	journal.Write(fmt.Sprintf("Consensus: %v", result))
	return result
}