marketws

type AnyMessage struct {
	Ping              *PingMessage
	Response          *Response
	SubscribedMessage *SubscribedMessage
}

type DepthTopicParam struct {
	ContractCode string `validate:"required"`
	Type         string `` /* 154-byte string literal not displayed */
}

type KlineTopicParam struct {
	ContractCode string                  `validate:"required"`
	Interval     usdmtypes.KlineInterval `validate:"required,oneof=1min 5min 15min 30min 1hour 4hour 1day 1mon"`
}

type Listener func(any)

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

type MarketWsClientCfg struct {
	Debug         bool
	BaseURL       string `validate:"required"`
	AutoReconnect bool   `validate:"required"`
	// Logger
	Logger *slog.Logger
}

type PingMessage struct {
	Ping int64 `json:"ping,omitempty"`
}

type PongMessage struct {
	Pong int64 `json:"pong,omitempty"`
}

type Request struct {
	ID    string `json:"id,omitempty"`
	Sub   string `json:"sub,omitempty"`
	UnSub string `json:"unsub,omitempty"`
}

type Response struct {
	ID     string `json:"id,omitempty"`
	Status string `json:"status,omitempty"`
	Subbed string `json:"subbed,omitempty"`
	Ts     int64  `json:"ts,omitempty"`
}

type SubscribedMessage struct {
	Channel string          `json:"ch,omitempty"`
	Ts      int64           `json:"ts,omitempty"`
	Data    json.RawMessage `json:"tick"`
}