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.Logger, blockStorage services.BlockStorage, ...) *blockProvider
• func NewCommunication(logger log.Logger, gossip gossiptopics.LeanHelix) *communication
• func NewKeyManager(logger log.Logger, signer signer.Signer) *keyManager
• func NewLoggerWrapper(log log.Logger, showDebug bool) *loggerWrapper
• func NewMembership(logger log.Logger, memberId primitives.NodeAddress, ...) *membership
• func ToLeanHelixBlock(blockPair *protocol.BlockPairContainer) lh.Block
• type BlockPairWrapper
  • func (b *BlockPairWrapper) Height() lhprimitives.BlockHeight
  • func (b *BlockPairWrapper) ReferenceTime() lhprimitives.TimestampSeconds
• type Service
  • func NewLeanHelixConsensusAlgo(parentContext context.Context, gossip gossiptopics.LeanHelix, ...) *Service
  • func (s *Service) HandleBlockConsensus(ctx context.Context, input *handlers.HandleBlockConsensusInput) (*handlers.HandleBlockConsensusOutput, error)
  • func (s *Service) HandleLeanHelixMessage(ctx context.Context, input *gossiptopics.LeanHelixInput) (*gossiptopics.EmptyOutput, error)

Constants

const LH_PREFIX = "=LH= "

Variables

var ConsensusLogTag = log.String("flow", "consensus")

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

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.Logger,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext) *blockProvider

func NewCommunication

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

func NewKeyManager

func NewKeyManager(logger log.Logger, signer signer.Signer) *keyManager

func NewLoggerWrapper

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

func NewMembership

func NewMembership(logger log.Logger, 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

func (*BlockPairWrapper) ReferenceTime

func (b *BlockPairWrapper) ReferenceTime() lhprimitives.TimestampSeconds

type Service

type Service struct {
	govnr.TreeSupervisor
	// contains filtered or unexported fields
}

func NewLeanHelixConsensusAlgo

func NewLeanHelixConsensusAlgo(
	parentContext context.Context,
	gossip gossiptopics.LeanHelix,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext,
	signer signer.Signer,
	parentLogger log.Logger,
	config config.LeanHelixConsensusConfig,
	metricFactory metric.Factory,

) *Service

func (*Service) HandleBlockConsensus

func (s *Service) HandleBlockConsensus(ctx context.Context, input *handlers.HandleBlockConsensusInput) (*handlers.HandleBlockConsensusOutput, error)

func (*Service) HandleLeanHelixMessage

func (s *Service) HandleLeanHelixMessage(ctx context.Context, input *gossiptopics.LeanHelixInput) (*gossiptopics.EmptyOutput, error)