leanhelixconsensus

Documentation

Index

• Constants
• Variables
• func CalcInstanceId(networkType protocol.SignerNetworkType, id primitives.VirtualChainId) lhprimitives.InstanceId
• func CreateResultsBlockProof(blockPair *protocol.BlockPairContainer, blockProof []byte) *protocol.ResultsBlockProof
• func CreateTransactionBlockProof(blockPair *protocol.BlockPairContainer, blockProof []byte) *protocol.TransactionsBlockProof
• func ExtractBlockProof(blockPair *protocol.BlockPairContainer) (primitives.LeanHelixBlockProof, error)
• func FromLeanHelixBlock(lhBlock lh.Block) *protocol.BlockPairContainer
• func NewBlockProvider(logger log.BasicLogger, blockStorage services.BlockStorage, ...) *blockProvider
• func NewCommunication(logger log.BasicLogger, gossip gossiptopics.LeanHelix) *communication
• func NewExponentialBackoffElectionTrigger(logger log.BasicLogger, minTimeout time.Duration, ...) lh.ElectionTrigger
• func NewKeyManager(logger log.BasicLogger, privateKey primitives.EcdsaSecp256K1PrivateKey) *keyManager
• func NewLeanHelixConsensusAlgo(parentContext context.Context, gossip gossiptopics.LeanHelix, ...) services.ConsensusAlgoLeanHelix
• func NewLoggerWrapper(log log.BasicLogger, showDebug bool) *loggerWrapper
• func NewMembership(logger log.BasicLogger, memberId primitives.NodeAddress, ...) *membership
• func ToLeanHelixBlock(blockPair *protocol.BlockPairContainer) lh.Block
• type BlockPairWrapper
  • func (b *BlockPairWrapper) Height() lhprimitives.BlockHeight

Constants

const LH_PREFIX = "=LH= "

Variables

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

var TIMEOUT_EXP_BASE = float64(2.0) // Modifying this value from 2.0 will affect its unit tests which are time-based

Functions

func CalcInstanceId

func CalcInstanceId(networkType protocol.SignerNetworkType, id primitives.VirtualChainId) lhprimitives.InstanceId

func CreateResultsBlockProof

func CreateResultsBlockProof(blockPair *protocol.BlockPairContainer, blockProof []byte) *protocol.ResultsBlockProof

func CreateTransactionBlockProof

func CreateTransactionBlockProof(blockPair *protocol.BlockPairContainer, blockProof []byte) *protocol.TransactionsBlockProof

func ExtractBlockProof

func ExtractBlockProof(blockPair *protocol.BlockPairContainer) (primitives.LeanHelixBlockProof, error)

func FromLeanHelixBlock

func FromLeanHelixBlock(lhBlock lh.Block) *protocol.BlockPairContainer

func NewBlockProvider

func NewBlockProvider(
	logger log.BasicLogger,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext) *blockProvider

func NewCommunication

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

func NewExponentialBackoffElectionTrigger

func NewExponentialBackoffElectionTrigger(logger log.BasicLogger, minTimeout time.Duration, onElectionCB func(m lhmetrics.ElectionMetrics)) lh.ElectionTrigger

func NewKeyManager

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

func NewLeanHelixConsensusAlgo

func NewLeanHelixConsensusAlgo(
	parentContext context.Context,
	gossip gossiptopics.LeanHelix,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext,
	parentLogger log.BasicLogger,
	config config.LeanHelixConsensusConfig,
	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, maxCommitteeSize uint32) *membership

func ToLeanHelixBlock

func ToLeanHelixBlock(blockPair *protocol.BlockPairContainer) lh.Block

Types

type BlockPairWrapper

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

func (*BlockPairWrapper) Height

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