binance

Documentation

Index

• Constants
• func Milli2Time(ts int64) time.Time
• func Time2Milli(ts time.Time) int64
• func TradeParam(symbol string, st int64, et int64, fid int64, limit int) url.Values
• type APIError
  • func (ae *APIError) ECode() int
  • func (ae *APIError) EMessage() string
  • func (ae *APIError) Error() string
  • func (ae *APIError) Is(target interface{}) bool
• type APIIF
• type CallResult
• type CodeC
  • func NewCodeC() *CodeC
  • func (cc *CodeC) DecodeByCB(raw []byte, cb func(g *gjson.Result) (rpc.Response, error)) (rpc.Response, error)
  • func (cc *CodeC) Encode(req rpc.Request) ([]byte, error)
  • func (cc *CodeC) LastID() string
• type GetRestReq
• type ListenKeyClient
• type NotifyClient
  • func NewNotifyClient(addr string, codec rpc.Codec, data chan interface{}, handler rpc.Handler) *NotifyClient
  • func (nc *NotifyClient) Handle(ctx context.Context, notify *rpc.Notify)
  • func (nc *NotifyClient) Push(ch string, data interface{})
  • func (wcl *NotifyClient) Subscribe(ctx context.Context, channels ...exchange.Channel) error
  • func (wcl *NotifyClient) UnSubscribe(ctx context.Context, channels ...exchange.Channel) error
• type RestClient
  • func NewRestClient(key, secret, host string) *RestClient
  • func (rc *RestClient) GetRequest(ctx context.Context, endPoint string, req GetRestReq, sign bool, ...) error
  • func (rc *RestClient) Request(ctx context.Context, method, endPoint string, param url.Values, data io.Reader, ...) error
• type RestReq
  • func NewRestReq() *RestReq
  • func (rr *RestReq) RecvWindow(window int) *RestReq
• type SubscribeRequest
• type WSClient
  • func NewWSClient(codec rpc.Codec, handler rpc.Handler, client ListenKeyClient) *WSClient
  • func (ws *WSClient) Run(ctx context.Context) error

Constants

const (
	MethodSubscibe    = "SUBSCRIBE"
	MethodUnSubscribe = "UNSUBSCRIBE"
)

const (
	Exchange = "binance"
)

Functions

func Milli2Time

func Milli2Time(ts int64) time.Time

func Time2Milli

func Time2Milli(ts time.Time) int64

func TradeParam

func TradeParam(symbol string, st int64, et int64, fid int64, limit int) url.Values

Types

type APIError

type APIError struct {
	Code    int    `json:"code"`
	Message string `json:"msg"`
}

APIError error message

func (*APIError) ECode

func (ae *APIError) ECode() int

func (*APIError) EMessage

func (ae *APIError) EMessage() string

func (*APIError) Error

func (ae *APIError) Error() string

func (*APIError) Is

func (ae *APIError) Is(target interface{}) bool

type APIIF

type APIIF interface {
	ECode() int
	EMessage() string
}

type CallResult

type CallResult struct {
	Result interface{} `json:"result"`
	ID     int64       `json:"id"`
}

type CodeC

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

CodeC common codec for spot swap notify

func NewCodeC

func NewCodeC() *CodeC

func (*CodeC) DecodeByCB

func (cc *CodeC) DecodeByCB(raw []byte, cb func(g *gjson.Result) (rpc.Response, error)) (rpc.Response, error)

func (*CodeC) Encode

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

Encode req to binance subscribe message

func (*CodeC) LastID

func (cc *CodeC) LastID() string

type GetRestReq

type GetRestReq interface {
	Values() (url.Values, error)
}

type ListenKeyClient

type ListenKeyClient interface {
	GetListenKeyAddr(ctx context.Context) (string, error)
	PersistListenKey(ctx context.Context) error
	DeleteListenKey(ctx context.Context) error
}

type NotifyClient

type NotifyClient struct {
	*exchange.WSClient
	// contains filtered or unexported fields
}

func NewNotifyClient

func NewNotifyClient(addr string, codec rpc.Codec, data chan interface{}, handler rpc.Handler) *NotifyClient

func (*NotifyClient) Handle

func (nc *NotifyClient) Handle(ctx context.Context, notify *rpc.Notify)

func (*NotifyClient) Push

func (nc *NotifyClient) Push(ch string, data interface{})

func (*NotifyClient) Subscribe

func (wcl *NotifyClient) Subscribe(ctx context.Context, channels ...exchange.Channel) error

func (*NotifyClient) UnSubscribe

func (wcl *NotifyClient) UnSubscribe(ctx context.Context, channels ...exchange.Channel) error

type RestClient

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

Binance Rest client instance

func NewRestClient

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

func (*RestClient) GetRequest

func (rc *RestClient) GetRequest(ctx context.Context, endPoint string, req GetRestReq, sign bool, dst interface{}) error

GetRequest helper method to send http GET request

func (*RestClient) Request

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

type RestReq

type RestReq struct {
	*exchange.RestReq
}

RestReq basic binance rest request instance add recvWindow param support

func NewRestReq

func NewRestReq() *RestReq

func (*RestReq) RecvWindow

func (rr *RestReq) RecvWindow(window int) *RestReq

type SubscribeRequest

type SubscribeRequest struct {
	Method string      `json:"method"`
	Params interface{} `json:"params"`
	ID     int64       `json:"id"`
}

type WSClient

type WSClient struct {
	rpc.Conn
	// contains filtered or unexported fields
}

WSClient common private wsclient for binance

func NewWSClient

func NewWSClient(codec rpc.Codec, handler rpc.Handler, client ListenKeyClient) *WSClient

func (*WSClient) Run

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