Documentation
¶
Index ¶
- Variables
- func IsAckSignValidate(va *protos.ConfirmAckBlock) bool
- type BlockSource
- type Consensus
- type ConsensusAlgorithm
- type MsgType
- type Receiver
- func (r *Receiver) ReceiveConfirmAck(ack *protos.ConfirmAckBlock, msgFrom string)
- func (r *Receiver) ReceiveConfirmReq(blk []*types.StateBlock, msgFrom string)
- func (r *Receiver) ReceiveGenerateBlock(result process.ProcessResult, blk *types.StateBlock)
- func (r *Receiver) ReceivePublish(blk *types.StateBlock, msgFrom string)
- func (r *Receiver) ReceiveSyncBlock(blocks types.StateBlockList)
Constants ¶
This section is empty.
Variables ¶
View Source
var GlobalUncheckedBlockNum atomic.Uint64
Functions ¶
func IsAckSignValidate ¶
func IsAckSignValidate(va *protos.ConfirmAckBlock) bool
Types ¶
type BlockSource ¶ added in v1.2.3
type BlockSource struct { Block *types.StateBlock BlockFrom types.SynchronizedKind Type MsgType Para interface{} }
type Consensus ¶ added in v1.2.3
type Consensus struct {
// contains filtered or unexported fields
}
func NewConsensus ¶ added in v1.2.3
func NewConsensus(ca ConsensusAlgorithm, cfgFile string) *Consensus
type ConsensusAlgorithm ¶ added in v1.2.3
type ConsensusAlgorithm interface { Init() Start() Stop() ProcessMsg(bs *BlockSource) }
type Receiver ¶ added in v1.2.3
type Receiver struct {
// contains filtered or unexported fields
}
func NewReceiver ¶ added in v1.2.3
func (*Receiver) ReceiveConfirmAck ¶ added in v1.2.3
func (r *Receiver) ReceiveConfirmAck(ack *protos.ConfirmAckBlock, msgFrom string)
func (*Receiver) ReceiveConfirmReq ¶ added in v1.2.3
func (r *Receiver) ReceiveConfirmReq(blk []*types.StateBlock, msgFrom string)
func (*Receiver) ReceiveGenerateBlock ¶ added in v1.2.3
func (r *Receiver) ReceiveGenerateBlock(result process.ProcessResult, blk *types.StateBlock)
func (*Receiver) ReceivePublish ¶ added in v1.2.3
func (r *Receiver) ReceivePublish(blk *types.StateBlock, msgFrom string)
func (*Receiver) ReceiveSyncBlock ¶ added in v1.2.3
func (r *Receiver) ReceiveSyncBlock(blocks types.StateBlockList)
Click to show internal directories.
Click to hide internal directories.