plugins

Feb 11, 2020

Changes in this version

+ const FiatErrorCodeAccountInactive

+ const FiatErrorCodeExhaustedAPIKey

+ const FiatErrorCodeInvalidAPIKey

+ func MakeFillDBWriter(db *sql.DB, assetDisplayFn model.AssetDisplayFn, exchangeName string) api.FillHandler

+ type BuySellConfig struct

+ AmountOfABase float64

+ AmountTolerance float64

+ DataFeedAURL string

+ DataFeedBURL string

+ DataTypeA string

+ DataTypeB string

+ Levels []StaticLevel

+ PriceTolerance float64

+ RateOffset float64

+ RateOffsetPercent float64

+ RateOffsetPercentFirst bool

+ func MakeBuysellConfig(priceTolerance float64, amountTolerance float64, rateOffsetPercent float64, ...) *BuySellConfig

+ func (c BuySellConfig) String() string

+ type ErrFiatAPI struct

+ Code int

+ Info string

+ Type string

+ func (e ErrFiatAPI) Error() string

+ type FillDBWriter struct

+ func (f *FillDBWriter) HandleFill(trade model.Trade) error

+ type FilterFactory struct

+ AssetDisplayFn model.AssetDisplayFn

+ BaseAsset hProtocol.Asset

+ DB *sql.DB

+ ExchangeName string

+ QuoteAsset hProtocol.Asset

+ TradingPair *model.TradingPair

+ func (f *FilterFactory) MakeFilter(configInput string) (SubmitFilter, error)

+ type MaxPriceFilterConfig struct

+ MaxPrice *float64

+ func (c *MaxPriceFilterConfig) String() string

+ func (c *MaxPriceFilterConfig) Validate() error

+ type MinPriceFilterConfig struct

+ MinPrice *float64

+ func (c *MinPriceFilterConfig) String() string

+ func (c *MinPriceFilterConfig) Validate() error

+ type StaticLevel struct

+ AMOUNT float64

+ SPREAD float64

type SubmitFilter

+ func MakeFilterMaxPrice(baseAsset hProtocol.Asset, quoteAsset hProtocol.Asset, ...) (SubmitFilter, error)

+ func MakeFilterMinPrice(baseAsset hProtocol.Asset, quoteAsset hProtocol.Asset, ...) (SubmitFilter, error)

+ func MakeFilterPriceFeed(baseAsset hProtocol.Asset, quoteAsset hProtocol.Asset, ...) (SubmitFilter, error)

+ type VolumeFilterConfig struct

+ SellBaseAssetCapInBaseUnits *float64

+ SellBaseAssetCapInQuoteUnits *float64

+ func (c *VolumeFilterConfig) String() string

+ func (c *VolumeFilterConfig) Validate() error

Apr 13, 2019

Changes in this version

type BatchedExchange

+ func (b BatchedExchange) OverrideOrderConstraints(pair *model.TradingPair, override *model.OrderConstraintsOverride)

+ type OrderConstraintsOverridesHandler struct

+ func MakeEmptyOrderConstraintsOverridesHandler() *OrderConstraintsOverridesHandler

+ func MakeOrderConstraintsOverridesHandler(inputs map[model.TradingPair]model.OrderConstraints) *OrderConstraintsOverridesHandler

+ func (ocHandler *OrderConstraintsOverridesHandler) Apply(pair *model.TradingPair, oc *model.OrderConstraints) *model.OrderConstraints

+ func (ocHandler *OrderConstraintsOverridesHandler) Get(pair *model.TradingPair) *model.OrderConstraintsOverride

+ func (ocHandler *OrderConstraintsOverridesHandler) IsCompletelyOverriden(pair *model.TradingPair) bool

+ func (ocHandler *OrderConstraintsOverridesHandler) Upsert(pair *model.TradingPair, override *model.OrderConstraintsOverride)

type SDEX

+ func (sdex *SDEX) OverrideOrderConstraints(pair *model.TradingPair, override *model.OrderConstraintsOverride)

Mar 29, 2019

Changes in this version

+ type BatchedExchange struct

+ func MakeBatchedExchange(inner api.Exchange, simMode bool, baseAsset horizon.Asset, ...) *BatchedExchange

+ func (b BatchedExchange) GetAccountBalances(assetList []interface{}) (map[interface{}]model.Number, error)

+ func (b BatchedExchange) GetBalanceHack(asset horizon.Asset) (*api.Balance, error)

+ func (b BatchedExchange) GetLatestTradeCursor() (interface{}, error)

+ func (b BatchedExchange) GetOpenOrders(pairs []*model.TradingPair) (map[model.TradingPair][]model.OpenOrder, error)

