utils

Documentation

Index

• Variables
• func CalcNotionalAmount(amount *big.Int, decimals uint8, price float64) *big.Float
• func FetchCoinGeckoCoins()
• func FetchCoinGeckoPrice(coinId string, timestamp time.Time) (float64, error)
• func FetchTokenPrices(ctx context.Context, coinIds []string) (map[string]float64, error)
• type CoinGeckoCoin
  • func FetchCoinGeckoCoin(chainId vaa.ChainID, symbol, name string) *CoinGeckoCoin
• type CoinGeckoCoinPrices
• type CoinGeckoErrorRes
• type CoinGeckoMarket
• type CoinGeckoMarketRes
• type Price
• type RateLimitClient
  • func NewRateLimitClient(limiter *rate.Limiter) *RateLimitClient
  • func (c *RateLimitClient) Do(ctx context.Context, req *http.Request) (*http.Response, error)

Variables

var CoinGeckoCoins map[string][]CoinGeckoCoin

var DefaultLimiter = rate.NewLimiter(rate.Every(time.Second), 3)

var DefaultRateLimitClient = NewRateLimitClient(DefaultLimiter)

Functions

func CalcNotionalAmount

func CalcNotionalAmount(amount *big.Int, decimals uint8, price float64) *big.Float

func FetchCoinGeckoCoins

func FetchCoinGeckoCoins()

func FetchCoinGeckoPrice

func FetchCoinGeckoPrice(coinId string, timestamp time.Time) (float64, error)

func FetchTokenPrices

func FetchTokenPrices(ctx context.Context, coinIds []string) (map[string]float64, error)

Types

type CoinGeckoCoin

type CoinGeckoCoin struct {
	Id     string `json:"id"`
	Symbol string `json:"symbol"`
	Name   string `json:"name"`
}

func FetchCoinGeckoCoin

func FetchCoinGeckoCoin(chainId vaa.ChainID, symbol, name string) *CoinGeckoCoin

type CoinGeckoCoinPrices

type CoinGeckoCoinPrices map[string]Price

type CoinGeckoErrorRes

type CoinGeckoErrorRes struct {
	Error string `json:"error"`
}

type CoinGeckoMarket

type CoinGeckoMarket [2]float64

type CoinGeckoMarketRes

type CoinGeckoMarketRes struct {
	Prices []CoinGeckoMarket `json:"prices"`
}

type Price

type Price struct {
	USD float64 `json:"usd"`
}

type RateLimitClient

type RateLimitClient struct {
	Ratelimiter *rate.Limiter
	// contains filtered or unexported fields
}

func NewRateLimitClient

func NewRateLimitClient(limiter *rate.Limiter) *RateLimitClient

func (*RateLimitClient) Do

func (c *RateLimitClient) Do(ctx context.Context, req *http.Request) (*http.Response, error)