mempool

type ChainState struct {
	Height     uint64
	BlockHash  *types.Hash
	TxHashList []*types.Hash
}

type Config struct {
	ID                 uint64
	BatchSize          uint64
	PoolSize           uint64
	IsTimed            bool
	BlockTimeout       time.Duration
	RebroadcastTimeout time.Duration
	TxSliceSize        uint64
	TxSliceTimeout     time.Duration
	ChainHeight        uint64
	Logger             logrus.FieldLogger
	StoragePath        string // db for persist mem pool meta data
	GetAccountNonce    GetAccountNonceFunc
}

type External interface {

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

	GetPendingTransactions(max int) []pb.Transaction

	GetTransaction(hash *types.Hash) pb.Transaction

	// IsPoolFull check if memPool has exceeded the limited txSize.
	IsPoolFull() bool
}

type GetAccountNonceFunc func(address *types.Address) uint64

type MemPool interface {
	// ProcessTransactions process transaction from api and other vp nodes.
	ProcessTransactions(txs []pb.Transaction, isLeader, isLocal bool) *raftproto.RequestBatch

	// GenerateBlock generate a block
	GenerateBlock() *raftproto.RequestBatch

	// CommitTransactions Remove removes the committed transactions from mempool
	CommitTransactions(state *ChainState)

	// HasPendingRequest checks if there is non-batched tx(s) in mempool pool or not
	HasPendingRequest() bool

	SetBatchSeqNo(batchSeq uint64)

	GetTimeoutTransactions(rebroadcastDuration time.Duration) [][]pb.Transaction

	// RemoveAliveTimeoutTxs get the remained local txs in timeoutIndex and removeTxs in memPool by tolerance time.
	RemoveAliveTimeoutTxs(removeDuration time.Duration) uint64

	SubscribeTxEvent(chan<- pb.Transactions) event.Subscription

	External
}

type TxCache struct {
	TxSetC  chan *pb.Transactions
	RecvTxC chan pb.Transaction
	TxRespC chan *TxWithResp
	// contains filtered or unexported fields
}

type TxWithResp struct {
	Tx pb.Transaction
	Ch chan bool
}