Package xyz.felh.okx.v5

Class OkxWsApiService

java.lang.Object
xyz.felh.okx.v5.OkxWsApiService
public class OkxWsApiService extends Object

  • Constructor Details

    • OkxWsApiService

      public OkxWsApiService()

    • OkxWsApiService

      public OkxWsApiService(boolean simulated)

    • OkxWsApiService

      public OkxWsApiService(okhttp3.OkHttpClient client, boolean simulated)

  • Method Details

    • connect

      public void connect(WsChannel wsChannel)
      connect ws
      Parameters:
      wsChannel - ws channel

    • setWebSocket

      public void setWebSocket(WsChannel wsChannel, okhttp3.WebSocket webSocket)
      set it when connected
      Parameters:
      wsChannel - ws channel
      webSocket - web socket

    • resetConnectCount

      public void resetConnectCount(WsChannel wsChannel)

    • setConnectState

      public void setConnectState(WsChannel wsChannel, boolean state)

    • reconnect

      public void reconnect(WsChannel wsChannel)
      reconnect
      Parameters:
      wsChannel - ws channel

    • isConnect

      public boolean isConnect(WsChannel wsChannel)
      is connect
      Parameters:
      wsChannel - channel
      Returns:
      isConnect

    • defaultRequest

      public static okhttp3.Request defaultRequest(WsChannel wsChannel, boolean simulated)

    • defaultClient

      public static okhttp3.OkHttpClient defaultClient(Duration pingInterval)

    • send

      public void send(WsChannel wsChannel, String message)
      send string message
      Parameters:
      wsChannel - ws channel
      message - message

    • send

      public void send(WsChannel wsChannel, okio.ByteString message)
      send byte message
      Parameters:
      wsChannel - wx channel
      message - message

    • disconnect

      public void disconnect(WsChannel wsChannel, int code, String reason)
      Manually close connection
      Parameters:
      wsChannel - ws channel
      code - code
      reason - reason

    • login

      public void login(LoginArg loginArg, String secretKey)

    • subscribeAccount

      public void subscribeAccount(AccountArg accountArg)
      账户频道
      Parameters:
      accountArg - arg

    • unsubscribeAccount

      public void unsubscribeAccount(AccountArg accountArg)

    • subscribePositions

      public void subscribePositions(PositionsArg positionsArg)
      持仓频道
      Parameters:
      positionsArg -

    • unsubscribePositions

      public void unsubscribePositions(PositionsArg positionsArg)

    • subscribeBalanceAndPosition

      public void subscribeBalanceAndPosition(BalanceAndPositionArg balanceAndPositionArg)
      账户余额和持仓频道
      Parameters:
      balanceAndPositionArg - arg

    • unsubscribeBalanceAndPosition

      public void unsubscribeBalanceAndPosition(BalanceAndPositionArg balanceAndPositionArg)

    • subscribeLiquidationWarning

      public void subscribeLiquidationWarning(LiquidationWarningArg liquidationWarningArg)
      爆仓风险预警推送频道
      Parameters:
      liquidationWarningArg -

    • unsubscribeLiquidationWarning

      public void unsubscribeLiquidationWarning(LiquidationWarningArg liquidationWarningArg)

    • subscribeAccountGreeks

      public void subscribeAccountGreeks(AccountGreeksArg accountGreeksArg)
      账户greeks频道
      Parameters:
      accountGreeksArg -

    • unsubscribeAccountGreeks

      public void unsubscribeAccountGreeks(AccountGreeksArg accountGreeksArg)

    • subscribeInstruments

      public void subscribeInstruments(InstrumentsArg instrumentsArg)
      品频道
      Parameters:
      instrumentsArg - arg

    • unsubscribeInstruments

      public void unsubscribeInstruments(InstrumentsArg instrumentsArg)

    • subscribeOpenInterest

      public void subscribeOpenInterest(OpenInterestArg openInterestArg)
      持仓总量频道
      Parameters:
      openInterestArg - arg

    • unsubscribeOpenInterest

      public void unsubscribeOpenInterest(OpenInterestArg openInterestArg)