Versions in this module Expand all Collapse all v6 v6.4.0 May 18, 2020 Changes in this version + func Reg(name string, create Create) + type AccountTxIndex struct + func NewAccountTxIndex(maxperaccount int) *AccountTxIndex + func (cache *AccountTxIndex) CanPush(tx *types.Transaction) bool + func (cache *AccountTxIndex) GetAccTxs(addrs *types.ReqAddrs) *types.TransactionDetails + func (cache *AccountTxIndex) Push(tx *types.Transaction) error + func (cache *AccountTxIndex) Remove(tx *types.Transaction) + func (cache *AccountTxIndex) TxNumOfAccount(addr string) int + type Create func(cfg *types.Mempool, sub []byte) queue.Module + func Load(name string) (create Create, err error) + type Item struct + EnterTime int64 + Priority int64 + Value *types.Transaction + type LastTxCache struct + func NewLastTxCache(size int) *LastTxCache + func (cache *LastTxCache) GetLatestTx() (txs []*types.Transaction) + func (cache *LastTxCache) Push(tx *types.Transaction) + func (cache *LastTxCache) Remove(tx *types.Transaction) + type Mempool struct + func NewMempool(cfg *types.Mempool) *Mempool + func (mem *Mempool) CheckExpireValid(msg *queue.Message) (bool, error) + func (mem *Mempool) Close() + func (mem *Mempool) GetAccTxs(addrs *types.ReqAddrs) *types.TransactionDetails + func (mem *Mempool) GetHeader() *types.Header + func (mem *Mempool) GetLastHeader() (interface{}, error) + func (mem *Mempool) GetLatestTx() []*types.Transaction + func (mem *Mempool) GetProperFeeRate(req *types.ReqProperFee) int64 + func (mem *Mempool) GetTotalCacheBytes() int64 + func (mem *Mempool) Height() int64 + func (mem *Mempool) PushTx(tx *types.Transaction) error + func (mem *Mempool) RemoveTxs(hashList *types.TxHashList) error + func (mem *Mempool) RemoveTxsOfBlock(block *types.Block) bool + func (mem *Mempool) SetMinFee(fee int64) + func (mem *Mempool) SetQueueCache(qcache QueueCache) + func (mem *Mempool) SetQueueClient(client queue.Client) + func (mem *Mempool) Size() int + func (mem *Mempool) TxNumOfAccount(addr string) int64 + func (mem *Mempool) Wait() + type QueueCache interface + Exist func(hash string) bool + GetCacheBytes func() int64 + GetItem func(hash string) (*Item, error) + GetProperFee func() int64 + Push func(tx *Item) error + Remove func(hash string) error + Size func() int + Walk func(count int, cb func(tx *Item) bool) + type SHashTxCache struct + func NewSHashTxCache(size int) *SHashTxCache + func (cache *SHashTxCache) Exist(shash string) bool + func (cache *SHashTxCache) GetSHashTxCache(sHash string) *types.Transaction + func (cache *SHashTxCache) Push(tx *types.Transaction) + func (cache *SHashTxCache) Remove(tx *types.Transaction) + type SimpleQueue struct + func NewSimpleQueue(subConfig SubConfig) *SimpleQueue + func (cache *SimpleQueue) Exist(hash string) bool + func (cache *SimpleQueue) GetCacheBytes() int64 + func (cache *SimpleQueue) GetItem(hash string) (*Item, error) + func (cache *SimpleQueue) GetProperFee() int64 + func (cache *SimpleQueue) Push(tx *Item) error + func (cache *SimpleQueue) Remove(hash string) error + func (cache *SimpleQueue) Size() int + func (cache *SimpleQueue) Walk(count int, cb func(value *Item) bool) + type SubConfig struct + PoolCacheSize int64 + ProperFee int64 Other modules containing this package github.com/33cn/chain33