binance

package
v0.0.13 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const Binance = "Binance"

Variables

This section is empty.

Functions

func ErrNotSupportType 

func ErrNotSupportType(format string, a ...interface{}) error

func IsErrNotSupportType 

func IsErrNotSupportType(err error) bool

Types

type AggTrade 

type AggTrade struct {
	E    string `json:"e,omitempty"`
	BigE uint64 `json:"E,omitempty"`
	S    string `json:"s,omitempty"`
	A    uint64 `json:"a,omitempty"`
	P    string `json:"p,omitempty"`
	Q    string `json:"q,omitempty"`
	F    uint64 `json:"f,omitempty"`
	L    uint64 `json:"l,omitempty"`
	BigT uint64 `json:"T,omitempty"`
	M    bool   `json:"m,omitempty"`
	BigM bool   `json:"M,omitempty"`
}

type BinanceBody 

type BinanceBody struct {
	Body interface{}
}

type BookTicker 

type BookTicker struct {
	U    uint64 `json:"u,omitempty"` // order book updateId
	S    string `json:"s,omitempty"` // 交易对
	B    string `json:"b,omitempty"` // 买单最优挂单价格
	BigB string `json:"B,omitempty"` // 买单最优挂单数量
	A    string `json:"a,omitempty"` // 卖单最优挂单价格
	BigA string `json:"A,omitempty"` // 卖单最优挂单数量
}

type Client 

type Client struct {
	APIKey    string
	SecretKey string
	BaseURL   string
	Id        string
	RpcId     int64
	// contains filtered or unexported fields
}

Client 单个 websocket 信息

func New 

func New(opts ...Option) *Client

func NewBinanceStream 

func NewBinanceStream(apiKey, secretKey string, streams []string) *Client

func (*Client) Send 

func (c *Client) Send(data []byte, id int64, callback Service)

func (*Client) Start 

func (c *Client) Start() error

func (*Client) Stop 

func (c *Client) Stop() error

func (*Client) Subscribe 

func (c *Client) Subscribe(ch interface{}) event.Subscription

func (*Client) UnpackTrade 

func (c *Client) UnpackTrade(data []byte) (interface{}, error)

type DepthUpdate 

type DepthUpdate struct {
}

type Kline 

type Kline struct {
	E    string `json:"e,omitempty"`
	BigE uint64 `json:"E,omitempty"`
	S    string `json:"s,omitempty"`
	K    struct {
		T    uint64 `json:"t,omitempty"`
		BigT uint64 `json:"T,omitempty"`
		S    string `json:"s,omitempty"`
		I    string `json:"i,omitempty"`
		F    uint64 `json:"f,omitempty"`
		// BigL uint64 `json:"L,omitempty"` // 这根K线期间末一笔成交ID
		O string `json:"o,omitempty"` // 这根K线期间第一笔成交价
		C string `json:"c,omitempty"` // 这根K线期间末一笔成交价
		H string `json:"h,omitempty"` // 这根K线期间最高成交价
		// L    string `json:"l,omitempty"` // 这根K线期间最低成交价
		V    string `json:"v,omitempty"` // 这根K线期间成交量
		N    uint64 `json:"n,omitempty"` // 这根K线期间成交笔数
		X    bool   `json:"x,omitempty"` // 这根K线是否完结(是否已经开始下一根K线)
		Q    string `json:"q,omitempty"` // 这根K线期间成交额
		BigV string `json:"V,omitempty"` // 主动买入的成交量
		BigQ string `json:"Q,omitempty"` // 主动买入的成交额
		BigB string `json:"B,omitempty"` // 忽略此参数
	} `json:"k,omitempty"`
}

type MiniTicker 

type MiniTicker struct {
}

type Option 

type Option func(*options)

func APIKey 

func APIKey(key string) Option

func BaseURL 

func BaseURL(path string) Option

func SecretKey 

func SecretKey(name string) Option

type Service 

type Service interface {
	Unmarshal(data []byte) (interface{}, error)
}

type SubscribeReq 

