leanhelixterm

Documentation

Index

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

Constants

const CallCommitteeContractInterval = 200 * time.Millisecond

Functions

func CommitsToProof

func CommitsToProof(log logger.LHLogger, 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(message interfaces.ConsensusMessage) error

type LeanHelixTerm

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

func NewLeanHelixTerm

func NewLeanHelixTerm(ctx context.Context, logger 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(ppm *interfaces.PreprepareMessage)
	HandlePrepare(pm *interfaces.PrepareMessage)
	HandleViewChange(vcm *interfaces.ViewChangeMessage)
	HandleCommit(cm *interfaces.CommitMessage)
	HandleNewView(nvm *interfaces.NewViewMessage)
}