para

package
v0.0.0-...-5c7291a Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2020 License: ISC Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL