binance

Documentation

Index

• Constants
• Variables
• func ErrorIs(err error, code int64) bool
• func StepSizeFormat(val decimal.Decimal, stepSize string) string
• type Client
  • func NewClient(l *log.Logger, cf *configfile.ConfigFile, eb *eventbus.Bus, ...) *Client
  • func (c *Client) Buy(ctx context.Context, coin, stableCoin string) (OrderResult, error)
  • func (c *Client) GetBalance(ctx context.Context, coins ...string) (map[string]decimal.Decimal, error)
  • func (c *Client) GetBalanceValue(ctx context.Context, altCoins []string) (map[string]decimal.Decimal, error)
  • func (c *Client) GetCoinsPrice(ctx context.Context, coins, altCoins []string) (map[string]CoinPrice, error)
  • func (c *Client) GetFee(ctx context.Context, symbol string) (decimal.Decimal, error)
  • func (c *Client) GetJumpFeeMultiplier(ctx context.Context, fromCoin, toCoin, bridge string) (decimal.Decimal, error)
  • func (c *Client) GetSymbolInfos(ctx context.Context, symbol string) (binance.Symbol, error)
  • func (c *Client) GetSymbolPrice(ctx context.Context, symbol string) (decimal.Decimal, error)
  • func (c *Client) GetSymbolPriceAtTime(ctx context.Context, coin, altCoin string, date time.Time) (CoinPrice, error)
  • func (c *Client) IsTradeInProgress() bool
  • func (c *Client) LogBalances(ctx context.Context)
  • func (c *Client) RefreshFees(ctx context.Context)
  • func (c *Client) RefreshSymbolInfos(ctx context.Context) (map[string]binance.Symbol, error)
  • func (c *Client) Sell(ctx context.Context, coin, stableCoin string) (OrderResult, error)
  • func (c *Client) Trade(ctx context.Context, coin, stableCoin string, side binance.SideType) (OrderResult, error)
  • func (c *Client) TradeLock() (func(), error)
  • func (c *Client) WaitForOrderCompletion(ctx context.Context, symbol string, orderId int64) (OrderResult, error)
• type CoinPrice
• type CoinPriceGroupByAlt
• type OrderResult
  • func (r OrderResult) IsPartiallyExecuted() bool
  • func (r OrderResult) Price() decimal.Decimal
  • func (r OrderResult) Quantity() decimal.Decimal
  • func (r OrderResult) Time() time.Time
• type SymbolBlackListGetter

Constants

const (
	BinanceErrorInvalidSymbol   int64 = -1121
	BinanceErrorInvalidQuantity int64 = -1013
)

Variables

var DefaultFee = decimal.NewFromFloat(0.998001)

var ErrNoPriceFoundAtTime = errors.New("no_price_found_at_time")

var InvalidFeeValue error = errors.New("can't find symbol fee")

Functions

func ErrorIs

func ErrorIs(err error, code int64) bool

func StepSizeFormat

func StepSizeFormat(val decimal.Decimal, stepSize string) string

Types

type Client

type Client struct {
	Logger          *log.Logger
	ConfigFile      *configfile.ConfigFile
	EventBus        *eventbus.Bus
	SymbolBlackList SymbolBlackListGetter
	// contains filtered or unexported fields
}

func NewClient

func NewClient(l *log.Logger, cf *configfile.ConfigFile, eb *eventbus.Bus, sbg SymbolBlackListGetter) *Client

func (*Client) Buy

func (c *Client) Buy(ctx context.Context, coin, stableCoin string) (OrderResult, error)

func (*Client) GetBalance

func (c *Client) GetBalance(ctx context.Context, coins ...string) (map[string]decimal.Decimal, error)

func (*Client) GetBalanceValue

func (c *Client) GetBalanceValue(ctx context.Context, altCoins []string) (map[string]decimal.Decimal, error)

func (*Client) GetCoinsPrice

func (c *Client) GetCoinsPrice(ctx context.Context, coins, altCoins []string) (map[string]CoinPrice, error)

func (*Client) GetFee

func (c *Client) GetFee(ctx context.Context, symbol string) (decimal.Decimal, error)

func (*Client) GetJumpFeeMultiplier

func (c *Client) GetJumpFeeMultiplier(ctx context.Context, fromCoin, toCoin, bridge string) (decimal.Decimal, error)

func (*Client) GetSymbolInfos

func (c *Client) GetSymbolInfos(ctx context.Context, symbol string) (binance.Symbol, error)

func (*Client) GetSymbolPrice

func (c *Client) GetSymbolPrice(ctx context.Context, symbol string) (decimal.Decimal, error)

func (*Client) GetSymbolPriceAtTime

func (c *Client) GetSymbolPriceAtTime(ctx context.Context, coin, altCoin string, date time.Time) (CoinPrice, error)

func (*Client) IsTradeInProgress

func (c *Client) IsTradeInProgress() bool

func (*Client) LogBalances

func (c *Client) LogBalances(ctx context.Context)

func (*Client) RefreshFees

func (c *Client) RefreshFees(ctx context.Context)

func (*Client) RefreshSymbolInfos

func (c *Client) RefreshSymbolInfos(ctx context.Context) (map[string]binance.Symbol, error)

func (*Client) Sell

func (c *Client) Sell(ctx context.Context, coin, stableCoin string) (OrderResult, error)

func (*Client) Trade

func (c *Client) Trade(ctx context.Context, coin, stableCoin string, side binance.SideType) (OrderResult, error)

Do not call this one directly, use .Buy() or .Sell()

func (*Client) TradeLock

func (c *Client) TradeLock() (func(), error)

return an error if a trade is in progress, otherwise return a release func to call when trade is over.

⚠️ Don't go concurrently too hard on this func, it's not concurrent safe, but that should be ok for our needs

func (*Client) WaitForOrderCompletion

func (c *Client) WaitForOrderCompletion(ctx context.Context, symbol string, orderId int64) (OrderResult, error)

type CoinPrice

type CoinPrice struct {
	Coin      string
	AltCoin   string
	Price     decimal.Decimal
	Timestamp time.Time
}

type CoinPriceGroupByAlt

type CoinPriceGroupByAlt struct {
	Coin   string
	Prices []CoinPrice
}

type OrderResult

type OrderResult struct {
	Order  *binance.Order
	Cancel *binance.CancelOrderResponse
}

func (OrderResult) IsPartiallyExecuted

func (r OrderResult) IsPartiallyExecuted() bool

func (OrderResult) Price

func (r OrderResult) Price() decimal.Decimal

func (OrderResult) Quantity

func (r OrderResult) Quantity() decimal.Decimal

func (OrderResult) Time

func (r OrderResult) Time() time.Time

type SymbolBlackListGetter

type SymbolBlackListGetter interface {
	IsSymbolBlacklisted(symbol string) bool
}