price

Documentation

Index

• func New(cfg *types.Mempool, sub []byte) queue.Module
• type Queue
  • func NewQueue(subcfg subConfig) *Queue
  • func (cache *Queue) GetItem(hash string) (*mempool.Item, error)
  • func (cache *Queue) GetProperFee() int64
  • func (cache *Queue) Push(item *mempool.Item) error
  • func (cache *Queue) Walk(count int, cb func(tx *mempool.Item) bool)

Functions

func New

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

New 创建price cache 结构的 mempool

Types

type Queue

type Queue struct {
	*skiplist.Queue
	// contains filtered or unexported fields
}

Queue 价格队列模式(价格=手续费/交易字节数,价格高者优先,同价则时间早优先)

func NewQueue

func NewQueue(subcfg subConfig) *Queue

NewQueue 创建队列

func (*Queue) GetItem

func (cache *Queue) GetItem(hash string) (*mempool.Item, error)

GetItem 获取数据通过 key

func (*Queue) GetProperFee

func (cache *Queue) GetProperFee() int64

GetProperFee 获取合适的手续费率,取前100的平均手续费率

func (*Queue) Push

func (cache *Queue) Push(item *mempool.Item) error

Push 加入数据到队列

func (*Queue) Walk

func (cache *Queue) Walk(count int, cb func(tx *mempool.Item) bool)

Walk 获取数据通过 key