factory

README

ConsensusFactory

ConsensusFactory is responsible for initializing the consensus processes with the proper parameters. It subscribes to the initialization topic and, upon reception of a message, will start all of the components related to consensus. It should also contain all the relevant information for the processes it intends to start up.

API

- `New(eventBus, rpcBus, timeOut, keys, d, k)` - creates a `ConsensusFactory` by accepting an `EventBus`, an `RPCBus`, and the `timerLength` being the duration of all the phases. It also initializes the channel for listening to the initial _block height_ necessary to begin the consensus.
- `StartConsensus()` - after receiving an initialization message with the Block Height, proceed to start the consensus components by invoking:
    - `reputation.Launch`
    - `generation.Launch`
    - `selection.Launch`
    - `reduction.Launch`
    - `agreement.Launch`

Documentation

Index

• type ConsensusFactory
  • func New(eventBus wire.EventBroker, rpcBus *wire.RPCBus, timerLength time.Duration, ...) *ConsensusFactory
  • func (c *ConsensusFactory) StartConsensus()

Types

type ConsensusFactory

type ConsensusFactory struct {
	user.Keys
	// contains filtered or unexported fields
}

ConsensusFactory is responsible for initializing the consensus processes with the proper parameters. It subscribes to the initialization topic and, upon reception of a message, will start all of the components related to consensus. It should also contain all the relevant information for the processes it intends to start up.

func New

func New(eventBus wire.EventBroker, rpcBus *wire.RPCBus, timerLength time.Duration,
	keys user.Keys) *ConsensusFactory

New returns an initialized ConsensusFactory.

func (*ConsensusFactory) StartConsensus

func (c *ConsensusFactory) StartConsensus()

StartConsensus will wait for a message to come in, and then proceed to start the consensus components.