ws

Documentation

Index

• func Debug(connWs ConnectorWs, s string)
• func Error(connWs ConnectorWs, errName string, err error, data interface{}, ...)
• func Login(connWs ConnectorWs)
• func Start(connWs ConnectorWs) error
• func Subscribe(connWs ConnectorWs, channel string, args interface{})
• type ConnectorWs

Functions

func Debug

func Debug(connWs ConnectorWs, s string)

func Error

func Error(connWs ConnectorWs, errName string, err error, data interface{}, errText string)

func Login

func Login(connWs ConnectorWs)

function to enter the private channel of the exchange. If exchange haven't private channel, an error will be returned

func Start

func Start(connWs ConnectorWs) error

подключение к серверу и постоянное чтение приходящих ответов

func Subscribe

func Subscribe(connWs ConnectorWs, channel string, args interface{})

for Binance, Bibit args - symbols for subscrybe for OKX args- structure for subscrybe to channel (without op)

Types

type ConnectorWs

type ConnectorWs interface {
	GetExchangeName() string
	GetPair(args ...string) string
	GetTradingType() string
	GetConfiguration() ccxtbeyang.Configuration
	GetConnection() *websocket.Conn
	SetConnection(c *websocket.Conn)
	GetSubs() []interface{}
	GetEmitter() *emission.Emitter
	GetLogger() *zap.Logger
	MessageHandler(data []byte)
	GetRequest(op string, channel string, args interface{}) (interface{}, error)
	GetPingMessage() (int, string)
}