consensus

Documentation

Index

• type Consensus
  • func (this *Consensus) ChooseConsensusPeer(dataBlock *entity.DataBlock) []string
  • func (this *Consensus) CreateConsensusLog(chainMessage *entity2.ChainMessage, dataBlock *entity.DataBlock, ...) *entity.ConsensusLog
  • func (this *Consensus) GetConsensusLog(chainMessage *entity2.ChainMessage) (*entity.ConsensusLog, error)
  • func (this *Consensus) GetDataBlock(chainMessage *entity2.ChainMessage) (*entity.DataBlock, error)
  • func (this *Consensus) GetDataBlockCacheKey(blockId string, sliceNumber uint64) string
  • func (this *Consensus) GetLogCacheKey(log *entity.ConsensusLog) string
  • func (this *Consensus) NearestConsensusPeer(key string, createTimestamp uint64) []string

Types

type Consensus

type Consensus struct {
	MemCache *cache.Cache
}

func (*Consensus) ChooseConsensusPeer

func (this *Consensus) ChooseConsensusPeer(dataBlock *entity.DataBlock) []string

* 主节点挑选副节点

func (*Consensus) CreateConsensusLog

func (this *Consensus) CreateConsensusLog(chainMessage *entity2.ChainMessage, dataBlock *entity.DataBlock, myselfPeer *entity1.MyselfPeer, status string) *entity.ConsensusLog

* 创建新的ConsensusLog，存入数据库中

func (*Consensus) GetConsensusLog

func (this *Consensus) GetConsensusLog(chainMessage *entity2.ChainMessage) (*entity.ConsensusLog, error)

* 从消息中提取ConsensusLog

func (*Consensus) GetDataBlock

func (this *Consensus) GetDataBlock(chainMessage *entity2.ChainMessage) (*entity.DataBlock, error)

* 从消息中提取datablock

func (*Consensus) GetDataBlockCacheKey

func (this *Consensus) GetDataBlockCacheKey(blockId string, sliceNumber uint64) string

* 获取datablock缓存的key

func (*Consensus) GetLogCacheKey

func (this *Consensus) GetLogCacheKey(log *entity.ConsensusLog) string

* 获取日志缓存的key

func (*Consensus) NearestConsensusPeer

func (this *Consensus) NearestConsensusPeer(key string, createTimestamp uint64) []string

* 获取最近的peer集合