leanhelixconsensus

Documentation

Index

• Constants
• Variables
• func CalculateNewBlockTimestamp(prevBlockTimestamp primitives.TimestampNano, now primitives.TimestampNano) primitives.TimestampNano
• func NewBlockProvider(logger log.BasicLogger, blockStorage services.BlockStorage, ...) *blockProvider
• func NewCommunication(logger log.BasicLogger, gossip gossiptopics.LeanHelix) *communication
• func NewKeyManager(logger log.BasicLogger, privateKey primitives.EcdsaSecp256K1PrivateKey) *keyManager
• func NewLeanHelixConsensusAlgo(ctx context.Context, gossip gossiptopics.LeanHelix, ...) services.ConsensusAlgoLeanHelix
• func NewLoggerWrapper(log log.BasicLogger, showDebug bool) *loggerWrapper
• func NewMembership(logger log.BasicLogger, memberId primitives.NodeAddress, ...) *membership
• type BlockPairWrapper
  • func ToBlockPairWrapper(blockPair *protocol.BlockPairContainer) *BlockPairWrapper
  • func (b *BlockPairWrapper) Height() lhprimitives.BlockHeight
• type Config

Constants

const LH_PREFIX = "<LH> "

Variables

var LogTag = log.Service("consensus-algo-lean-helix")

Functions

func CalculateNewBlockTimestamp

func CalculateNewBlockTimestamp(prevBlockTimestamp primitives.TimestampNano, now primitives.TimestampNano) primitives.TimestampNano

func NewBlockProvider

func NewBlockProvider(
	logger log.BasicLogger,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext,
	nodeAddress primitives.NodeAddress,
	nodePrivateKey primitives.EcdsaSecp256K1PrivateKey) *blockProvider

func NewCommunication

func NewCommunication(logger log.BasicLogger, gossip gossiptopics.LeanHelix) *communication

func NewKeyManager

func NewKeyManager(logger log.BasicLogger, privateKey primitives.EcdsaSecp256K1PrivateKey) *keyManager

func NewLeanHelixConsensusAlgo

func NewLeanHelixConsensusAlgo(
	ctx context.Context,
	gossip gossiptopics.LeanHelix,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext,
	parentLogger log.BasicLogger,
	config Config,
	metricFactory metric.Factory,

) services.ConsensusAlgoLeanHelix

func NewLoggerWrapper

func NewLoggerWrapper(log log.BasicLogger, showDebug bool) *loggerWrapper

func NewMembership

func NewMembership(logger log.BasicLogger, memberId primitives.NodeAddress, consensusContext services.ConsensusContext) *membership

Types

type BlockPairWrapper

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

func ToBlockPairWrapper

func ToBlockPairWrapper(blockPair *protocol.BlockPairContainer) *BlockPairWrapper

func (*BlockPairWrapper) Height

func (b *BlockPairWrapper) Height() lhprimitives.BlockHeight

type Config

type Config interface {
	NodeAddress() primitives.NodeAddress
	NodePrivateKey() primitives.EcdsaSecp256K1PrivateKey
	FederationNodes(asOfBlock uint64) map[string]config.FederationNode
	LeanHelixConsensusRoundTimeoutInterval() time.Duration
	ActiveConsensusAlgo() consensus.ConsensusAlgoType
}