score

Documentation

Index

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

Functions

func New

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

New 创建score cache 结构的 mempool

Types

type Queue

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

Queue 分数队列模式(分数=常量a*手续费/交易字节数-常量b*时间*定量c,按分数排队,高的优先,常量a,b和定量c可配置)

func NewQueue

func NewQueue(subcfg subConfig) *Queue

NewQueue 创建队列

func (*Queue) Exist

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

Exist 是否存在

func (*Queue) GetItem

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

GetItem 获取数据通过 key

func (*Queue) Push

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

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

func (*Queue) Remove

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

Remove 删除数据

func (*Queue) Size

func (cache *Queue) Size() int

Size 数据总数

func (*Queue) Walk

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

Walk 遍历整个队列