maxbftmode

Documentation

Index

• Constants
• Variables
• type CoreEngine
  • func NewCoreEngine(cf *config.CoreEngineConfig) (*CoreEngine, error)
  • func (c *CoreEngine) GetBlockCommitter() protocol.BlockCommitter
  • func (c *CoreEngine) GetBlockProposer() protocol.BlockProposer
  • func (c *CoreEngine) GetBlockVerifier() protocol.BlockVerifier
  • func (c *CoreEngine) GetMaxbftHelper() protocol.MaxbftHelper
  • func (c *CoreEngine) OnMessage(message *msgbus.Message)
  • func (c *CoreEngine) OnQuit()
  • func (c *CoreEngine) Start()
  • func (c *CoreEngine) Stop()

Constants

const ConsensusTypeMAXBFT = "MAXBFT"

Variables

var NilTMAXBFTProvider provider.CoreProvider = (*maxbftProvider)(nil)

Types

type CoreEngine

type CoreEngine struct {
	BlockVerifier  protocol.BlockVerifier  // block verifier, to verify block that proposer generated
	BlockCommitter protocol.BlockCommitter // block committer, to commit block to store after consensus

	MaxbftHelper protocol.MaxbftHelper
	// contains filtered or unexported fields
}

CoreEngine is a block handle engine. One core engine for one chain. nolint: unused, structcheck

func NewCoreEngine

func NewCoreEngine(cf *config.CoreEngineConfig) (*CoreEngine, error)

NewCoreEngine new a core engine.

func (*CoreEngine) GetBlockCommitter

func (c *CoreEngine) GetBlockCommitter() protocol.BlockCommitter

func (*CoreEngine) GetBlockProposer

func (c *CoreEngine) GetBlockProposer() protocol.BlockProposer

func (*CoreEngine) GetBlockVerifier

func (c *CoreEngine) GetBlockVerifier() protocol.BlockVerifier

func (*CoreEngine) GetMaxbftHelper

func (c *CoreEngine) GetMaxbftHelper() protocol.MaxbftHelper

func (*CoreEngine) OnMessage

func (c *CoreEngine) OnMessage(message *msgbus.Message)

OnMessage consume a message from message bus

func (*CoreEngine) OnQuit

func (c *CoreEngine) OnQuit()

OnQuit called when quit subsribe message from message bus

func (*CoreEngine) Start

func (c *CoreEngine) Start()

Start, initialize core engine

func (*CoreEngine) Stop

func (c *CoreEngine) Stop()

Stop, stop core engine