Help us shape the future of Go! Take the 2026 Go Developer Survey

mempool

package
v1.72.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 23, 2026 License: BSD-3-Clause Imports: 18 Imported by: 29

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Reg 

func Reg(name string, create Create)

Reg 注册一个create

Types

type AccountTxIndex 

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

AccountTxIndex 账户和交易索引

func NewAccountTxIndex 

func NewAccountTxIndex(maxperaccount int) *AccountTxIndex

NewAccountTxIndex 创建一个新的索引

func (*AccountTxIndex) CanPush 

func (cache *AccountTxIndex) CanPush(tx *types.Transaction) bool

CanPush 是否可以push 进 account index

func (*AccountTxIndex) GetAccTxs 

func (cache *AccountTxIndex) GetAccTxs(addrs *types.ReqAddrs) *types.TransactionDetails

GetAccTxs 用来获取对应账户地址（列表）中的全部交易详细信息

func (*AccountTxIndex) Push 

func (cache *AccountTxIndex) Push(tx *types.Transaction, txHash string) error

Push push transaction to AccountTxIndex

func (*AccountTxIndex) Remove 

func (cache *AccountTxIndex) Remove(tx *types.Transaction, txHash string)

Remove 根据交易哈希删除对应账户的对应交易

func (*AccountTxIndex) TxNumOfAccount 

func (cache *AccountTxIndex) TxNumOfAccount(addr string) int

TxNumOfAccount 返回账户在Mempool中交易数量

type Create 

type Create func(cfg *types.Mempool, sub []byte) queue.Module

Create 创建一个mempool模块

func Load 

func Load(name string) (create Create, err error)

Load 加载一个create

type Item 

type Item struct {
	Value     *types.Transaction
	Priority  int64
	EnterTime int64
}

Item 为Mempool中包装交易的数据结构

type LastTxCache 

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

LastTxCache 最后放入cache的交易

func NewLastTxCache 

func NewLastTxCache(size int) *LastTxCache

NewLastTxCache 创建最后交易的cache

func (*LastTxCache) GetLatestTx 

func (cache *LastTxCache) GetLatestTx() (txs []*types.Transaction)

GetLatestTx 返回最新十条加入到txCache的交易

func (*LastTxCache) Push 

func (cache *LastTxCache) Push(tx *types.Transaction, txHash string)

Push tx into LastTxCache

func (*LastTxCache) Remove 

func (cache *LastTxCache) Remove(txHash string)

Remove remove tx of last cache

type Mempool 

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

Mempool mempool 基础类

func NewMempool 

func NewMempool(cfg *types.Mempool) *Mempool

NewMempool 新建mempool 实例

func (*Mempool) CheckExpireValid 

func (mem *Mempool) CheckExpireValid(msg *queue.Message) (bool, error)

CheckExpireValid 检查交易过期有效性，过期返回false，未过期返回true

func (*Mempool) Close 

func (mem *Mempool) Close()

Close 关闭mempool

func (*Mempool) GetAccTxs 

func (mem *Mempool) GetAccTxs(addrs *types.ReqAddrs) *types.TransactionDetails

GetAccTxs 用来获取对应账户地址（列表）中的全部交易详细信息

func (*Mempool) GetHeader 

func (mem *Mempool) GetHeader() *types.Header

GetHeader 获取header, 只需要读锁

func (*Mempool) GetLastHeader 

func (mem *Mempool) GetLastHeader() (interface{}, error)

GetLastHeader 获取LastHeader的height和blockTime

func (*Mempool) GetLatestTx 

func (mem *Mempool) GetLatestTx() []*types.Transaction

GetLatestTx 返回最新十条加入到mempool的交易

func (*Mempool) GetProperFeeRate 

func (mem *Mempool) GetProperFeeRate(req *types.ReqProperFee) int64

GetProperFeeRate 获取合适的手续费率

func (*Mempool) GetTotalCacheBytes 

func (mem *Mempool) GetTotalCacheBytes() int64

GetTotalCacheBytes 获取缓存交易的总占用空间

func (*Mempool) Height 

func (mem *Mempool) Height() int64

Height 获取区块高度

func (*Mempool) PushTx 

