para

Documentation

Index

• func New(cfg *types.Mempool, sub []byte) queue.Module
• type Mempool
  • func NewMempool(cfg *types.Mempool) *Mempool
  • func (mem *Mempool) Close()
  • func (mem *Mempool) SetQueueClient(client queue.Client)
  • func (mem *Mempool) Wait()

Functions

func New

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

New 创建price cache 结构的 mempool

Types

type Mempool

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

Mempool mempool 基础类

func NewMempool

func NewMempool(cfg *types.Mempool) *Mempool

NewMempool 新建mempool 实例

func (*Mempool) Close

func (mem *Mempool) Close()

Close method

func (*Mempool) SetQueueClient

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

SetQueueClient 初始化mempool模块

func (*Mempool) Wait

func (mem *Mempool) Wait()

Wait for ready