gossip

type Actor interface {
	// SetPlayers changes the list of participants that the actor should send
	// rumors to. It is up to the implementation to send to only a subset.
	SetPlayers(mino.Players)

	// Add adds the rumor in the set of rumors that must be spread to the
	// participants.
	Add(rumor Rumor) error

	// Close cleans any resource used by the actor.
	Close() error
}

type Flat struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Gossiper interface {
	// Rumors returns a channel populated with the new rumors.
	Rumors() <-chan Rumor

	// Listen starts to listen for rumors and returns a gossip actor.
	Listen() (Actor, error)
}

type Rumor interface {
	serde.Message

	// GetID returns the unique identifier of the rumor.
	GetID() []byte
}