+ func (b BatchedExchange) GetOrderBook(pair *model.TradingPair, maxCount int32) (*model.OrderBook, error)

+ func (b BatchedExchange) GetOrderConstraints(pair *model.TradingPair) *model.OrderConstraints

+ func (b BatchedExchange) GetTradeHistory(pair model.TradingPair, maybeCursorStart interface{}, ...) (*api.TradeHistoryResult, error)

+ func (b BatchedExchange) LoadOffersHack() ([]horizon.Offer, error)

+ func (b BatchedExchange) OpenOrders2Offers(orders []model.OpenOrder, baseAsset horizon.Asset, quoteAsset horizon.Asset, ...) ([]hProtocol.Offer, error)

+ func (b BatchedExchange) Ops2Commands(ops []build.TransactionMutator, baseAsset horizon.Asset, ...) ([]Command, error)

+ func (b BatchedExchange) SubmitOps(ops []build.TransactionMutator, asyncCallback func(hash string, e error)) error

+ func (b BatchedExchange) SubmitOpsSynch(ops []build.TransactionMutator, asyncCallback func(hash string, e error)) error

+ type Command struct

+ func MakeCommandAdd(order *model.Order) Command

+ func MakeCommandCancel(openOrder *model.OpenOrder) Command

+ func Ops2CommandsHack(ops []build.TransactionMutator, baseAsset horizon.Asset, ...) ([]Command, error)

+ func (c *Command) GetAdd() (*model.Order, error)

+ func (c *Command) GetCancel() (*model.OpenOrder, error)

+ func (c *Command) GetOp() Operation

type ExchangeContainer

+ Tested bool

+ type IEIF struct

+ func MakeIEIF(isTradingSdex bool) *IEIF

+ func (ieif *IEIF) AddLiabilities(selling horizon.Asset, buying horizon.Asset, incrementalSell float64, ...)

+ func (ieif *IEIF) AvailableCapacity(asset horizon.Asset, incrementalNativeAmountRaw float64) (*Liabilities, error)

+ func (ieif *IEIF) GetAssetBalance(asset horizon.Asset) (*api.Balance, error)

+ func (ieif *IEIF) LogAllLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset)

+ func (ieif *IEIF) RecomputeAndLogCachedLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset)

+ func (ieif *IEIF) ResetCachedBalances()

+ func (ieif *IEIF) ResetCachedLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset) error

+ func (ieif *IEIF) SetExchangeShim(exchangeShim api.ExchangeShim)

+ type Operation int8

+ const OpAdd

+ const OpCancel

type SDEX

+ func (sdex *SDEX) GetAccountBalances(assetList []interface{}) (map[interface{}]model.Number, error)

+ func (sdex *SDEX) GetAssetConverter() *model.AssetConverter

+ func (sdex *SDEX) GetBalanceHack(asset horizon.Asset) (*api.Balance, error)

+ func (sdex *SDEX) IEIF() *IEIF

+ func (sdex *SDEX) LoadOffersHack() ([]horizon.Offer, error)

+ func (sdex *SDEX) SubmitOpsSynch(ops []build.TransactionMutator, asyncCallback func(hash string, e error)) error

type SubmitFilter

+ func MakeFilterMakerMode(submitMode api.SubmitMode, exchangeShim api.ExchangeShim, sdex *SDEX, ...) SubmitFilter

+ func MakeFilterOrderConstraints(oc *model.OrderConstraints, baseAsset horizon.Asset, quoteAsset horizon.Asset) SubmitFilter

Mar 5, 2019

Changes in this version

+ type OpFeeStroops func() (uint64, error)

+ func SdexFeeFnFromStats(horizonBaseURL string, capacityTrigger float64, percentile uint8, ...) (OpFeeStroops, error)

+ func SdexFixedFeeFn(fixedFeeStroops uint64) OpFeeStroops

Feb 6, 2019

Changes in this version

+ func SetPrivateSdexHack(api *horizon.Client, network build.Network) error

type SDEX

+ func (sdex *SDEX) Assets() (baseAsset horizon.Asset, quoteAsset horizon.Asset, e error)

+ func (sdex *SDEX) GetOrderBook(pair *model.TradingPair, maxCount int32) (*model.OrderBook, error)

+ type SubmitFilter interface

+ Apply func(ops []build.TransactionMutator, sellingOffers []horizon.Offer, ...) ([]build.TransactionMutator, error)

+ func MakeSubmitFilter(submitMode api.SubmitMode, sdex *SDEX, tradingPair *model.TradingPair) SubmitFilter

