committee

Documentation

Index

• type CommitteeModule
• type PbftCommitteeModule
  • func NewPbftCommitteeModule(Ip_nodeTable map[uint64]string, Ss *signal.StopSignal, ...) *PbftCommitteeModule
  • func (rthm *PbftCommitteeModule) HandleBlockInfo(b *pbft.BlockInfoMsg)
  • func (rthm *PbftCommitteeModule) MsgSendingControl()

Types

type CommitteeModule

type CommitteeModule interface {
	HandleBlockInfo(*pbft.BlockInfoMsg)
	MsgSendingControl()
}

type PbftCommitteeModule

type PbftCommitteeModule struct {
	Ss *signal.StopSignal
	// contains filtered or unexported fields
}

func NewPbftCommitteeModule

func NewPbftCommitteeModule(Ip_nodeTable map[uint64]string, Ss *signal.StopSignal, slog *supervisor_log.SupervisorLog, csvFilePath string, dataNum, batchNum int) *PbftCommitteeModule

func (*PbftCommitteeModule) HandleBlockInfo

func (rthm *PbftCommitteeModule) HandleBlockInfo(b *pbft.BlockInfoMsg)

func (*PbftCommitteeModule) MsgSendingControl

func (rthm *PbftCommitteeModule) MsgSendingControl()

MsgSendingControl Sup开启的时候同步地调一次。 把tx读出来然后用txSending发出去。