future

Documentation

Index

• Constants
• func TypeString(ft exchange.FutureType) string
• type CodeC
  • func NewCodeC(cm map[string]string) *CodeC
  • func (cc *CodeC) Decode(raw []byte) (rpc.Response, error)
• type FSymbol
• type FutureSymbol
  • func (fs *FutureSymbol) String() string
  • func (fs *FutureSymbol) WSSub() string
• type FutureSymbolResp
• type RestClient
  • func NewRestClient(key, secret string) *RestClient
  • func (rc *RestClient) GetFutureSymbols(index string) []*FutureSymbol
  • func (rc *RestClient) Init(ctx context.Context) error
• type WSClient
  • func NewWSClient(codeMap map[string]string, data chan interface{}) *WSClient
  • func (ws *WSClient) Subscribe(ctx context.Context, typ exchange.SubType, syms ...exchange.Symbol) error
• type WSClientDeriv
  • func NewWSClientDeriv(addr string, codec rpc.Codec, data chan interface{}) *WSClientDeriv
  • func (ws *WSClientDeriv) DoSubscribe(ctx context.Context, channels []string) error
  • func (ws *WSClientDeriv) Handle(ctx context.Context, notify *rpc.Notify)

Constants

const (
	ContractStatusOnline = 1
)

const (
	FutureHost = "api.hbdm.com"
)

const (
	FutureWSAddr = "wss://api.hbdm.com/ws"
)

Functions

func TypeString

func TypeString(ft exchange.FutureType) string

Types

type CodeC

type CodeC struct {
	*huobi.CodeC
	// contains filtered or unexported fields
}

func NewCodeC

func NewCodeC(cm map[string]string) *CodeC

func (*CodeC) Decode

func (cc *CodeC) Decode(raw []byte) (rpc.Response, error)

type FSymbol

type FSymbol struct {
	Symbol         string `json:"symbol"`
	ContractCode   string `json:"contract_code"`
	DeliveryDate   string `json:"delivery_date"`
	ContractType   string `json:"contract_type"`
	ContractStatus int    `json:"contract_status"`
}

type FutureSymbol

type FutureSymbol struct {
	*exchange.BaseFutureSymbol
}

func (*FutureSymbol) String

func (fs *FutureSymbol) String() string

func (*FutureSymbol) WSSub

func (fs *FutureSymbol) WSSub() string

WSSub return symbol which used by websocket subscribe

type FutureSymbolResp

type FutureSymbolResp struct {
	Status string    `json:"status"`
	Data   []FSymbol `json:"data"`
}

type RestClient

type RestClient struct {
	*huobi.RestClient
	// contains filtered or unexported fields
}

func NewRestClient

func NewRestClient(key, secret string) *RestClient

func (*RestClient) GetFutureSymbols

func (rc *RestClient) GetFutureSymbols(index string) []*FutureSymbol

func (*RestClient) Init

func (rc *RestClient) Init(ctx context.Context) error

type WSClient

type WSClient struct {
	*WSClientDeriv
}

func NewWSClient

func NewWSClient(codeMap map[string]string, data chan interface{}) *WSClient

func (*WSClient) Subscribe

func (ws *WSClient) Subscribe(ctx context.Context, typ exchange.SubType, syms ...exchange.Symbol) error

type WSClientDeriv

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

WSClientDeriv define common logic used by huobi future swap ws

func NewWSClientDeriv

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

func (*WSClientDeriv) DoSubscribe

func (ws *WSClientDeriv) DoSubscribe(ctx context.Context, channels []string) error

func (*WSClientDeriv) Handle

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