spot

Feb 24, 2023

Changes in this version

+ const WSAddr

+ var HuobiSide2ExchangeSide map[string]exchange.OrderSide = map[string]exchange.OrderSide

+ func IsTradeDetailChanel(ch string) bool

+ func ParseTradeTick(ch string, ts int64, raw json.RawMessage) ([]*exchange.Trade, error)

+ func TradeDetailSymbol(ch string) string

+ type TradeDetail struct

+ Data []TradeDetailData

+ ID int64

+ TS int64

+ func (td *TradeDetail) Parse(sym exchange.Symbol) ([]*exchange.Trade, error)

+ type TradeDetailChannel struct

+ func NewTradeDetailChannel(sym string) *TradeDetailChannel

+ func (tdc *TradeDetailChannel) String() string

+ type TradeDetailData struct

+ Amount float64

+ Direction string

+ ID big.Int

+ Price float64

+ TS int64

+ TradeID int64

type WSClient

+ func NewWSClient(data chan interface{}) *WSClient

May 6, 2022

Changes in this version

+ const AccountHistoryEndPoint

+ const AccountLedgerEndPoint

+ const DepositWitdrawlEndPoint

+ const SubUserListEndPoint

+ type AccountHistoryData struct

+ AccountID int

+ AcctBalance string

+ AvailBalance string

+ Currency string

+ RecordID int

+ TransactAmt string

+ TransactTime int

+ TransactType string

+ type AccountHistoryReq struct

+ func NewAccountHistoryReq(uid int) *AccountHistoryReq

+ func (ar *AccountHistoryReq) AddTime(ts time.Time) *AccountHistoryReq

+ func (ar *AccountHistoryReq) Currency(cy string) *AccountHistoryReq

+ func (ar *AccountHistoryReq) EndTime(ts time.Time) *AccountHistoryReq

+ func (ar *AccountHistoryReq) FromID(id int) *AccountHistoryReq

+ func (ar *AccountHistoryReq) Size(size int) *AccountHistoryReq

+ func (ar *AccountHistoryReq) Sort(sort string) *AccountHistoryReq

+ func (ar *AccountHistoryReq) TransactTypes(types ...string) *AccountHistoryReq

+ type AccountHistoryResp struct

+ Data []AccountHistoryData

+ ErrCode string

+ ErrMsg string

+ NextID int

+ Status string

+ type AccountLedgerData struct

+ AccountID int

+ Currency string

+ TransactAmt float64

+ TransactID int

+ TransactTime int64

+ TransactType string

+ TransferType string

+ Transferee int

+ Transferer int

+ type AccountLedgerReq struct

+ func NewAccountLedgerReq(uid int) *AccountLedgerReq

+ func (ar *AccountLedgerReq) Currency(cy string) *AccountLedgerReq

+ func (ar *AccountLedgerReq) EndTime(et time.Time) *AccountLedgerReq

+ func (ar *AccountLedgerReq) FromID(id int) *AccountLedgerReq

+ func (ar *AccountLedgerReq) Limit(limit int) *AccountLedgerReq

+ func (ar *AccountLedgerReq) Sort(s string) *AccountLedgerReq

+ func (ar *AccountLedgerReq) StartTime(st time.Time) *AccountLedgerReq

+ func (ar *AccountLedgerReq) TransactTypes(typ string) *AccountLedgerReq

+ type AccountLedgerResp struct

+ Code int

+ Data []AccountLedgerData

+ Message string

+ NextID int

+ OK bool

+ type DepositWithdrawlRecord struct

+ Address string

+ AddressTag string

+ Amount float64

+ Chain string

+ CreatedAt int64

+ Currency string

+ ErrorCode string

+ ErrorMsg string

+ Fee float64

+ ID int

+ State string

+ TxHash string

+ Type string

+ UpdatedAt int64

+ type DepositWithdrawlReq struct

+ func NewDepositWithdrawlReq(typ string) *DepositWithdrawlReq

+ func (dr *DepositWithdrawlReq) Direct(d string) *DepositWithdrawlReq

+ func (dr *DepositWithdrawlReq) Type(typ string) *DepositWithdrawlReq

type RestClient

+ func (cl *RestClient) DepositWitdrawl(ctx context.Context, req *DepositWithdrawlReq) ([]DepositWithdrawlRecord, error)

+ func (rc *RestClient) AccountHistory(ctx context.Context, req *AccountHistoryReq) (*AccountHistoryResp, error)

+ func (rc *RestClient) AccountLedger(ctx context.Context, req *AccountLedgerReq) (*AccountLedgerResp, error)

+ func (rc *RestClient) SubUserAccount(ctx context.Context, req *SubUserAccountReq) ([]BalanceResp, error)

+ func (rc *RestClient) SubUserList(ctx context.Context, req *SubUserListReq) (*SubUserListResp, error)

+ type SubUserAccountReq struct

+ func NewSubUserAccountReq(uid int) *SubUserAccountReq