type SubscribeReq struct {
	Method string        `json:"method,omitempty"`
	Params []interface{} `json:"params,omitempty"`
	ID     int64         `json:"id,omitempty"`
}

type SubscribeResp 

type SubscribeResp struct {
	Result []string `json:"result,omitempty"`
	ID     int64    `json:"id,omitempty"`
	Code   int      `json:"code,omitempty"`
	Msg    int      `json:"msg,omitempty"`
}

type SubscribeService 

type SubscribeService struct {
	C *Client
	// contains filtered or unexported fields
}

func (*SubscribeService) Do 

func (s *SubscribeService) Do(ctx context.Context, ID uint) error

func (*SubscribeService) Subscribe 

func (s *SubscribeService) Subscribe(channel string)

func (*SubscribeService) Unmarshal 

func (s *SubscribeService) Unmarshal(data []byte) (interface{}, error)

type Ticker 

type Ticker struct {
	E    string `json:"e,omitempty"`
	BigE uint64 `json:"E,omitempty"`
	S    string `json:"s,omitempty"`
	P    string `json:"p,omitempty"`
	BigP string `json:"P,omitempty"`
	W    string `json:"w,omitempty"` // 平均价格
	X    string `json:"x,omitempty"` // 整整24小时之前，向前数的最后一次成交价格
	C    string `json:"c,omitempty"` // 最新成交价格
	BigQ string `json:"Q,omitempty"` // 最新成交交易的成交量
	B    string `json:"b,omitempty"` // 目前最高买单价
	BigB string `json:"B,omitempty"` // 目前最高买单价的挂单量
	A    string `json:"a,omitempty"` // 目前最低卖单价
	BigA string `json:"A,omitempty"` // 目前最低卖单价的挂单量
	O    string `json:"o,omitempty"` // 整整24小时前，向后数的第一次成交价格
	H    string `json:"h,omitempty"` // 24小时内最高成交价
	L    string `json:"l,omitempty"` // 24小时内最低成交价
	V    string `json:"v,omitempty"` // 24小时内成交量
	Q    string `json:"Q,omitempty"` // 24小时内成交额
	BigO uint64 `json:"O,omitempty"` // 统计开始时间
	BigC uint64 `json:"C,omitempty"` // 统计结束时间
	BigF uint64 `json:"F,omitempty"` // 24小时内第一笔成交交易ID
	BigL uint64 `json:"L,omitempty"` // 24小时内最后一笔成交交易ID
	N    uint64 `json:"n,omitempty"` // 24小时内成交数
}

type Trade 

type Trade struct {
	E    string `json:"e,omitempty"`
	BigE uint64 `json:"E,omitempty"`
	S    string `json:"s,omitempty"`
	A    uint64 `json:"a,omitempty"`
	P    string `json:"p,omitempty"`
	Q    string `json:"q,omitempty"`
	F    uint64 `json:"f,omitempty"`
	L    uint64 `json:"l,omitempty"`
	BigT uint64 `json:"T,omitempty"`
	M    bool   `json:"m,omitempty"`
	BigM bool   `json:"M,omitempty"`
}

type UnsubscribeReq 

type UnsubscribeReq struct {
	Method string        `json:"method,omitempty"`
	Params []interface{} `json:"params,omitempty"`
	ID     int64         `json:"id,omitempty"`
}

type UnsubscribeResp 

type UnsubscribeResp struct {
	Result []string `json:"result,omitempty"`
	ID     int64    `json:"id,omitempty"`
	Code   int      `json:"code,omitempty"`
	Msg    int      `json:"msg,omitempty"`
}

type UnsubscribeService 

type UnsubscribeService struct {
	C *Client
	// contains filtered or unexported fields
}

func (*UnsubscribeService) Do 

func (sub *UnsubscribeService) Do(ctx context.Context, ID uint) error

func (*UnsubscribeService) Subscribe 

func (sub *UnsubscribeService) Subscribe(x string)

func (*UnsubscribeService) Unmarshal 

func (s *UnsubscribeService) Unmarshal(data []byte) (interface{}, error)

Source Files

View all Source files

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.