huobi

Documentation

Index

• Constants
• Variables
• func NewError(msg string) error
• func ParseTS(ts int64) time.Time
• func ParseTSStr(str string) (ret time.Time, err error)
• func Signature(secret, method, host, path, query string) string
• type CallParam
• type CodeC
  • func NewCodeC() *CodeC
  • func (cc *CodeC) Decompress(raw []byte) ([]byte, error)
  • func (CodeC) Encode(req rpc.Request) ([]byte, error)
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Is(target interface{}) bool
• type NotifyTrade
• type Response
  • func (r *Response) Parse(raw []byte) (rpc.Response, error)
• type RestClient
  • func NewRestClient(key, secret, host string) *RestClient
  • func (rc *RestClient) Property() exchange.Property
  • func (rc *RestClient) Request(ctx context.Context, method string, endPoint string, param url.Values, ...) error
  • func (rc *RestClient) RequestWithRawResp(ctx context.Context, method string, endPoint string, param url.Values, ...) error
• type RestResponse
• type Tick
• type Trade
  • func ParseTrades(raw json.RawMessage) ([]Trade, error)
• type WSClient
  • func NewWSClient(addr string, codec rpc.Codec, data chan interface{}) *WSClient
  • func (ws *WSClient) Handle(ctx context.Context, notify *rpc.Notify)
  • func (ws *WSClient) Subscribe(ctx context.Context, channels ...exchange.Channel) error
  • func (ws *WSClient) UnSubscribe(ctx context.Context, channels ...exchange.Channel) error

Constants

const (
	Huobi = "huobi"

	StatusOK = "ok"
	CodeOK   = 200
)

const (
	MethodPing        = "ping"
	MethodPong        = "pong"
	MethodSubscibe    = "sub"
	MethodUnSubscribe = "unsub"
)

Variables

var (
	//SkipError means the response can not be handled directly by Parse method
	SkipError = errors.New("skip error")
)

Functions

func NewError

func NewError(msg string) error

func ParseTS

func ParseTS(ts int64) time.Time

ParseTS parse huobi timestmp microsecond

func ParseTSStr

func ParseTSStr(str string) (ret time.Time, err error)

func Signature

func Signature(secret, method, host, path, query string) string

Types

type CallParam

type CallParam struct {
	Pong  int    `json:"pong,omitempty"`
	Sub   string `json:"sub,omitempty"`
	UnSub string `json:"unsub,omitempty"`
	ID    string `json:"id,omitempty"`
}

CallParam carry params which used by huobi websocket sub and pong

type CodeC

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

func NewCodeC

func NewCodeC() *CodeC

func (*CodeC) Decompress

func (cc *CodeC) Decompress(raw []byte) ([]byte, error)

func (CodeC) Encode

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

type Error

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

func (*Error) Error

func (e *Error) Error() string

func (*Error) Is

func (e *Error) Is(target interface{}) bool

type NotifyTrade

type NotifyTrade struct {
	Trades []Trade
	Chan   string
}

type Response

type Response struct {
	Ping    int             `json:"ping,omitempty"`
	Ch      string          `json:"ch,omitempty"`
	TS      int64           `json:"ts,omitempty"`
	Tick    json.RawMessage `json:"tick,omitempty"`
	ID      string          `json:"id,omitempty"`
	Status  string          `json:"status,omitempty"`
	Subbed  string          `json:"subbed,omitempty"`
	ErrCode string          `json:"err-code,omitempty"`
	ErrMsg  string          `json:"err-msg,omitempty"`
}

func (*Response) Parse

func (r *Response) Parse(raw []byte) (rpc.Response, error)

type RestClient

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

func NewRestClient

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

func (*RestClient) Property

func (rc *RestClient) Property() exchange.Property

func (*RestClient) Request

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

func (*RestClient) RequestWithRawResp

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

type RestResponse

type RestResponse struct {
	Status string      `json:"status"`
	Code   int         `json:"code"`
	Data   interface{} `json:"data"`
}

type Tick

type Tick struct {
	ID   int64   `json:"id"`
	TS   int64   `json:"ts"`
	Data []Trade `json:"data"`
}

type Trade

type Trade struct {
	Amount    float64 `json:"amount"`
	TS        int64   `json:"ts"`
	ID        int64   `json:"id"`
	TradeID   int64   `json:"tradeId"`
	Price     float64 `json:"price"`
	Direction string  `json:"direction"`
}

func ParseTrades

func ParseTrades(raw json.RawMessage) ([]Trade, error)

type WSClient

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

WSClient with auto response ping support

func NewWSClient

func NewWSClient(addr string, codec rpc.Codec, data chan interface{}) *WSClient

func (*WSClient) Handle

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

func (*WSClient) Subscribe

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

func (*WSClient) UnSubscribe

func (ws *WSClient) UnSubscribe(ctx context.Context, channels ...exchange.Channel) error