+ type SubUserData struct

+ UID int

+ UserState string

+ type SubUserListReq struct

+ func NewSubUserListReq() *SubUserListReq

+ func (sr *SubUserListReq) FromID(id int) *SubUserListReq

+ type SubUserListResp struct

+ Code int

+ Data []SubUserData

+ Message string

+ NextID int

Oct 27, 2021

Changes in this version

+ const TypeFrozen

+ const TypeTrade

+ type Balance struct

+ Balance string

+ Currency string

+ SeqNum string

+ Type string

+ type BalanceReq struct

+ AccountID int

+ type BalanceResp struct

+ ID int

+ List []Balance

+ State string

+ Type string

type RestClient

+ func (rc *RestClient) Balance(ctx context.Context, req *BalanceReq) (*BalanceResp, error)

+ func (rc *RestClient) FetchBalance(ctx context.Context, currencies ...string) (*exchange.Balances, error)

Aug 6, 2021

Changes in this version

+ const AccountsEndPoint

+ const ActionPing

+ const ActionPong

+ const ActionPush

+ const ActionReq

+ const ActionSub

+ const MBPAddr

+ const PlaceOrderEndPoint

+ const PrivateWSClientAddr

+ func NewMBPChannel(sym exchange.Symbol, size int) exchange.Channel

+ func ParseDepth(ch string, ts int64, tick json.RawMessage) (interface{}, error)

+ func ParseOrder(data json.RawMessage) (interface{}, error)

+ func ParseOrderStatus(state string) (exchange.OrderStatus, error)

+ func ParseOrderType(oType string) (exchange.OrderSide, exchange.OrderType, error)

+ type Account struct

+ ID int64

+ State string

+ SubType string

+ Type string

+ type CodeC struct

+ func NewCodeC() *CodeC

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

+ type Depth struct

+ Asks [][2]float64

+ Bids [][2]float64

+ PrevSeqNum int64

+ SeqNum int64

+ type MBPChannel struct

+ func (mc *MBPChannel) String() string

+ type MBPDepthDS struct

+ func NewMBPDepthDS(symbol exchange.Symbol) *MBPDepthDS

+ func (ds *MBPDepthDS) AddRefresh(d *Depth)

+ func (ds *MBPDepthDS) OrderBook(size int) *exchange.OrderBook

+ func (ds *MBPDepthDS) Push(d *Depth, ts time.Time) (inited bool, err error)

+ type MBPFullReq struct

+ ID string

+ Req string

+ func NewMBPFullReq(symbol exchange.Symbol, size int) *MBPFullReq

+ type MBPFullResp struct

+ Data Depth

+ ID string

+ Req string

+ Status string

+ TS int64

+ type MatchResultReq OrdersReq

+ func NewMatchResultReq(orderID string) *MatchResultReq

+ type OrderData struct

+ AccountID int64

+ Aggressor bool

+ ClientOrderID string

+ EventType string

+ ExecAmt string

+ LastActTime int64

+ OrderCreateTime int64

+ OrderID int64

+ OrderPrice string

+ OrderSize string

+ OrderSource string

+ OrderStatus string

+ OrderValue string

+ RemainAmt string

+ Symbol string

+ TradeID int64

+ TradePrice string

+ TradeTime int64

+ TradeVolume string

+ Type string

+ func (od *OrderData) Parse() (*exchange.Order, error)

+ type OrdersChannel struct

+ func NewOrdersChannel(sym string) *OrdersChannel

+ func (oc *OrdersChannel) String() string

+ type OrdersReq struct

+ OrderID string

+ func NewOrdersReq(orderID string) *OrdersReq

+ type OrdersResp struct

+ Data OrdersRespDetail

+ func (r *OrdersResp) Transform() (*exchange.Order, error)

+ type OrdersRespDetail struct

+ AccountID int64

+ Amount string

+ CanceledAt int64

+ CreatedAt int64

+ FilledAmount string

+ FilledCashAmount string

+ FilledFees string

+ FinishedAt int64

+ ID int64

+ Price string

+ Source string

+ State string

+ Symbol string

+ Type string

+ UserID int64

+ type PlaceReq struct

+ func NewPlaceReq(accountID string, symbol string, typ string, amount string) *PlaceReq

+ func (pr *PlaceReq) ClientOrderID(coi string) *PlaceReq

+ func (pr *PlaceReq) Operator(op string) *PlaceReq

+ func (pr *PlaceReq) Price(price string) *PlaceReq

+ func (pr *PlaceReq) Serialize() ([]byte, error)

+ func (pr *PlaceReq) Source(source string) *PlaceReq

+ func (pr *PlaceReq) StopPrice(sp string) *PlaceReq

+ type PlaceResp struct

+ Data string

+ ErrCode string

+ ErrMsg string

+ Status string

+ type PrivateCodeC struct

+ func NewPrivateCodeC() *PrivateCodeC

