sposFactory

Documentation

Index

• Variables
• func GetBroadcastMessenger(marshalizer marshal.Marshalizer, hasher hashing.Hasher, ...) (consensus.BroadcastMessenger, error)
• func GetConsensusCoreFactory(consensusType string) (spos.ConsensusService, error)
• func GetSubroundsFactory(consensusDataContainer spos.ConsensusCoreHandler, ...) (spos.SubroundsFactory, error)

Variables

var ErrInvalidConsensusType = errors.New("invalid consensus type")

ErrInvalidConsensusType signals that an invalid consensus type has been provided

var ErrInvalidShardId = errors.New("invalid shard id")

ErrInvalidShardId signals that an invalid shard id has been provided

Functions

func GetBroadcastMessenger

func GetBroadcastMessenger(
	marshalizer marshal.Marshalizer,
	hasher hashing.Hasher,
	messenger consensus.P2PMessenger,
	shardCoordinator sharding.Coordinator,
	privateKey crypto.PrivateKey,
	peerSignatureHandler crypto.PeerSignatureHandler,
	headersSubscriber consensus.HeadersPoolSubscriber,
	interceptorsContainer process.InterceptorsContainer,
) (consensus.BroadcastMessenger, error)

GetBroadcastMessenger returns a consensus service depending of the given parameter

func GetConsensusCoreFactory

func GetConsensusCoreFactory(consensusType string) (spos.ConsensusService, error)

GetConsensusCoreFactory returns a consensus service depending of the given parameter

func GetSubroundsFactory

func GetSubroundsFactory(
	consensusDataContainer spos.ConsensusCoreHandler,
	consensusState *spos.ConsensusState,
	worker spos.WorkerHandler,
	consensusType string,
	appStatusHandler core.AppStatusHandler,
	indexer spos.ConsensusDataIndexer,
	chainID []byte,
	currentPid core.PeerID,
) (spos.SubroundsFactory, error)

GetSubroundsFactory returns a subrounds factory depending of the given parameter