msgcache

type CachedMsgTransmitter struct {
	sync.RWMutex // 读写锁，用户后续有查询需求
	// contains filtered or unexported fields
}

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

type Handler interface {
	HandleProposal(*PendingProposal)
}

type MissingProposal struct {
	BlockHeight uint64
	View        uint64
	BlockId     string
}

type MsgTransmitter interface {
	// HandleProposal 处理提案数据
	HandleProposal(proposal *PendingProposal) error

	// Stop 释放资源
	Stop() error

	// Start 启动服务
	Start()

	SetForest(forester forest.Forester)
}

type PendingProposal struct {
	// FromOtherNodes marks that the proposal is from other nodes' responses or not
	FromOtherNodes bool

	// Proposal is the raw proposal
	Proposal *maxbft.ProposalData

	// Sender indicates witch node the proposal is from
	Sender string

	// Qc is the qc of the proposal
	Qc *maxbft.QuorumCert
}