exchange

Documentation

Index

• Constants
• Variables
• func InitBroadcastService()
• func NewExchange(exchangeName string) (interfaces.Exchange, error)
• type Broadcast
• type BroadcastManage
  • func (c *BroadcastManage) ListenerTickerPrice(exchangeName string, chIndex int64, ...) error
  • func (c *BroadcastManage) RemoveListenerTickerPrice(exchangeName string, chIndex int64) error
  • func (c *BroadcastManage) StartListen(exchangeName string, chIndex int64) error

Constants

const (
	BinanceExchange = "binance"
)

Variables

var BroadcastService = map[string]map[int64]*Broadcast{}

BroadcastService 广播服务

Functions

func InitBroadcastService

func InitBroadcastService()

InitBroadcastService 初始化广播服务

func NewExchange

func NewExchange(exchangeName string) (interfaces.Exchange, error)

NewExchange 创建交易所

Types

type Broadcast

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

Broadcast 广播

type BroadcastManage

type BroadcastManage struct {
}

BroadcastManage 广播管理

var BroadcastServiceManageService *BroadcastManage

BroadcastServiceManageService 广播服务管理

func (*BroadcastManage) ListenerTickerPrice

func (c *BroadcastManage) ListenerTickerPrice(exchangeName string, chIndex int64, chListenersFunc func(broadcastMessage *utils.Message) error) error

ListenerTickerPrice 最新价格监听者

func (*BroadcastManage) RemoveListenerTickerPrice

func (c *BroadcastManage) RemoveListenerTickerPrice(exchangeName string, chIndex int64) error

RemoveListenerTickerPrice 删除监听者

func (*BroadcastManage) StartListen

func (c *BroadcastManage) StartListen(exchangeName string, chIndex int64) error

StartListen 启动监听