oracle

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2022 License: Apache-2.0 Imports: 22 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ComputeTVWAP added in v0.1.2 

func ComputeTVWAP(prices provider.AggregatedProviderCandles) (map[string]sdk.Dec, error)

ComputeTVWAP computes the time volume weighted average price for all points for each exchange pair. Filters out any candles that did not occur within timePeriod. The provided prices argument reflects a mapping of provider => {<base> => <TickerPrice>, ...}.

Ref : https://en.wikipedia.org/wiki/Time-weighted_average_price

func ComputeVWAP 

func ComputeVWAP(prices provider.AggregatedProviderPrices) (map[string]sdk.Dec, error)

ComputeVWAP computes the volume weighted average price for all price points for each ticker/exchange pair. The provided prices argument reflects a mapping of provider => {<base> => <TickerPrice>, ...}.

Ref: https://en.wikipedia.org/wiki/Volume-weighted_average_price

func Connect 

func Connect(protoAddr string) (net.Conn, error)

Connect dials the given address and returns a net.Conn. The protoAddr argument should be prefixed with the protocol, eg. "tcp://127.0.0.1:8080" or "unix:///tmp/test.sock".

func FilterCandleDeviations added in v0.2.0 

func FilterCandleDeviations(
	logger zerolog.Logger,
	candles provider.AggregatedProviderCandles,
	deviationThresholds map[string]sdk.Dec,
) (provider.AggregatedProviderCandles, error)

FilterCandleDeviations finds the standard deviations of the tvwaps of all assets, and filters out any providers that are not within 2𝜎 of the mean.

func FilterTickerDeviations added in v0.2.0 

func FilterTickerDeviations(
	logger zerolog.Logger,
	prices provider.AggregatedProviderPrices,
	deviationThresholds map[string]sdk.Dec,
) (provider.AggregatedProviderPrices, error)

FilterTickerDeviations finds the standard deviations of the prices of all assets, and filters out any providers that are not within 2𝜎 of the mean.

func GenerateExchangeRatesString 

func GenerateExchangeRatesString(prices map[string]sdk.Dec) string

GenerateExchangeRatesString generates a canonical string representation of the aggregated exchange rates.

func GenerateSalt 

func GenerateSalt(length int) (string, error)

GenerateSalt generates a random salt, size length/2, as a HEX encoded string.

func GetComputedPrices added in v0.2.0 

func GetComputedPrices(
	logger zerolog.Logger,
	providerCandles provider.AggregatedProviderCandles,
	providerPrices provider.AggregatedProviderPrices,
	providerPairs map[provider.Name][]types.CurrencyPair,
	deviations map[string]sdk.Dec,
) (prices map[string]sdk.Dec, err error)

GetComputedPrices gets the candle and ticker prices and computes it. It returns candles' TVWAP if possible, if not possible (not available or due to some staleness) it will use the most recent ticker prices and the VWAP formula instead.

func NewProvider added in v0.1.3 

func NewProvider(
	ctx context.Context,
	providerName provider.Name,
	logger zerolog.Logger,
	endpoint provider.Endpoint,
	providerPairs ...types.CurrencyPair,
) (provider.Provider, error)

func ProtocolAndAddress 

func ProtocolAndAddress(listenAddr string) (string, string)

ProtocolAndAddress splits an address into the protocol and address components. For instance, "tcp://127.0.0.1:8080" will be split into "tcp" and "127.0.0.1:8080". If the address has no protocol prefix, the default is "tcp".

func SetProviderTickerPricesAndCandles added in v0.2.0 

func SetProviderTickerPricesAndCandles(
	providerName provider.Name,
	providerPrices provider.AggregatedProviderPrices,
	providerCandles provider.AggregatedProviderCandles,
	prices map[string]types.TickerPrice,
	candles map[string][]types.CandlePrice,
	pair types.CurrencyPair,
) (success bool)

SetProviderTickerPricesAndCandles flattens and collects prices for candles and tickers based on the base currency per provider. Returns true if at least one of price or candle exists.

func StandardDeviation added in v0.1.1 

func StandardDeviation(
	prices map[provider.Name]map[string]sdk.Dec,
) (map[string]sdk.Dec, map[string]sdk.Dec, error)

StandardDeviation returns maps of the standard deviations and means of assets. Will skip calculating for an asset if there are less than 3 prices.

Types

type Oracle 

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

Oracle implements the core component responsible for fetching exchange rates for a given set of currency pairs and determining the correct exchange rates to submit to the on-chain price oracle adhering the oracle specification.

func New 

func New(
	logger zerolog.Logger,
	oc client.OracleClient,
	currencyPairs []config.CurrencyPair,
	providerTimeout time.Duration,
	deviations map[string]sdk.Dec,
	endpoints map[provider.Name]provider.Endpoint,
) *Oracle

func (*Oracle) GetLastPriceSyncTimestamp 

func (o *Oracle) GetLastPriceSyncTimestamp() time.Time

GetLastPriceSyncTimestamp returns the latest timestamp at which prices where fetched from the oracle's set of exchange rate providers.

func (*Oracle) GetParamCache added in v0.2.2 

func (o *Oracle) GetParamCache(ctx context.Context, currentBlockHeigh int64) (oracletypes.Params, error)

GetParamCache returns the last updated parameters of the x/oracle module if the current ParamCache is outdated, we will query it again.

func (*Oracle) GetParams 

func (o *Oracle) GetParams(ctx context.Context) (oracletypes.Params, error)

GetParams returns the current on-chain parameters of the x/oracle module.

func (*Oracle) GetPrices 

func (o *Oracle) GetPrices() map[string]sdk.Dec

GetPrices returns a copy of the current prices fetched from the oracle's set of exchange rate providers.

func (*Oracle) SetPrices 

func (o *Oracle) SetPrices(ctx context.Context) error

SetPrices retrieves all the prices and candles from our set of providers as determined in the config. If candles are available, uses TVWAP in order to determine prices. If candles are not available, uses the most recent prices with VWAP. Warns the the user of any missing prices, and filters out any faulty providers which do not report prices or candles within 2𝜎 of the others.

func (*Oracle) Start 

func (o *Oracle) Start(ctx context.Context) error

Start starts the oracle process in a blocking fashion.

func (*Oracle) Stop 

func (o *Oracle) Stop()

Stop stops the oracle process and waits for it to gracefully exit.

type ParamCache added in v0.2.2 

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

ParamCache is used to cache oracle param data for an amount of blocks, defined by paramsCacheInterval.

func (*ParamCache) IsOutdated added in v0.2.2 

func (paramCache *ParamCache) IsOutdated(currentBlockHeigh int64) bool

IsOutdated checks whether or not the current param data was fetched in the last 200 blocks.

func (*ParamCache) Update added in v0.2.2 

func (paramCache *ParamCache) Update(currentBlockHeigh int64, params oracletypes.Params)

Update retrieves the most recent oracle params and updates the instance.

type PreviousPrevote 

type PreviousPrevote struct {
	ExchangeRates     string
	Salt              string
	SubmitBlockHeight int64
}

PreviousPrevote defines a structure for defining the previous prevote submitted on-chain.

func NewPreviousPrevote 

func NewPreviousPrevote() *PreviousPrevote

Source Files

View all Source files

Directories

Path Synopsis

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.