+ func (pcc *PrivateCodeC) Decode(raw []byte) (rpc.Response, error)

+ func (pcc *PrivateCodeC) Encode(req rpc.Request) ([]byte, error)

+ type PrivateWSClient struct

+ func NewPrivateWSClient(key, secret string, data chan interface{}) *PrivateWSClient

+ func (pws *PrivateWSClient) Auth(ctx context.Context) error

+ func (pws *PrivateWSClient) Handle(ctx context.Context, n *rpc.Notify)

+ func (pws *PrivateWSClient) Run(ctx context.Context) error

+ func (pws *PrivateWSClient) Subscribe(ctx context.Context, channels ...exchange.Channel) error

+ type PrivateWSReq struct

+ Action string

+ Ch string

+ Params interface{}

+ type PrivateWSResp struct

+ Action string

+ Ch string

+ Code int

+ Data json.RawMessage

type RestClient

+ func (rc *RestClient) Accounts(ctx context.Context) ([]Account, error)

+ func (rc *RestClient) FetchOrder(ctx context.Context, order *exchange.Order) (*exchange.Order, error)

+ func (rc *RestClient) MatchResult(ctx context.Context, req *MatchResultReq) ([]MatchResult, error)

+ func (rc *RestClient) Orders(ctx context.Context, req *OrdersReq) (*OrdersResp, error)

+ func (rc *RestClient) Place(ctx context.Context, req *PlaceReq) (*PlaceResp, error)

+ func (rc *RestClient) SubmitCancel(ctx context.Context, req *SubmitCancelReq) (*PlaceResp, error)

+ type SubmitCancelReq OrdersReq

+ func NewSubmitCancelReq(orderID string) *SubmitCancelReq

type Symbol

+ AmountPrecision int

+ MaxOrderAmt float64

+ MinOrderAmt float64

+ MinOrderValue float64

+ PricePrecision int

+ ValuePrecision int

+ type WSClient struct

+ func NewMBPWSClient(data chan interface{}) *WSClient

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

Jun 18, 2021

Changes in this version

+ const DirectNext

+ const DirectNone

+ const DirectPrev

+ const MatchResutEndPoint

+ const MatchRoleMaker

+ const MatchRoleTaker

+ const TransactFeeRateEndPoint

+ func Init(ctx context.Context) error

+ func ParseSymbol(symbol string) (exchange.SpotSymbol, error)

+ type Direct string

+ type MatchResult struct

+ CreatedAt int64

+ FeeCurrency string

+ FeeDeductCurrency string

+ FeeDeductState string

+ FilledAmount decimal.Decimal

+ FilledFees decimal.Decimal

+ FilledPoints decimal.Decimal

+ ID int64

+ MatchID int64

+ OrderID int64

+ Price decimal.Decimal

+ Role string

+ Source string

+ Symbol string

+ TradeID int64

+ Type string

+ func (mr *MatchResult) Parse() (*exchange.Trade, error)

type RestClient

+ func (rc *RestClient) FetchSymbols(ctx context.Context) ([]Symbol, error)

+ func (rc *RestClient) MatchResults(ctx context.Context, symbol string, types []string, st int64, et int64, ...) ([]MatchResult, error)

+ func (rc *RestClient) Symbols(ctx context.Context) ([]exchange.SpotSymbol, error)

+ func (rc *RestClient) Trades(ctx context.Context, req *exchange.TradeReqParam) ([]exchange.Trade, error)

+ func (rc *RestClient) TransactFeeRate(ctx context.Context, symbols []string) ([]TransactFeeRate, error)

type SpotSymbol

+ Symbol string

type Symbol

+ func (s *Symbol) Parse() (exchange.SpotSymbol, error)

type TransactFeeRate

+ ActualMakerRate decimal.Decimal

+ ActualTakerRate decimal.Decimal

+ func (tfr *TransactFeeRate) Parse() (*exchange.TradeFee, error)

Dec 2, 2020

Changes in this version

+ const SpotHost

+ type RestClient struct

+ func NewRestClient(key, secret string) *RestClient

+ func (rc *RestClient) FeeRate(ctx context.Context, syms ...exchange.Symbol) ([]exchange.TradeFee, error)

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

+ func (rc *RestClient) NewSpotSymbol(base, quote string) exchange.SpotSymbol

+ func (rc *RestClient) ParseSpotSymbol(pair string) (exchange.SpotSymbol, error)

+ type SpotSymbol struct

+ func (ss *SpotSymbol) String() string

+ type Symbol struct

+ BaseCurrency string

+ QuoteCurreny string

+ Symbol string

+ type SymbolResp struct

+ Data []Symbol

+ Status string

+ type TradeFeeResult struct

+ Code int

+ Data []TransactFeeRate

+ Success bool

+ type TransactFeeRate struct

+ ActualMakerFeeRate string

+ ActualTakerFeeRate string

+ MakerFeeRate string

+ Symbol string

+ TakerFeeRate string