fetcher

type Blockchain interface {
	FetchBalanceData(addr ethereum.Address, timepoint uint64) (map[string]common.BalanceEntry, error)
	FetchRates(sources, dests []common.Token, timepoint uint64) (common.AllRateEntry, error)
	IsMined(tx ethereum.Hash) (bool, error)
}

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

type Exchange interface {
	ID() common.ExchangeID
	Name() string
	TokenPairs() []common.TokenPair
	FetchPriceData(timepoint uint64) (map[common.TokenPairID]common.ExchangePrice, error)
	FetchEBalanceData(timepoint uint64) (common.EBalanceEntry, error)
	FetchOrderData(timepoint uint64) (common.OrderEntry, error)
	OrderStatus(id common.ActivityID, timepoint uint64) (string, error)
	DepositStatus(id common.ActivityID, timepoint uint64) (string, error)
	WithdrawStatus(id common.ActivityID, timepoint uint64) (string, error)
}

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

type FetcherRunner interface {
	GetExchangeTicker() <-chan time.Time
	GetBlockchainTicker() <-chan time.Time
	// Start must be non-blocking and must only return after runner
	// gets to ready state before GetExchangeTicker() and
	// GetBlockchainTicker() get called
	Start() error
	// Stop should only be invoked when the runner is already running
	Stop() error
}

type Storage interface {
	StorePrice(data map[common.TokenPairID]common.OnePrice, timepoint uint64) error
	StoreBalance(data map[string]common.BalanceEntry, timepoint uint64) error
	StoreEBalance(data map[common.ExchangeID]common.EBalanceEntry, timepoint uint64) error
	StoreRate(data common.AllRateEntry, timepoint uint64) error

	GetPendingActivities() ([]common.ActivityRecord, error)
	UpdateActivityStatus(action string, id common.ActivityID, destination string, status string) error
}

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

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