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,
	peerSignatureHandler crypto.PeerSignatureHandler,
	headersSubscriber consensus.HeadersPoolSubscriber,
	interceptorsContainer process.InterceptorsContainer,
	alarmScheduler core.TimersScheduler,
	keysHandler consensus.KeysHandler,
) (consensus.BroadcastMessenger, error)

GetBroadcastMessenger returns a consensus service depending on the given parameter

func GetConsensusCoreFactory

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

GetConsensusCoreFactory returns a consensus service depending on the given parameter

func GetSubroundsFactory

func GetSubroundsFactory(
	consensusDataContainer spos.ConsensusCoreHandler,
	consensusState *spos.ConsensusState,
	worker spos.WorkerHandler,
	consensusType string,
	appStatusHandler core.AppStatusHandler,
	outportHandler outport.OutportHandler,
	sentSignatureTracker spos.SentSignaturesTracker,
	chainID []byte,
	currentPid core.PeerID,
) (spos.SubroundsFactory, error)

GetSubroundsFactory returns a subrounds factory depending on the given parameter