Documentation ¶
Index ¶
- Constants
- Variables
- type KlineTopicParam
- type Listener
- type WooXWebsocketCfg
- type WooXWebsocketClient
- func (w *WooXWebsocketClient) AddListener(event string, listener Listener) *emission.Emitter
- func (w *WooXWebsocketClient) GetAllBbosTopic() (string, error)
- func (w *WooXWebsocketClient) GetAllTickersTopic() (string, error)
- func (w *WooXWebsocketClient) GetBboTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetEstFundingRateTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetIndexPriceTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetKlineTopic(params *KlineTopicParam) (string, error)
- func (w *WooXWebsocketClient) GetListeners(event string, argument any) *emission.Emitter
- func (w *WooXWebsocketClient) GetMarkPriceTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetMarkPricesTopic() (string, error)
- func (w *WooXWebsocketClient) GetOpenInterestTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetOrderbookTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetTickerTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) GetTradeTopic(symbol string) (string, error)
- func (w *WooXWebsocketClient) IsConnected() bool
- func (w *WooXWebsocketClient) RemoveListener(event string, listener Listener) *emission.Emitter
- func (w *WooXWebsocketClient) Subscribe(topics []string) error
- func (w *WooXWebsocketClient) UnSubscribe(topics []string) error
Constants ¶
View Source
const ( SUBSCRIBE = "subscribe" UNSUBSCRIBE = "unsubscribe" )
View Source
const (
MaxTryTimes = 5
)
Variables ¶
View Source
var ( TestNetPublicBaseURL = "wss://wss.staging.woo.org/ws/stream/" PublicBaseURL = "wss://wss.woo.org/ws/stream/" TestNetPrivateBaseURL = "wss://wss.staging.woo.org/v2/ws/private/stream/" PrivateBaseURL = "wss://wss.woo.org/v2/ws/private/stream/" )
Functions ¶
This section is empty.
Types ¶
type KlineTopicParam ¶
type WooXWebsocketCfg ¶
type WooXWebsocketClient ¶
type WooXWebsocketClient struct {
// contains filtered or unexported fields
}
func NewWooXWebsocketClient ¶
func NewWooXWebsocketClient(ctx context.Context, cfg *WooXWebsocketCfg) (*WooXWebsocketClient, error)
func (*WooXWebsocketClient) AddListener ¶
func (w *WooXWebsocketClient) AddListener(event string, listener Listener) *emission.Emitter
func (*WooXWebsocketClient) GetAllBbosTopic ¶
func (w *WooXWebsocketClient) GetAllBbosTopic() (string, error)
func (*WooXWebsocketClient) GetAllTickersTopic ¶
func (w *WooXWebsocketClient) GetAllTickersTopic() (string, error)
func (*WooXWebsocketClient) GetBboTopic ¶
func (w *WooXWebsocketClient) GetBboTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetEstFundingRateTopic ¶
func (w *WooXWebsocketClient) GetEstFundingRateTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetIndexPriceTopic ¶
func (w *WooXWebsocketClient) GetIndexPriceTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetKlineTopic ¶
func (w *WooXWebsocketClient) GetKlineTopic(params *KlineTopicParam) (string, error)
func (*WooXWebsocketClient) GetListeners ¶
func (w *WooXWebsocketClient) GetListeners(event string, argument any) *emission.Emitter
func (*WooXWebsocketClient) GetMarkPriceTopic ¶
func (w *WooXWebsocketClient) GetMarkPriceTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetMarkPricesTopic ¶
func (w *WooXWebsocketClient) GetMarkPricesTopic() (string, error)
func (*WooXWebsocketClient) GetOpenInterestTopic ¶
func (w *WooXWebsocketClient) GetOpenInterestTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetOrderbookTopic ¶
func (w *WooXWebsocketClient) GetOrderbookTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetTickerTopic ¶
func (w *WooXWebsocketClient) GetTickerTopic(symbol string) (string, error)
func (*WooXWebsocketClient) GetTradeTopic ¶
func (w *WooXWebsocketClient) GetTradeTopic(symbol string) (string, error)
func (*WooXWebsocketClient) IsConnected ¶
func (w *WooXWebsocketClient) IsConnected() bool
IsConnected returns the WebSocket connection state
func (*WooXWebsocketClient) RemoveListener ¶
func (w *WooXWebsocketClient) RemoveListener(event string, listener Listener) *emission.Emitter
func (*WooXWebsocketClient) Subscribe ¶
func (w *WooXWebsocketClient) Subscribe(topics []string) error
func (*WooXWebsocketClient) UnSubscribe ¶
func (w *WooXWebsocketClient) UnSubscribe(topics []string) error
Click to show internal directories.
Click to hide internal directories.