market

Documentation

Index

• Constants
• type DataPerTokenAndCurrency
• type DataPoint
• type Manager
  • func NewManager(main thirdparty.MarketDataProvider, fallback thirdparty.MarketDataProvider, ...) *Manager
  • func (pm *Manager) FetchHistoricalDailyPrices(symbol string, currency string, limit int, allData bool, aggregate int) ([]thirdparty.HistoricalPrice, error)
  • func (pm *Manager) FetchHistoricalHourlyPrices(symbol string, currency string, limit int, aggregate int) ([]thirdparty.HistoricalPrice, error)
  • func (pm *Manager) FetchPrice(symbol string, currency string) (float64, error)
  • func (pm *Manager) FetchPrices(symbols []string, currencies []string) (map[string]map[string]float64, error)
  • func (pm *Manager) FetchTokenDetails(symbols []string) (map[string]thirdparty.TokenDetails, error)
  • func (pm *Manager) FetchTokenMarketValues(symbols []string, currency string) (map[string]thirdparty.TokenMarketValues, error)
  • func (pm *Manager) GetCachedPrices() DataPerTokenAndCurrency
  • func (pm *Manager) GetOrFetchPrices(symbols []string, currencies []string, maxAgeInSeconds int64) (DataPerTokenAndCurrency, error)

Constants

const (
	EventMarketStatusChanged walletevent.EventType = "wallet-market-status-changed"
)

Types

type DataPerTokenAndCurrency

type DataPerTokenAndCurrency = map[string]map[string]DataPoint

type DataPoint

type DataPoint struct {
	Price     float64
	UpdatedAt int64
}

type Manager

type Manager struct {
	IsConnected     bool
	LastCheckedAt   int64
	IsConnectedLock sync.RWMutex
	// contains filtered or unexported fields
}

func NewManager

func NewManager(main thirdparty.MarketDataProvider, fallback thirdparty.MarketDataProvider, feed *event.Feed) *Manager

func (*Manager) FetchHistoricalDailyPrices

func (pm *Manager) FetchHistoricalDailyPrices(symbol string, currency string, limit int, allData bool, aggregate int) ([]thirdparty.HistoricalPrice, error)

func (*Manager) FetchHistoricalHourlyPrices

func (pm *Manager) FetchHistoricalHourlyPrices(symbol string, currency string, limit int, aggregate int) ([]thirdparty.HistoricalPrice, error)

func (*Manager) FetchPrice

func (pm *Manager) FetchPrice(symbol string, currency string) (float64, error)

func (*Manager) FetchPrices

func (pm *Manager) FetchPrices(symbols []string, currencies []string) (map[string]map[string]float64, error)

func (*Manager) FetchTokenDetails

func (pm *Manager) FetchTokenDetails(symbols []string) (map[string]thirdparty.TokenDetails, error)

func (*Manager) FetchTokenMarketValues

func (pm *Manager) FetchTokenMarketValues(symbols []string, currency string) (map[string]thirdparty.TokenMarketValues, error)

func (*Manager) GetCachedPrices

func (pm *Manager) GetCachedPrices() DataPerTokenAndCurrency

func (*Manager) GetOrFetchPrices

func (pm *Manager) GetOrFetchPrices(symbols []string, currencies []string, maxAgeInSeconds int64) (DataPerTokenAndCurrency, error)

Return cached price if present in cache and age is less than maxAgeInSeconds. Fetch otherwise.