huobi

Documentation

Index

• Constants
• func NewError(msg string) error
• 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() (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
• type RestResponse
• type Tick
• type Trade
  • func ParseTrades(raw json.RawMessage) ([]Trade, error)

Constants

const (
	Huobi = "huobi"

	StatusOK = "ok"
	CodeOK   = 200
)

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

Functions

func NewError

func NewError(msg string) error

Types

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"`
	Ch   string          `json:"ch"`
	TS   int             `json:"ts"`
	Tick json.RawMessage `json:"tick"`
}

func (*Response) Parse

func (r *Response) Parse() (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

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)