websocket

Documentation

Index

• Constants
• Variables
• type KlineTopicParam
• type Listener
• type WooXWebsocketCfg
• type WooXWebsocketClient
  • func NewWooXWebsocketClient(cfg *WooXWebsocketCfg) (*WooXWebsocketClient, error)
  • func (w *WooXWebsocketClient) AddListener(event string, listener Listener) *emission.Emitter
  • func (w *WooXWebsocketClient) Close() error
  • 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) Open() error
  • 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

const (
	SUBSCRIBE   = "subscribe"
	UNSUBSCRIBE = "unsubscribe"
)

const (
	MaxTryTimes = 5
)

Variables

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/"
)

Types

type KlineTopicParam

type KlineTopicParam struct {
	Symbol string `validate:"required"`
	Time   string `validate:"required,oneof=1m 5m 15m 30m 1h 1d 1w 1M"`
}

type Listener

type Listener func(any)

type WooXWebsocketCfg

type WooXWebsocketCfg struct {
	Debug         bool
	BaseURL       string `validate:"required"`
	AutoReconnect bool   `validate:"required"`

	Key           string
	Secret        string
	ApplicationID string `validate:"required"`

	// Logger
	Logger *slog.Logger
}

type WooXWebsocketClient

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

func NewWooXWebsocketClient

func NewWooXWebsocketClient(cfg *WooXWebsocketCfg) (*WooXWebsocketClient, error)

func (*WooXWebsocketClient) AddListener

func (w *WooXWebsocketClient) AddListener(event string, listener Listener) *emission.Emitter

func (*WooXWebsocketClient) Close

func (w *WooXWebsocketClient) Close() error

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) Open

func (w *WooXWebsocketClient) Open() error

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