batch

Documentation

Index

• type AsyncTimeRangedBatchQuery
  • func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, since, until time.Time) chan error
• type ClosedOrderBatchQuery
  • func (q *ClosedOrderBatchQuery) Query(ctx context.Context, symbol string, startTime, endTime time.Time, ...) (c chan types.Order, errC chan error)
• type DepositBatchQuery
  • func (e *DepositBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.Deposit, errC chan error)
• type KLineBatchQuery
  • func (e *KLineBatchQuery) Query(ctx context.Context, symbol string, interval types.Interval, ...) (c chan types.KLine, errC chan error)
• type MarginInterestBatchQuery
  • func (e *MarginInterestBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginInterest, errC chan error)
• type MarginLiquidationBatchQuery
  • func (e *MarginLiquidationBatchQuery) Query(ctx context.Context, startTime, endTime time.Time) (c chan types.MarginLiquidation, errC chan error)
• type MarginLoanBatchQuery
  • func (e *MarginLoanBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginLoan, errC chan error)
• type MarginRepayBatchQuery
  • func (e *MarginRepayBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginRepay, errC chan error)
• type RewardBatchQuery
  • func (q *RewardBatchQuery) Query(ctx context.Context, startTime, endTime time.Time) (c chan types.Reward, errC chan error)
• type TradeBatchQuery
  • func (e TradeBatchQuery) Query(ctx context.Context, symbol string, options *types.TradeQueryOptions) (c chan types.Trade, errC chan error)
• type WithdrawBatchQuery
  • func (e *WithdrawBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.Withdraw, errC chan error)

Types

type AsyncTimeRangedBatchQuery

type AsyncTimeRangedBatchQuery struct {
	// Type is the object type of the result
	Type interface{}

	// Limiter is the rate limiter for each query
	Limiter *rate.Limiter

	// Q is the remote query function
	Q func(startTime, endTime time.Time) (interface{}, error)

	// T function returns time of an object
	T func(obj interface{}) time.Time

	// ID returns the ID of the object
	ID func(obj interface{}) string

	// JumpIfEmpty jump the startTime + duration when the result is empty
	JumpIfEmpty time.Duration
}

func (*AsyncTimeRangedBatchQuery) Query

func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, since, until time.Time) chan error

type ClosedOrderBatchQuery

type ClosedOrderBatchQuery struct {
	types.ExchangeTradeHistoryService
}

func (*ClosedOrderBatchQuery) Query

func (q *ClosedOrderBatchQuery) Query(ctx context.Context, symbol string, startTime, endTime time.Time, lastOrderID uint64) (c chan types.Order, errC chan error)

type DepositBatchQuery

type DepositBatchQuery struct {
	types.ExchangeTransferService
}

func (*DepositBatchQuery) Query

func (e *DepositBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.Deposit, errC chan error)

type KLineBatchQuery

type KLineBatchQuery struct {
	types.Exchange
}

func (*KLineBatchQuery) Query

func (e *KLineBatchQuery) Query(ctx context.Context, symbol string, interval types.Interval, startTime, endTime time.Time) (c chan types.KLine, errC chan error)

type MarginInterestBatchQuery

type MarginInterestBatchQuery struct {
	types.MarginHistory
}

func (*MarginInterestBatchQuery) Query

func (e *MarginInterestBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginInterest, errC chan error)

type MarginLiquidationBatchQuery

type MarginLiquidationBatchQuery struct {
	types.MarginHistory
}

func (*MarginLiquidationBatchQuery) Query

func (e *MarginLiquidationBatchQuery) Query(ctx context.Context, startTime, endTime time.Time) (c chan types.MarginLiquidation, errC chan error)

type MarginLoanBatchQuery

type MarginLoanBatchQuery struct {
	types.MarginHistory
}

func (*MarginLoanBatchQuery) Query

func (e *MarginLoanBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginLoan, errC chan error)

type MarginRepayBatchQuery

type MarginRepayBatchQuery struct {
	types.MarginHistory
}

func (*MarginRepayBatchQuery) Query

func (e *MarginRepayBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.MarginRepay, errC chan error)

type RewardBatchQuery

type RewardBatchQuery struct {
	Service types.ExchangeRewardService
}

func (*RewardBatchQuery) Query

func (q *RewardBatchQuery) Query(ctx context.Context, startTime, endTime time.Time) (c chan types.Reward, errC chan error)

type TradeBatchQuery

type TradeBatchQuery struct {
	types.ExchangeTradeHistoryService
}

func (TradeBatchQuery) Query

func (e TradeBatchQuery) Query(ctx context.Context, symbol string, options *types.TradeQueryOptions) (c chan types.Trade, errC chan error)

type WithdrawBatchQuery

type WithdrawBatchQuery struct {
	types.ExchangeTransferService
}

func (*WithdrawBatchQuery) Query

func (e *WithdrawBatchQuery) Query(ctx context.Context, asset string, startTime, endTime time.Time) (c chan types.Withdraw, errC chan error)