ws

Jul 19, 2023

Changes in this version

+ func ResponceFromUnknownChannel(connWs ConnectorWs, message string)

+ func Stop(connWs ConnectorWs)

type ConnectorWs

+ ClearOperations func()

+ GetErrorChan func() chan error

+ GetIsConnStable func() bool

+ GetOperations func() []config.Operation

+ SendToErrorChan func(err error)

+ SetErrorChan func(ch chan error)

+ SetIsConnStable func(stable bool)

Mar 16, 2023

Changes in this version

+ func Login(connWs ConnectorWs)

Feb 27, 2023

Changes in this version

type ConnectorWs

+ GetPingMessage func() string

Feb 21, 2023

Changes in this version

+ func Debug(connWs ConnectorWs, s string)

+ func Error(connWs ConnectorWs, errName string, err error, data []interface{}, ...)

+ func Start(connWs ConnectorWs) error

+ func Subscribe(connWs ConnectorWs, channel string, symbols []string)

+ type ConnectorWs interface

+ AddSub func(sub interface{})

+ GetConfiguration func() Configuration

+ GetConnection func() *websocket.Conn

+ GetEmitter func() *emission.Emitter

+ GetExchangeName func() string

+ GetLogger func() *zap.Logger

+ GetPair func(args ...string) string

+ GetRequest func(op string, channel string, symbols []string) interface{}

+ GetSubs func() []interface{}

+ GetTradingType func() TradingType

+ MessageHandler func(data []byte)

+ SetConnection func(c *websocket.Conn)

+ type TradingType string

+ const FuturesTrading

+ const MarginTrading

+ const SpotTrading