ws

Mar 19, 2024

Changes in this version

+ type ClientOption func(c *ClientWs)

+ func WithLogger(sink logr.LogSink) ClientOption

Feb 28, 2024

Changes in this version

type ClientWs

+ func (c *ClientWs) CheckConnect(p bool) bool

Jan 20, 2023

Changes in this version

type Private

+ func (c *Private) AdvancedAlgoOrder(req requests.AlgoOrder, ch ...chan *private.AlgoOrder) error

+ func (c *Private) UAdvancedAlgoOrder(req requests.AlgoOrder, rCh ...bool) error

Jan 20, 2023

Changes in this version

type Private

+ func (c *Private) AlgoOrder(req requests.AlgoOrder, ch ...chan *private.AlgoOrder) error

+ func (c *Private) UAlgoOrder(req requests.AlgoOrder, rCh ...bool) error

Nov 6, 2022

Changes in this version

+ const PingPeriod

+ type ClientWs struct

+ AuthRequested *time.Time

+ Authorized bool

+ Cancel context.CancelFunc

+ DoneChan chan interface{}

+ ErrChan chan *events.Error

+ LoginChan chan *events.Login

+ Private *Private

+ Public *Public

+ RawEventChan chan *events.Basic

+ StructuredEventChan chan interface{}

+ SubscribeChan chan *events.Subscribe

+ SuccessChan chan *events.Success

+ Trade *Trade

+ UnsubscribeCh chan *events.Unsubscribe

+ func NewClient(ctx context.Context, apiKey, secretKey, passphrase string, ...) *ClientWs

+ func (c *ClientWs) Connect(p bool) error

+ func (c *ClientWs) Login() error

+ func (c *ClientWs) Send(p bool, op okex.Operation, args []map[string]string, ...) error

+ func (c *ClientWs) SetChannels(errCh chan *events.Error, subCh chan *events.Subscribe, ...)

+ func (c *ClientWs) Subscribe(p bool, ch []okex.ChannelName, args map[string]string) error

+ func (c *ClientWs) Unsubscribe(p bool, ch []okex.ChannelName, args map[string]string) error

+ func (c *ClientWs) WaitForAuthorization() error

+ type Private struct

+ func NewPrivate(c *ClientWs) *Private

+ func (c *Private) Account(req requests.Account, ch ...chan *private.Account) error

+ func (c *Private) BalanceAndPosition(ch ...chan *private.BalanceAndPosition) error

+ func (c *Private) Order(req requests.Order, ch ...chan *private.Order) error

+ func (c *Private) Position(req requests.Position, ch ...chan *private.Position) error

+ func (c *Private) Process(data []byte, e *events.Basic) bool

+ func (c *Private) UAccount(req requests.Account, rCh ...bool) error

+ func (c *Private) UBalanceAndPosition(rCh ...bool) error

+ func (c *Private) UOrder(req requests.Order, rCh ...bool) error

+ func (c *Private) UPosition(req requests.Position, rCh ...bool) error

+ type Public struct

+ func NewPublic(c *ClientWs) *Public

+ func (c *Public) Candlesticks(req requests.Candlesticks, ch ...chan *public.Candlesticks) error

+ func (c *Public) EstimatedDeliveryExercisePrice(req requests.EstimatedDeliveryExercisePrice, ...) error

+ func (c *Public) FundingRate(req requests.FundingRate, ch ...chan *public.FundingRate) error

+ func (c *Public) IndexCandlesticks(req requests.IndexCandlesticks, ch ...chan *public.IndexCandlesticks) error

+ func (c *Public) IndexTickers(req requests.IndexTickers, ch ...chan *public.IndexTickers) error

+ func (c *Public) Instruments(req requests.Instruments, ch ...chan *public.Instruments) error

+ func (c *Public) MarkPrice(req requests.MarkPrice, ch ...chan *public.MarkPrice) error

+ func (c *Public) MarkPriceCandlesticks(req requests.MarkPriceCandlesticks, ch ...chan *public.MarkPriceCandlesticks) error

+ func (c *Public) OPTIONSummary(req requests.OPTIONSummary, ch ...chan *public.OPTIONSummary) error

+ func (c *Public) OpenInterest(req requests.OpenInterest, ch ...chan *public.OpenInterest) error

+ func (c *Public) OrderBook(req requests.OrderBook, ch ...chan *public.OrderBook) error

+ func (c *Public) PriceLimit(req requests.PriceLimit, ch ...chan *public.PriceLimit) error

+ func (c *Public) Process(data []byte, e *events.Basic) bool

+ func (c *Public) Tickers(req requests.Tickers, ch ...chan *public.Tickers) error

+ func (c *Public) Trades(req requests.Trades, ch ...chan *public.Trades) error

+ func (c *Public) UCandlesticks(req requests.Candlesticks, rCh ...bool) error

+ func (c *Public) UEstimatedDeliveryExercisePrice(req requests.EstimatedDeliveryExercisePrice, rCh ...bool) error

+ func (c *Public) UFundingRate(req requests.FundingRate, rCh ...bool) error

+ func (c *Public) UIndexCandlesticks(req requests.IndexCandlesticks, rCh ...bool) error

+ func (c *Public) UIndexTickers(req requests.IndexTickers, rCh ...bool) error

+ func (c *Public) UInstruments(req requests.Instruments, rCh ...bool) error

+ func (c *Public) UMarkPrice(req requests.MarkPrice, rCh ...bool) error

+ func (c *Public) UMarkPriceCandlesticks(req requests.MarkPriceCandlesticks, rCh ...bool) error

+ func (c *Public) UOPTIONSummary(req requests.OPTIONSummary, rCh ...bool) error

+ func (c *Public) UOpenInterest(req requests.OpenInterest, rCh ...bool) error

+ func (c *Public) UOrderBook(req requests.OrderBook, rCh ...bool) error

+ func (c *Public) UPriceLimit(req requests.PriceLimit, rCh ...bool) error

+ func (c *Public) UTickers(req requests.Tickers, rCh ...bool) error

+ func (c *Public) UTrades(req requests.Trades, rCh ...bool) error

+ type Trade struct

+ func NewTrade(c *ClientWs) *Trade

+ func (c *Trade) AmendOrder(req ...requests.AmendOrder) error

+ func (c *Trade) CancelOrder(req ...requests.CancelOrder) error

+ func (c *Trade) PlaceOrder(req ...requests.PlaceOrder) error