okex

package
v0.0.0-...-d95647c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 4, 2019 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const (
	OrderPlaceTypeBuy        = "buy"         //限价买
	OrderPlaceTypeSell       = "sell"        //限价卖
	OrderPlaceTypeBuyMarket  = "buy_market"  //市价买
	OrderPlaceTypeSellMarket = "sell_market" //市价卖
)
View Source
const (
	OrderStatusCancel         = -1 //已撤销
	OrderStatusUnsettled      = 0  //未成交
	OrderStatusPartialFilled  = 1  //部分成交
	OrderStatusFilled         = 2  //完全成交
	OrderStatusCancelApplying = 4  //撤单申请中
)
View Source
const (
	WSAddChannel   = "addChannel"
	WSChannelValue = "channelValue"
)

Variables

View Source
var ConnectionClosedError = fmt.Errorf("websocket connection closed")

ConnectionClosedError Websocket未连接错误

View Source
var Endpoint = "wss://real.okex.com:10441/websocket"

Endpoint 行情的Websocket入口

Functions

func TransOrderStateFromStatus

func TransOrderStateFromStatus(s int) string

func TransOrderType

func TransOrderType(t string) string

Types

type BalanceReturn

type BalanceReturn struct {
	Result bool              `json:"result"`
	Info   BalanceReturnInfo `json:"info"`
}

type BalanceReturnInfo

type BalanceReturnInfo struct {
	Funds struct {
		Free    map[string]string `json:"free"`
		Freezed map[string]string `json:"freezed"`
	} `json:"funds"`
}

type CancelOrderReturn

type CancelOrderReturn struct {
	Result    bool   `json:"result"`
	ErrorCode int    `json:"error_code"`
	OrderID   string `json:"order_id"`
}

type Listener

type Listener = func(topic string, json *simplejson.Json)

Listener 订阅事件监听器

type Market

type Market struct {

	// 主动发送心跳的时间间隔,默认5秒
	HeartbeatInterval time.Duration
	// 接收消息超时时间,默认10秒
	ReceiveTimeout time.Duration
	// contains filtered or unexported fields
}

func NewMarket

func NewMarket() (m *Market, err error)

NewMarket 创建Market实例

func (*Market) Close

func (m *Market) Close() error

Close 关闭连接

func (*Market) Loop

func (m *Market) Loop()

Loop 进入循环

func (*Market) ReConnect

func (m *Market) ReConnect() (err error)

ReConnect 重新连接

func (*Market) Request

func (m *Market) Request(req string) (*simplejson.Json, error)

Request 请求行情信息

func (*Market) Subscribe

func (m *Market) Subscribe(topic string, listener Listener) error

Subscribe 订阅

func (*Market) Unsubscribe

func (m *Market) Unsubscribe(topic string)

Unsubscribe 取消订阅

type OKEX

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

func NewOKEX

func NewOKEX(apiKey, secretKey string) (*OKEX, error)

func (*OKEX) GetAccountBalance

func (o *OKEX) GetAccountBalance() ([]proto.AccountBalance, error)

func (*OKEX) GetExchangeType

func (o *OKEX) GetExchangeType() string

func (*OKEX) GetOrderInfo

func (o *OKEX) GetOrderInfo(params *proto.OrderInfoParams) (*proto.Order, error)

func (*OKEX) GetOrders

func (o *OKEX) GetOrders(params *proto.OrdersParams) ([]proto.Order, error)

func (*OKEX) OrderCancel

func (o *OKEX) OrderCancel(params *proto.OrderCancelParams) error

func (*OKEX) OrderPlace

func (o *OKEX) OrderPlace(params *proto.OrderPlaceParams) (*proto.OrderPlaceReturn, error)

访问频率 20次/2秒

func (*OKEX) SubscribeDetail

func (h *OKEX) SubscribeDetail(symbols ...string)

type OrderInfoReturn

type OrderInfoReturn struct {
	Result    bool                       `json:"result"`
	ErrorCode int                        `json:"error_code"`
	Orders    []OrderInfoReturnOrderItem `json:"orders"`
}

type OrderInfoReturnOrderItem

type OrderInfoReturnOrderItem struct {
	Amount     float64 `json:"amount"`
	AvgPrice   string  `json:"avg_price"`
	CreateDate int64   `json:"create_date"`
	DealAmount float64 `json:"deal_amount"`
	OrderID    int64   `json:"order_id"`
	Price      float64 `json:"price"`
	Status     int     `json:"status"`
	Symbol     string  `json:"symbol"`
	Type       string  `json:"type"`
}

type OrderPlaceReturn

type OrderPlaceReturn struct {
	Result    bool  `json:"result"`
	OrderID   int64 `json:"order_id"`
	ErrorCode int   `json:"error_code"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL