exchange

package
v0.0.24 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 31, 2022 License: MIT Imports: 17 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidQuantity   = errors.New("invalid quantity")
	ErrInsufficientFunds = errors.New("insufficient funds or locked")
	ErrInvalidAsset      = errors.New("invalid asset")
)
View Source 
var ErrInsufficientData = errors.New("insufficient data")

Functions

func CandleFromKline 

func CandleFromKline(pair string, k binance.Kline) model.Candle

func CandleFromWsKline 

func CandleFromWsKline(pair string, k binance.WsKline) model.Candle

func SplitAssetQuote 

func SplitAssetQuote(pair string) (asset string, quote string)

Types

type AssetQuote 

type AssetQuote struct {
	Quote string
	Asset string
}

type AssetValue added in v0.0.14 

type AssetValue struct {
	Time  time.Time
	Value float64
}

type Binance 

type Binance struct {
	APIKey    string
	APISecret string
	// contains filtered or unexported fields
}

func NewBinance 

func NewBinance(ctx context.Context, options ...BinanceOption) (*Binance, error)

func (*Binance) Account 

func (b *Binance) Account() (model.Account, error)

func (*Binance) AssetsInfo added in v0.0.18 

func (b *Binance) AssetsInfo(pair string) model.AssetInfo

func (*Binance) Cancel 

func (b *Binance) Cancel(order model.Order) error

func (*Binance) CandlesByLimit 

func (b *Binance) CandlesByLimit(ctx context.Context, pair, period string, limit int) ([]model.Candle, error)

func (*Binance) CandlesByPeriod 

func (b *Binance) CandlesByPeriod(ctx context.Context, pair, period string,
	start, end time.Time) ([]model.Candle, error)

func (*Binance) CandlesSubscription 

func (b *Binance) CandlesSubscription(ctx context.Context, pair, period string) (chan model.Candle, chan error)

func (*Binance) CreateOrderLimit 

func (b *Binance) CreateOrderLimit(side model.SideType, pair string,
	quantity float64, limit float64) (model.Order, error)

func (*Binance) CreateOrderMarket 

func (b *Binance) CreateOrderMarket(side model.SideType, pair string, quantity float64) (model.Order, error)

func (*Binance) CreateOrderMarketQuote 

func (b *Binance) CreateOrderMarketQuote(side model.SideType, pair string, quantity float64) (model.Order, error)

func (*Binance) CreateOrderOCO 

func (b *Binance) CreateOrderOCO(side model.SideType, pair string,
	quantity, price, stop, stopLimit float64) ([]model.Order, error)

func (*Binance) CreateOrderStop added in v0.0.24 

func (b *Binance) CreateOrderStop(pair string, quantity float64, limit float64) (model.Order, error)

func (*Binance) LastQuote added in v0.0.21 

func (b *Binance) LastQuote(ctx context.Context, pair string) (float64, error)

func (*Binance) Order 

func (b *Binance) Order(pair string, id int64) (model.Order, error)

func (*Binance) Orders 

func (b *Binance) Orders(pair string, limit int) ([]model.Order, error)

func (*Binance) Position 

func (b *Binance) Position(pair string) (asset, quote float64, err error)

type BinanceOption 

type BinanceOption func(*Binance)

func WithBinanceCredentials 

func WithBinanceCredentials(key, secret string) BinanceOption

type CSVFeed 

type CSVFeed struct {
	Feeds               map[string]PairFeed
	CandlePairTimeFrame map[string][]model.Candle
}

func NewCSVFeed 

func NewCSVFeed(targetTimeframe string, feeds ...PairFeed) (*CSVFeed, error)

func (CSVFeed) AssetsInfo added in v0.0.18 

func (c CSVFeed) AssetsInfo(pair string) model.AssetInfo

func (*CSVFeed) CandlesByLimit 

func (c *CSVFeed) CandlesByLimit(_ context.Context, pair, timeframe string, limit int) ([]model.Candle, error)

func (CSVFeed) CandlesByPeriod 

func (c CSVFeed) CandlesByPeriod(_ context.Context, pair, timeframe string,
	start, end time.Time) ([]model.Candle, error)

func (CSVFeed) CandlesSubscription 

func (c CSVFeed) CandlesSubscription(_ context.Context, pair, timeframe string) (chan model.Candle, chan error)

func (CSVFeed) LastQuote added in v0.0.21 

func (c CSVFeed) LastQuote(_ context.Context, _ string) (float64, error)

type DataFeed 

type DataFeed struct {
	Data chan model.Candle
	Err  chan error
}

type DataFeedConsumer 

type DataFeedConsumer func(model.Candle)

type DataFeedSubscription 

type DataFeedSubscription struct {
	Feeds                   *set.LinkedHashSetString
	DataFeeds               map[string]*DataFeed
	SubscriptionsByDataFeed map[string][]Subscription
	// contains filtered or unexported fields
}

func NewDataFeed 

func NewDataFeed(exchange service.Exchange) *DataFeedSubscription

func (*DataFeedSubscription) Connect 

func (d *DataFeedSubscription) Connect()

func (*DataFeedSubscription) Preload 

func (d *DataFeedSubscription) Preload(pair, timeframe string, candles []model.Candle)

func (*DataFeedSubscription) Start 

func (d *DataFeedSubscription) Start(loadSync bool)

func (*DataFeedSubscription) Subscribe 

func (d *DataFeedSubscription) Subscribe(pair, timeframe string, consumer DataFeedConsumer, onCandleClose bool)

type OrderError added in v0.0.23 

type OrderError struct {
	Err      error
	Pair     string
	Quantity float64
}

func (*OrderError) Error added in v0.0.23 

func (o *OrderError) Error() string

type PairFeed 

type PairFeed struct {
	Pair      string
	File      string
	Timeframe string
}

type PaperWallet 

type PaperWallet struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPaperWallet 

func NewPaperWallet(ctx context.Context, baseCoin string, options ...PaperWalletOption) *PaperWallet

func (*PaperWallet) Account 

func (p *PaperWallet) Account() (model.Account, error)

func (*PaperWallet) AssetValues added in v0.0.14 

func (p *PaperWallet) AssetValues(pair string) []AssetValue

func (*PaperWallet) AssetsInfo added in v0.0.18 

func (p *PaperWallet) AssetsInfo(pair string) model.AssetInfo

func (*PaperWallet) Cancel 

func (p *PaperWallet) Cancel(order model.Order) error

func (*PaperWallet) CandlesByLimit 

func (p *PaperWallet) CandlesByLimit(ctx context.Context, pair, period string, limit int) ([]model.Candle, error)

func (*PaperWallet) CandlesByPeriod 

func (p *PaperWallet) CandlesByPeriod(ctx context.Context, pair, period string,
	start, end time.Time) ([]model.Candle, error)

func (*PaperWallet) CandlesSubscription 

func (p *PaperWallet) CandlesSubscription(ctx context.Context, pair, timeframe string) (chan model.Candle, chan error)

func (*PaperWallet) CreateOrderLimit 

func (p *PaperWallet) CreateOrderLimit(side model.SideType, pair string,
	size float64, limit float64) (model.Order, error)

func (*PaperWallet) CreateOrderMarket 

func (p *PaperWallet) CreateOrderMarket(side model.SideType, pair string, size float64) (model.Order, error)

func (*PaperWallet) CreateOrderMarketQuote 

func (p *PaperWallet) CreateOrderMarketQuote(side model.SideType, pair string,
	quantity float64) (model.Order, error)

func (*PaperWallet) CreateOrderOCO 

func (p *PaperWallet) CreateOrderOCO(side model.SideType, pair string,
	size, price, stop, stopLimit float64) ([]model.Order, error)

func (*PaperWallet) CreateOrderStop added in v0.0.24 

func (p *PaperWallet) CreateOrderStop(pair string, size float64, limit float64) (model.Order, error)

func (*PaperWallet) EquityValues added in v0.0.14 

func (p *PaperWallet) EquityValues() []AssetValue

func (*PaperWallet) ID 

func (p *PaperWallet) ID() int64

func (*PaperWallet) LastQuote added in v0.0.21 

func (p *PaperWallet) LastQuote(ctx context.Context, pair string) (float64, error)

func (*PaperWallet) MaxDrawdown added in v0.0.14 

func (p *PaperWallet) MaxDrawdown() (float64, time.Time, time.Time)

func (*PaperWallet) OnCandle 

func (p *PaperWallet) OnCandle(candle model.Candle)

func (*PaperWallet) Order 

func (p *PaperWallet) Order(pair string, id int64) (model.Order, error)

func (*PaperWallet) Pairs added in v0.0.14 

func (p *PaperWallet) Pairs() []string

func (*PaperWallet) Position 

func (p *PaperWallet) Position(pair string) (asset, quote float64, err error)

func (*PaperWallet) Summary 

func (p *PaperWallet) Summary()

type PaperWalletOption 

type PaperWalletOption func(*PaperWallet)

func WithDataFeed 

func WithDataFeed(feeder service.Feeder) PaperWalletOption

func WithPaperAsset 

func WithPaperAsset(pair string, amount float64) PaperWalletOption

func WithPaperFee 

func WithPaperFee(maker, taker float64) PaperWalletOption

type Subscription 

type Subscription struct {
	// contains filtered or unexported fields
}

type UserInfo 

type UserInfo struct {
	MakerCommission float64
	TakerCommission float64
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.