Jan 11, 2019

Changes in this version

+ func MakeFillLogger() api.FillHandler

+ func MakeFillTracker(pair *model.TradingPair, threadTracker *multithreading.ThreadTracker, ...) api.FillTracker

+ func MakeTradingExchange(exchangeType string, apiKeys []api.ExchangeAPIKey, simMode bool) (api.Exchange, error)

+ type ExchangeContainer struct

+ Description string

+ SortOrder uint8

+ TradeEnabled bool

+ type FillLogger struct

+ func (f *FillLogger) HandleFill(trade model.Trade) error

+ type FillTracker struct

+ func (f *FillTracker) GetPair() (pair *model.TradingPair)

+ func (f *FillTracker) NumHandlers() uint8

+ func (f *FillTracker) RegisterHandler(handler api.FillHandler)

+ func (f *FillTracker) TrackFills() error

type SDEX

+ func (sdex *SDEX) GetLatestTradeCursor() (interface{}, error)

+ func (sdex *SDEX) GetOrderConstraints(pair *model.TradingPair) *model.OrderConstraints

+ func (sdex *SDEX) GetTradeHistory(pair model.TradingPair, maybeCursorStart interface{}, ...) (*api.TradeHistoryResult, error)

Nov 27, 2018

Changes in this version

+ func MakeIntervalTimeController(tickInterval time.Duration) api.TimeController

+ type IntervalTimeController struct

+ func (t *IntervalTimeController) ShouldUpdate(lastUpdateTime time.Time, currentUpdateTime time.Time) bool

+ func (t *IntervalTimeController) SleepTime(lastUpdateTime time.Time, currentUpdateTime time.Time) time.Duration

Oct 15, 2018

Changes in this version

+ func Exchanges() map[string]string

+ func MakeExchange(exchangeType string) api.Exchange

+ func MakeFeedPair(dataTypeA, dataFeedAUrl, dataTypeB, dataFeedBUrl string) *api.FeedPair

+ func MakePriceFeed(feedType string, url string) api.PriceFeed

+ func MakeStrategy(sdex *SDEX, assetBase *horizon.Asset, assetQuote *horizon.Asset, ...) api.Strategy

+ func Strategies() map[string]StrategyContainer

+ type Balance struct

+ Balance float64

+ Reserve float64

+ Trust float64

+ type Liabilities struct

+ Buying float64

+ Selling float64

+ type SDEX struct

+ API *horizon.Client

+ Network build.Network

+ SourceAccount string

+ SourceSeed string

+ TradingAccount string

+ TradingSeed string

+ func MakeSDEX(api *horizon.Client, sourceSeed string, tradingSeed string, ...) *SDEX

+ func (sdex *SDEX) AddLiabilities(selling horizon.Asset, buying horizon.Asset, incrementalSell float64, ...)

+ func (sdex *SDEX) AvailableCapacity(asset horizon.Asset, incrementalNativeAmountRaw float64) (*Liabilities, error)

+ func (sdex *SDEX) ComputeIncrementalNativeAmountRaw(isNewOffer bool) float64

+ func (sdex *SDEX) CreateBuyOffer(base horizon.Asset, counter horizon.Asset, price float64, amount float64, ...) (*build.ManageOfferBuilder, error)

+ func (sdex *SDEX) CreateSellOffer(base horizon.Asset, counter horizon.Asset, price float64, amount float64, ...) (*build.ManageOfferBuilder, error)

+ func (sdex *SDEX) DeleteAllOffers(offers []horizon.Offer) []build.TransactionMutator

+ func (sdex *SDEX) DeleteOffer(offer horizon.Offer) build.ManageOfferBuilder

+ func (sdex *SDEX) LogAllLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset)

+ func (sdex *SDEX) ModifyBuyOffer(offer horizon.Offer, price float64, amount float64, ...) (*build.ManageOfferBuilder, error)

+ func (sdex *SDEX) ModifySellOffer(offer horizon.Offer, price float64, amount float64, ...) (*build.ManageOfferBuilder, error)

+ func (sdex *SDEX) ParseOfferAmount(amt string) (float64, error)

+ func (sdex *SDEX) RecomputeAndLogCachedLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset)

+ func (sdex *SDEX) ResetCachedBalances()

+ func (sdex *SDEX) ResetCachedLiabilities(assetBase horizon.Asset, assetQuote horizon.Asset) error

+ func (sdex *SDEX) SubmitOps(ops []build.TransactionMutator) error

+ type StrategyContainer struct

+ Complexity string

+ Description string

+ NeedsConfig bool

+ SortOrder uint8