mempool

type Config struct {
	ID uint64

	BatchSize      uint64
	PoolSize       uint64
	TxSliceSize    uint64
	BatchTick      time.Duration
	FetchTimeout   time.Duration
	TxSliceTimeout time.Duration

	PeerMgr            peermgr.PeerManager
	GetTransactionFunc func(hash *types.Hash) (*pb.Transaction, error)
	ChainHeight        uint64
	Logger             logrus.FieldLogger
}

type FetchTxnRequest struct {
	ReplicaId       uint64            `protobuf:"varint,1,opt,name=replicaId,proto3" json:"replicaId,omitempty"`
	Height          uint64            `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	MissingTxHashes map[uint64]string `` /* 197-byte string literal not displayed */
}

type FetchTxnResponse struct {
	ReplicaId      uint64                     `protobuf:"varint,1,opt,name=replicaId,proto3" json:"replicaId,omitempty"`
	Height         uint64                     `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	MissingTxnList map[uint64]*pb.Transaction `` /* 194-byte string literal not displayed */
}

type LocalMissingTxnEvent struct {
	Height             uint64
	MissingTxnHashList map[uint64]string
	WaitC              chan bool
}

type MemPool interface {
	// Start starts mempool service.
	Start() error

	// Stop stops mempool service.
	Stop()

	// RecvTransaction receives transaction from API.
	RecvTransaction(tx *pb.Transaction) error

	// RecvForwardTxs receives transactions from other vp nodes.
	RecvForwardTxs(txSlice *TxSlice)

	// UpdateLeader updates the leader node info when the consensus module updates the leader status.
	UpdateLeader(uint64)

	// FetchTxn sends the fetching missing transactions request.
	FetchTxn(lostTxnEvent *LocalMissingTxnEvent)

	// RecvFetchTxnRequest receives the fetching missing transactions request,
	// and load the related transactions from its mempool or storage.
	RecvFetchTxnRequest(fetchTxnRequest *FetchTxnRequest)

	// RecvFetchTxnResponse receives the fetching missing transactions response,
	// and posts to consensus module.
	RecvFetchTxnResponse(fetchTxnResponse *FetchTxnResponse)

	// GetChainHeight gets the sequence number of block.
	GetChainHeight() uint64

	// IncreaseChainHeight increases the sequence number of block.
	IncreaseChainHeight()

	// GetBlock return the transactions list by given ready.
	// If the corresponding transaction cannot be found, a list of missing transactions will be returned.
	GetBlockByHashList(ready *raftproto.Ready) (map[uint64]string, []*pb.Transaction)

	// Remove removes the committed transactions from mempool
	CommitTransactions(ready *raftproto.Ready)

	// GetPendingNonceByAccount will return the latest pending nonce of a given account
	GetPendingNonceByAccount(account string) uint64
}

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

type TxSlice struct {
	TxList []*pb.Transaction `protobuf:"bytes,1,rep,name=TxList,proto3" json:"TxList,omitempty"`
}