candidate

type Broker ¶

type Broker struct {
	// contains filtered or unexported fields
}

Broker is the entry point for the candidate component. It manages an in-memory store of `Candidate` messages, and allows for the fetching of these messages through the `RPCBus`. It listens for incoming `Candidate` messages and puts them on the store. In case an internal component requests an absent `Candidate` message, the Broker can make a `GetCandidate` request to the rest of the network, and will attempt to provide the requesting component with it's needed `Candidate`.

func NewBroker(broker eventbus.Broker, rpcBus *rpcbus.RPCBus) *Broker

func (c Broker) Clear(round uint64) int

func (b *Broker) Listen()

type Candidate ¶

type Candidate struct {
	*block.Block
	*block.Certificate
}

func NewCandidate() *Candidate