accuser

Documentation

Index

• Variables
• type Accuser
  • func NewAccuser(nodeInfo cluster.NodeInfo, signer *crypto.SecureSigner, ...) *Accuser
  • func (ac *Accuser) OnHeatbeatFail(msg struct{})
  • func (ac *Accuser) OnHeatbeatSuc(msg *pb.HeatbeatMsg)
  • func (ac *Accuser) OnTermChange(newTerm int64)
  • func (ac *Accuser) Run(ctx context.Context)
  • func (ac *Accuser) TriggerByBlockStore(term int64)
  • func (ac *Accuser) TriggerByTxStore(term int64)

Variables

var (
	AccuseInterval int64 //accuse 间隔 单位s
)

Types

type Accuser

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

Accuser 发起accuse的结构体

func NewAccuser

func NewAccuser(nodeInfo cluster.NodeInfo, signer *crypto.SecureSigner,
	pm *cluster.PeerManager) *Accuser

NewAccuser 新建一个Accuser对象并返回

func (*Accuser) OnHeatbeatFail

func (ac *Accuser) OnHeatbeatFail(msg struct{})

OnHeatbeatFail receive heatbeat from leader check fail

func (*Accuser) OnHeatbeatSuc

func (ac *Accuser) OnHeatbeatSuc(msg *pb.HeatbeatMsg)

OnHeatbeatSuc receive heatbeat from leader

func (*Accuser) OnTermChange

func (ac *Accuser) OnTermChange(newTerm int64)

OnTermChange term自增之后的回调处理

func (*Accuser) Run

func (ac *Accuser) Run(ctx context.Context)

Run Accuser循环处理accuse并做区块间隔检测

func (*Accuser) TriggerByBlockStore

func (ac *Accuser) TriggerByBlockStore(term int64)

TriggerByBlockStore blockstore发起accuse

func (*Accuser) TriggerByTxStore

func (ac *Accuser) TriggerByTxStore(term int64)

TriggerByTxStore txstore发起accuse