okex

package
v0.0.0-...-debd72c Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2023 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Code generated by go generate; DO NOT EDIT.

Index

Constants

View Source 
const ID = "okex"
View Source 
const PlatformToken = "OKB"

OKB is the platform currency of OKEx, pre-allocate static string here

Variables

View Source 
var CandleChannels = []string{
	"candle1Y",
	"candle6M", "candle3M", "candle1M",
	"candle1W",
	"candle1D", "candle2D", "candle3D", "candle5D",
	"candle12H", "candle6H", "candle4H", "candle2H", "candle1H",
	"candle30m", "candle15m", "candle5m", "candle3m", "candle1m",
}

Functions

This section is empty.

Types

type BookEntry 

type BookEntry struct {
	Price         fixedpoint.Value
	Volume        fixedpoint.Value
	NumLiquidated int
	NumOrders     int
}

type BookEvent 

type BookEvent struct {
	InstrumentID         string
	Symbol               string
	Action               string
	Bids                 []BookEntry
	Asks                 []BookEntry
	MillisecondTimestamp int64
	Checksum             int
	// contains filtered or unexported fields
}

func (*BookEvent) Book 

func (data *BookEvent) Book() types.SliceOrderBook

func (*BookEvent) BookTicker 

func (data *BookEvent) BookTicker() types.BookTicker

type Candle 

type Candle struct {
	Channel      string
	InstrumentID string
	Symbol       string
	Interval     string
	Open         fixedpoint.Value
	High         fixedpoint.Value
	Low          fixedpoint.Value
	Close        fixedpoint.Value

	// Trading volume, with a unit of contact.
	// If it is a derivatives contract, the value is the number of contracts.
	// If it is SPOT/MARGIN, the value is the amount of trading currency.
	Volume fixedpoint.Value

	// Trading volume, with a unit of currency.
	// If it is a derivatives contract, the value is the number of settlement currency.
	// If it is SPOT/MARGIN, the value is the number of quote currency.
	VolumeInCurrency fixedpoint.Value

	MillisecondTimestamp int64

	StartTime time.Time
}

func (*Candle) KLine 

func (c *Candle) KLine() types.KLine

type CandleKey 

type CandleKey struct {
	InstrumentID string
	Channel      string
}

type Exchange 

type Exchange struct {
	types.MarginSettings
	types.FuturesSettings
	// contains filtered or unexported fields
}

func New 

func New(key, secret, passphrase string) *Exchange

func (*Exchange) CancelOrders 

func (e *Exchange) CancelOrders(ctx context.Context, orders ...types.Order) error

func (*Exchange) Name 

func (e *Exchange) Name() types.ExchangeName

func (*Exchange) NewStream 

func (e *Exchange) NewStream() types.Stream

func (*Exchange) PlatformFeeCurrency 

func (e *Exchange) PlatformFeeCurrency() string

func (*Exchange) QueryAccount 

func (e *Exchange) QueryAccount(ctx context.Context) (*types.Account, error)

func (*Exchange) QueryAccountBalances 

func (e *Exchange) QueryAccountBalances(ctx context.Context) (types.BalanceMap, error)

func (*Exchange) QueryClosedOrders 

func (e *Exchange) QueryClosedOrders(ctx context.Context, symbol string, since, until time.Time, lastOrderID uint64) ([]types.Order, error)

lastOrderID is not supported on MAX

func (*Exchange) QueryKLines 

func (e *Exchange) QueryKLines(ctx context.Context, symbol string, interval types.Interval, options types.KLineQueryOptions) ([]types.KLine, error)

func (*Exchange) QueryMarkets 

func (e *Exchange) QueryMarkets(ctx context.Context) (types.MarketMap, error)

func (*Exchange) QueryOpenOrders 

func (e *Exchange) QueryOpenOrders(ctx context.Context, symbol string) (orders []types.Order, err error)

func (*Exchange) QueryPositions 

func (e *Exchange) QueryPositions(ctx context.Context, symbol string) ([]*types.Positions, error)

func (*Exchange) QueryTicker 

func (e *Exchange) QueryTicker(ctx context.Context, symbol string) (*types.Ticker, error)

func (*Exchange) QueryTickers 

func (e *Exchange) QueryTickers(ctx context.Context, symbols ...string) (map[string]types.Ticker, error)

func (*Exchange) QueryTrades 

func (e *Exchange) QueryTrades(ctx context.Context, symbol string, options *types.TradeQueryOptions) ([]types.Trade, error)

func (*Exchange) SubmitAlgoOrder 

func (e *Exchange) SubmitAlgoOrder(ctx context.Context, order types.SubmitOrder) (*types.Order, error)

func (*Exchange) SubmitOrder 

func (e *Exchange) SubmitOrder(ctx context.Context, order types.SubmitOrder) (*types.Order, error)

type Stream 

type Stream struct {
	types.StandardStream
	// contains filtered or unexported fields
}

func NewStream 

func NewStream(client *okexapi.RestClient) *Stream

func (*Stream) EmitAccountEvent 

func (s *Stream) EmitAccountEvent(account okexapi.Account)

func (*Stream) EmitBookEvent 

func (s *Stream) EmitBookEvent(book BookEvent)

func (*Stream) EmitCandleEvent 

func (s *Stream) EmitCandleEvent(candle Candle)

func (*Stream) EmitEvent 

func (s *Stream) EmitEvent(event WebSocketEvent)

func (*Stream) EmitOrderDetailsEvent 

func (s *Stream) EmitOrderDetailsEvent(orderDetails []okexapi.OrderDetails)

func (*Stream) OnAccountEvent 

func (s *Stream) OnAccountEvent(cb func(account okexapi.Account))

func (*Stream) OnBookEvent 

func (s *Stream) OnBookEvent(cb func(book BookEvent))

func (*Stream) OnCandleEvent 

func (s *Stream) OnCandleEvent(cb func(candle Candle))

func (*Stream) OnEvent 

func (s *Stream) OnEvent(cb func(event WebSocketEvent))

func (*Stream) OnOrderDetailsEvent 

func (s *Stream) OnOrderDetailsEvent(cb func(orderDetails []okexapi.OrderDetails))

type StreamEventHub 

type StreamEventHub interface {
	OnCandleEvent(cb func(candle Candle))

	OnBookEvent(cb func(book BookEvent))

	OnEvent(cb func(event WebSocketEvent))

	OnAccountEvent(cb func(account okexapi.Account))

	OnOrderDetailsEvent(cb func(orderDetails []okexapi.OrderDetails))
}

type WebSocketEvent 

type WebSocketEvent struct {
	Event   string      `json:"event"`
	Code    string      `json:"code,omitempty"`
	Message string      `json:"msg,omitempty"`
	Arg     interface{} `json:"arg,omitempty"`
}

type WebsocketLogin 

type WebsocketLogin struct {
	Key        string `json:"apiKey"`
	Passphrase string `json:"passphrase"`
	Timestamp  string `json:"timestamp"`
	Sign       string `json:"sign"`
}

type WebsocketOp 

type WebsocketOp struct {
	Op   string      `json:"op"`
	Args interface{} `json:"args"`
}

type WebsocketSubscription 

type WebsocketSubscription struct {
	Channel        string `json:"channel"`
	InstrumentID   string `json:"instId,omitempty"`
	InstrumentType string `json:"instType,omitempty"`
}

Source Files

View all Source files

Directories

Path Synopsis
Code generated by go generate; DO NOT EDIT.
 Code generated by go generate; DO NOT EDIT.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.