leanhelixterm

Documentation

Index

• func CommitsToProof(log logger.LHLogger, blockHeight primitives.BlockHeight, ...) termincommittee.OnInCommitteeCommitCallback
• type ConsensusMessagesFilter
  • func NewConsensusMessagesFilter(handler TermMessagesHandler, keyManager interfaces.KeyManager, ...) *ConsensusMessagesFilter
  • func (mp *ConsensusMessagesFilter) HandleConsensusMessage(ctx context.Context, message interfaces.ConsensusMessage) error
• type LeanHelixTerm
  • func NewLeanHelixTerm(ctx context.Context, log logger.LHLogger, config *interfaces.Config, ...) *LeanHelixTerm
  • func (lht *LeanHelixTerm) Dispose()
• type TermMessagesHandler

Functions

func CommitsToProof

func CommitsToProof(log logger.LHLogger, blockHeight primitives.BlockHeight, myMemberId primitives.MemberId, keyManager interfaces.KeyManager, onCommit interfaces.OnCommitCallback) termincommittee.OnInCommitteeCommitCallback

Types

type ConsensusMessagesFilter

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

func NewConsensusMessagesFilter

func NewConsensusMessagesFilter(handler TermMessagesHandler, keyManager interfaces.KeyManager, randomSeed uint64) *ConsensusMessagesFilter

func (*ConsensusMessagesFilter) HandleConsensusMessage

func (mp *ConsensusMessagesFilter) HandleConsensusMessage(ctx context.Context, message interfaces.ConsensusMessage) error

type LeanHelixTerm

type LeanHelixTerm struct {
	*ConsensusMessagesFilter
	// contains filtered or unexported fields
}

func NewLeanHelixTerm

func NewLeanHelixTerm(ctx context.Context, log logger.LHLogger, config *interfaces.Config, state *state.State, electionTrigger interfaces.ElectionScheduler, onCommit interfaces.OnCommitCallback, prevBlock interfaces.Block, prevBlockProofBytes []byte, canBeFirstLeader bool) *LeanHelixTerm

func (*LeanHelixTerm) Dispose

func (lht *LeanHelixTerm) Dispose()

type TermMessagesHandler

type TermMessagesHandler interface {
	HandlePrePrepare(ctx context.Context, ppm *interfaces.PreprepareMessage)
	HandlePrepare(ctx context.Context, pm *interfaces.PrepareMessage)
	HandleViewChange(ctx context.Context, vcm *interfaces.ViewChangeMessage)
	HandleCommit(ctx context.Context, cm *interfaces.CommitMessage)
	HandleNewView(ctx context.Context, nvm *interfaces.NewViewMessage)
}