func (mem *Mempool) PushTx(tx *types.Transaction) error

PushTx 将交易推入mempool，并返回结果（error）

func (*Mempool) RemoveTxs 

func (mem *Mempool) RemoveTxs(hashList *types.TxHashList) error

RemoveTxs 从mempool中删除给定Hash的txs

func (*Mempool) RemoveTxsOfBlock 

func (mem *Mempool) RemoveTxsOfBlock(block *types.Block) bool

RemoveTxsOfBlock 移除mempool中已被Blockchain打包的tx

func (*Mempool) SetMinFee 

func (mem *Mempool) SetMinFee(fee int64)

SetMinFee 设置最小交易费用

func (*Mempool) SetQueueCache 

func (mem *Mempool) SetQueueCache(qcache QueueCache)

SetQueueCache 设置排队策略

func (*Mempool) SetQueueClient 

func (mem *Mempool) SetQueueClient(cli queue.Client)

SetQueueClient 初始化mempool模块

func (*Mempool) Size 

func (mem *Mempool) Size() int

Size 返回mempool中txCache大小

func (*Mempool) TxNumOfAccount 

func (mem *Mempool) TxNumOfAccount(addr string) int64

TxNumOfAccount 返回账户在mempool中交易数量

func (*Mempool) Wait 

func (mem *Mempool) Wait()

Wait wait mempool ready

type QueueCache 

type QueueCache interface {
	Exist(hash string) bool
	GetItem(hash string) (*Item, error)
	Push(tx *Item) error
	Remove(hash string) error
	Size() int
	Walk(count int, cb func(tx *Item) bool)
	GetProperFee() int64
	GetCacheBytes() int64
}

QueueCache 排队交易处理

type SHashTxCache 

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

SHashTxCache 通过shorthash缓存交易

func NewSHashTxCache 

func NewSHashTxCache(size int) *SHashTxCache

NewSHashTxCache 创建通过短hash交易的cache

func (*SHashTxCache) Exist 

func (cache *SHashTxCache) Exist(shash string) bool

Exist 是否存在

func (*SHashTxCache) GetSHashTxCache 

func (cache *SHashTxCache) GetSHashTxCache(sHash string) *types.Transaction

GetSHashTxCache 返回shorthash对应的tx交易信息

func (*SHashTxCache) Push 

func (cache *SHashTxCache) Push(tx *types.Transaction, txHash []byte)

Push tx into SHashTxCache

func (*SHashTxCache) Remove 

func (cache *SHashTxCache) Remove(txHash string)

Remove remove tx of SHashTxCache

type SimpleQueue 

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

SimpleQueue 简单队列模式(默认提供一个队列，便于测试)

func NewSimpleQueue 

func NewSimpleQueue(subConfig SubConfig) *SimpleQueue

NewSimpleQueue 创建队列

func (*SimpleQueue) Exist 

func (cache *SimpleQueue) Exist(hash string) bool

Exist 是否存在

func (*SimpleQueue) GetCacheBytes 

func (cache *SimpleQueue) GetCacheBytes() int64

GetCacheBytes 获取缓存占用空间大小

func (*SimpleQueue) GetItem 

func (cache *SimpleQueue) GetItem(hash string) (*Item, error)

GetItem 获取数据通过 key

func (*SimpleQueue) GetProperFee 

func (cache *SimpleQueue) GetProperFee() int64

GetProperFee 获取合适的手续费

func (*SimpleQueue) Push 

func (cache *SimpleQueue) Push(tx *Item) error

Push 把给定tx添加到SimpleQueue；如果tx已经存在SimpleQueue中或Mempool已满则返回对应error

func (*SimpleQueue) Remove 

func (cache *SimpleQueue) Remove(hash string) error

Remove 删除数据

func (*SimpleQueue) Size 

func (cache *SimpleQueue) Size() int

Size 数据总数

func (*SimpleQueue) Walk 

func (cache *SimpleQueue) Walk(count int, cb func(value *Item) bool)

Walk 遍历整个队列

type SubConfig 

type SubConfig struct {
	PoolCacheSize int64 `json:"poolCacheSize"`
	ProperFee     int64 `json:"properFee"`
}

SubConfig 配置信息

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.