okex

Documentation

Index

• Constants
• func NewSpotSymbol(base, quote string) exchange.SpotSymbol
• func NewSwapSymbol(index string) exchange.SwapSymbol
• func ParseSwapSymbol(sym string) (exchange.SwapSymbol, error)
• func ParseTime(timestamp string) (time.Time, error)
• func SubscribeCB(channel string, cb ResponseParseCB)
• type CodeC
  • func NewCodeC() *CodeC
  • func (cc *CodeC) Decode(raw []byte) (rpc.Response, error)
  • func (cc *CodeC) Encode(req rpc.Request) ([]byte, error)
• type ResponseParseCB
• type RestClient
  • func NewRestClient(key, secret, passPhrase string) *RestClient
  • func NewTESTRestClient(key, secret, passPhrase string) *RestClient
  • func (rc *RestClient) FeeRate(ctx context.Context, syms ...exchange.Symbol) ([]exchange.TradeFee, error)
  • func (rc *RestClient) Request(ctx context.Context, method, endPoint string, params url.Values, ...) error
• type SpotSymbol
  • func (ss *SpotSymbol) String() string
• type SwapSymbol
  • func (ss *SwapSymbol) String() string
• type TradeFee
• type WSClient
  • func NewTESTWSClient(key, secret, passPhrase string, data chan interface{}) *WSClient
  • func NewWSClient(key, secret, passPhrase string, data chan interface{}) *WSClient
  • func (ws *WSClient) Auth(ctx context.Context) error
  • func (ws *WSClient) Handle(ctx context.Context, notify *rpc.Notify)
  • func (ws *WSClient) Run(ctx context.Context) error
  • func (ws *WSClient) Subscribe(ctx context.Context, channel ...exchange.Channel) error

Constants

const (
	OkexWSAddr     = "wss://real.okex.com:8443/ws/v3"
	OkexTESTWSAddr = "wss://real.okex.com:8443/ws/v3?brokerId=9999"
	OKEX           = "okex"
)

Functions

func NewSpotSymbol

func NewSpotSymbol(base, quote string) exchange.SpotSymbol

func NewSwapSymbol

func NewSwapSymbol(index string) exchange.SwapSymbol

func ParseSwapSymbol

func ParseSwapSymbol(sym string) (exchange.SwapSymbol, error)

func ParseTime

func ParseTime(timestamp string) (time.Time, error)

func SubscribeCB

func SubscribeCB(channel string, cb ResponseParseCB)

Types

type CodeC

type CodeC struct {
	LastSUBID string //okex op fail do not return operate type. we have to record
}

func NewCodeC

func NewCodeC() *CodeC

func (*CodeC) Decode

func (cc *CodeC) Decode(raw []byte) (rpc.Response, error)

func (*CodeC) Encode

func (cc *CodeC) Encode(req rpc.Request) ([]byte, error)

type ResponseParseCB

type ResponseParseCB func(string, string, json.RawMessage) (*rpc.Notify, error)

type RestClient

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

func NewRestClient

func NewRestClient(key, secret, passPhrase string) *RestClient

func NewTESTRestClient

func NewTESTRestClient(key, secret, passPhrase string) *RestClient

func (*RestClient) FeeRate

func (rc *RestClient) FeeRate(ctx context.Context, syms ...exchange.Symbol) ([]exchange.TradeFee, error)

func (*RestClient) Request

func (rc *RestClient) Request(ctx context.Context, method, endPoint string, params url.Values, body io.Reader, sign bool, dst interface{}) error

type SpotSymbol

type SpotSymbol struct {
	*exchange.BaseSpotSymbol
}

func (*SpotSymbol) String

func (ss *SpotSymbol) String() string

type SwapSymbol

type SwapSymbol struct {
	*exchange.BaseSwapSymbol
}

func (*SwapSymbol) String

func (ss *SwapSymbol) String() string

type TradeFee

type TradeFee struct {
	Maker     string `json:"maker"`
	Taker     string `json:"taker"`
	Timestamp string `json:"timestamp"`
}

type WSClient

type WSClient struct {
	*exchange.WSClient

	Key        string
	Secret     string
	PassPhrase string
	// contains filtered or unexported fields
}

func NewTESTWSClient

func NewTESTWSClient(key, secret, passPhrase string, data chan interface{}) *WSClient

NewTESTWSClient return a wsclient for okex testnet

func NewWSClient

func NewWSClient(key, secret, passPhrase string, data chan interface{}) *WSClient

func (*WSClient) Auth

func (ws *WSClient) Auth(ctx context.Context) error

func (*WSClient) Handle

func (ws *WSClient) Handle(ctx context.Context, notify *rpc.Notify)

func (*WSClient) Run

func (ws *WSClient) Run(ctx context.Context) error

Run start the websocket loop and create a goroutine which will send ping message to okex server periodically

func (*WSClient) Subscribe

func (ws *WSClient) Subscribe(ctx context.Context, channel ...exchange.Channel) error

Subscribe in order to get subscribe result only one channle can subscribe each time