consensus

Documentation

Index

• Variables
• func IsAckSignValidate(va *protos.ConfirmAckBlock) bool
• type BlockSource
• type Consensus
  • func NewConsensus(ca ConsensusAlgorithm, cfgFile string) *Consensus
  • func (c *Consensus) Init()
  • func (c *Consensus) RPC(kind uint, in, out interface{})
  • func (c *Consensus) Start()
  • func (c *Consensus) Stop()
• type ConsensusAlgorithm
• type MsgType
• type Receiver
  • func NewReceiver(eb event.EventBus) *Receiver
  • func (r *Receiver) ReceiveConfirmAck(ack *protos.ConfirmAckBlock, msgFrom string)
  • func (r *Receiver) ReceiveConfirmReq(blk []*types.StateBlock, msgFrom string)
  • func (r *Receiver) ReceiveGenerateBlock(blk *types.StateBlock)
  • func (r *Receiver) ReceivePublish(blk *types.StateBlock, msgFrom string)
  • func (r *Receiver) ReceiveSyncBlock(blocks types.StateBlockList)

Variables

var GlobalUncheckedBlockNum atomic.Uint64

Functions

func IsAckSignValidate

func IsAckSignValidate(va *protos.ConfirmAckBlock) bool

Types

type BlockSource

type BlockSource struct {
	Block     *types.StateBlock
	BlockFrom types.SynchronizedKind
	Type      MsgType
	Para      interface{}
}

type Consensus

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

func NewConsensus

func NewConsensus(ca ConsensusAlgorithm, cfgFile string) *Consensus

func (*Consensus) Init

func (c *Consensus) Init()

func (*Consensus) RPC

func (c *Consensus) RPC(kind uint, in, out interface{})

func (*Consensus) Start

func (c *Consensus) Start()

func (*Consensus) Stop

func (c *Consensus) Stop()

type ConsensusAlgorithm

type ConsensusAlgorithm interface {
	Init()
	Start()
	Stop()
	ProcessMsg(bs *BlockSource)
	RPC(kind uint, in, out interface{})
}

type MsgType

type MsgType byte

const (
	MsgPublishReq MsgType = iota
	MsgConfirmReq
	MsgConfirmAck
	MsgSync
	MsgGenerateBlock
)

type Receiver

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

func NewReceiver

func NewReceiver(eb event.EventBus) *Receiver

func (*Receiver) ReceiveConfirmAck

func (r *Receiver) ReceiveConfirmAck(ack *protos.ConfirmAckBlock, msgFrom string)

func (*Receiver) ReceiveConfirmReq

func (r *Receiver) ReceiveConfirmReq(blk []*types.StateBlock, msgFrom string)

func (*Receiver) ReceiveGenerateBlock

func (r *Receiver) ReceiveGenerateBlock(blk *types.StateBlock)

func (*Receiver) ReceivePublish

func (r *Receiver) ReceivePublish(blk *types.StateBlock, msgFrom string)

func (*Receiver) ReceiveSyncBlock

func (r *Receiver) ReceiveSyncBlock(blocks types.StateBlockList)