resolver

package
v1.4.569 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2025 License: GPL-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PAIR_SEPARATOR                 = "-"
	LIST_SEPARATOR                 = ","
	TRADE_VOLUME_THRESHOLD_DEFAULT = float64(0.001)
)

Variables

View Source 
var (
	EXCHANGES   = scrapers.Exchanges
	BLOCKCHAINS = scrapers.Blockchains

	EXCHANGESYMBOL_CACHE = make(map[string]dia.Asset)
)

Functions

This section is empty.

Types

type Asset added in v1.4.305 

type Asset struct {
	Address    graphql.NullString
	BlockChain graphql.NullString
}

type DiaResolver 

type DiaResolver struct {
	DS              models.DB
	RelDB           models.RelDB
	InfluxBatchSize int64
}

Resolver is the root resolver

func (*DiaResolver) GetAssetByExchangesymbol added in v1.4.461 

func (r *DiaResolver) GetAssetByExchangesymbol(exchange string, symbol string) (dia.Asset, error)

GetAssetByExchangesymbol is a poor man's cache that returns the underlying asset given a @symbol on @exchange.

func (*DiaResolver) GetChart 

func (r *DiaResolver) GetChart(ctx context.Context, args struct {
	Filter               graphql.NullString
	BlockDurationSeconds graphql.NullInt
	BlockShiftSeconds    graphql.NullInt
	Symbol               graphql.NullString
	StartTime            graphql.NullTime
	EndTime              graphql.NullTime
	Exchanges            *[]graphql.NullString
	Address              graphql.NullString
	BlockChain           graphql.NullString
	BaseAsset            *[]Asset
}) (*[]*FilterPointResolver, error)

func (*DiaResolver) GetChartMeta added in v1.4.2 

func (r *DiaResolver) GetChartMeta(ctx context.Context, args struct {
	Filter               graphql.NullString
	BlockDurationSeconds graphql.NullInt
	BlockShiftSeconds    graphql.NullInt
	Symbol               graphql.NullString
	StartTime            graphql.NullTime
	EndTime              graphql.NullTime
	Exchanges            *[]graphql.NullString
	Address              graphql.NullString
	BlockChain           graphql.NullString
	BaseAsset            *[]Asset
}) (*FilterPointMetaResolver, error)

TO DO: Use context?

func (*DiaResolver) GetFeed added in v1.4.305 

func (r *DiaResolver) GetFeed(ctx context.Context, args struct {
	Filter               graphql.NullString
	BlockSizeSeconds     graphql.NullInt
	BlockShiftSeconds    graphql.NullInt
	StartTime            graphql.NullTime
	EndTime              graphql.NullTime
	TradeVolumeThreshold graphql.NullFloat
	NativeDenomination   graphql.NullBool
	FeedSelection        *[]FeedSelection
}) (*[]*FilterPointExtendedResolver, error)

TO DO: Use context?

func (*DiaResolver) GetFeedAggregation added in v1.4.429 

func (r *DiaResolver) GetFeedAggregation(ctx context.Context, args struct {
	StartTime            graphql.NullTime
	EndTime              graphql.NullTime
	TradeVolumeThreshold graphql.NullFloat
	FeedSelection        *[]FeedSelection
}) (*[]*FeedSelectionAggregatedResolver, error)

GetFeedAggregation computes stats such as volume and number of trades fo a given FeedSelection.

func (*DiaResolver) GetSupplies 

func (r *DiaResolver) GetSupplies(ctx context.Context, args struct{ Symbol graphql.NullString }) (*[]*SupplyResolver, error)

func (*DiaResolver) GetSupply 

func (r *DiaResolver) GetSupply(ctx context.Context, args struct{ Symbol graphql.NullString }) (*SupplyResolver, error)

func (*DiaResolver) GetVWALP added in v1.4.2 

func (r *DiaResolver) GetVWALP(ctx context.Context, args struct {
	Quotetokenblockchain graphql.NullString
	Quotetokenaddress    graphql.NullString
	BaseAssets           *[]Asset
	Exchanges            *[]graphql.NullString
	BlockDurationSeconds graphql.NullInt
	EndTime              graphql.NullTime
	BasisPoints          graphql.NullInt
}) (*VWALPResolver, error)

func (*DiaResolver) GetxcFeed added in v1.4.258 

func (r *DiaResolver) GetxcFeed(ctx context.Context, args struct {
	Filter            graphql.NullString
	QuoteAssets       *[]Asset
	Exchanges         *[]graphql.NullString
	BlockSizeSeconds  graphql.NullInt
	BlockShiftSeconds graphql.NullInt
	StartTime         graphql.NullTime
	EndTime           graphql.NullTime
}) (*[]*FilterPointResolver, error)

GetxcFeed returns filter points for a (possibly) cross chain feed given by @QuoteAssets.

type Exchangepair added in v1.4.305 

type Exchangepair struct {
	Exchange           graphql.NullString
	Pairs              *[]graphql.NullString
	LiquidityThreshold graphql.NullFloat
}

type FeedSelection added in v1.4.305 

type FeedSelection struct {
	Address            graphql.NullString
	Blockchain         graphql.NullString
	LiquidityThreshold graphql.NullFloat
	Exchangepairs      *[]Exchangepair
}

type FeedSelectionAggregatedResolver added in v1.4.429 

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

func (*FeedSelectionAggregatedResolver) Basetokenaddress added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Basetokenaddress(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Basetokenblockchain added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Basetokenblockchain(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Basetokensymbol added in v1.4.433 

func (qr *FeedSelectionAggregatedResolver) Basetokensymbol(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Exchange added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Exchange(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) LastPrice added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) LastPrice(ctx context.Context) (*float64, error)

func (*FeedSelectionAggregatedResolver) PoolLiquidityUSD added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) PoolLiquidityUSD(ctx context.Context) (*float64, error)

func (*FeedSelectionAggregatedResolver) Pooladdress added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Pooladdress(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Quotetokenaddress added in v1.4.433 

func (qr *FeedSelectionAggregatedResolver) Quotetokenaddress(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Quotetokenblockchain added in v1.4.433 

func (qr *FeedSelectionAggregatedResolver) Quotetokenblockchain(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Quotetokensymbol added in v1.4.433 

func (qr *FeedSelectionAggregatedResolver) Quotetokensymbol(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) StatusCode added in v1.4.451 

func (qr *FeedSelectionAggregatedResolver) StatusCode(ctx context.Context) (*int32, error)

func (*FeedSelectionAggregatedResolver) StatusMessage added in v1.4.451 

func (qr *FeedSelectionAggregatedResolver) StatusMessage(ctx context.Context) (*string, error)

func (*FeedSelectionAggregatedResolver) Time added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Time(ctx context.Context) (*graphql.Time, error)

func (*FeedSelectionAggregatedResolver) TradesCount added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) TradesCount(ctx context.Context) (*int32, error)

func (*FeedSelectionAggregatedResolver) Volume added in v1.4.429 

func (qr *FeedSelectionAggregatedResolver) Volume(ctx context.Context) (*float64, error)

type FilterPointExtendedResolver added in v1.4.310 

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

func (*FilterPointExtendedResolver) Name added in v1.4.310 

func (qr *FilterPointExtendedResolver) Name(ctx context.Context) (*string, error)

func (*FilterPointExtendedResolver) Pairs added in v1.4.310 

func (qr *FilterPointExtendedResolver) Pairs(ctx context.Context) (*[]string, error)

func (*FilterPointExtendedResolver) Pools added in v1.4.310 

func (qr *FilterPointExtendedResolver) Pools(ctx context.Context) (*[]string, error)

func (*FilterPointExtendedResolver) StatusCode added in v1.4.451 

func (qr *FilterPointExtendedResolver) StatusCode(ctx context.Context) (*int32, error)

func (*FilterPointExtendedResolver) StatusMessage added in v1.4.451 

func (qr *FilterPointExtendedResolver) StatusMessage(ctx context.Context) (*string, error)

func (*FilterPointExtendedResolver) Symbol added in v1.4.310 

func (qr *FilterPointExtendedResolver) Symbol(ctx context.Context) (*string, error)

func (*FilterPointExtendedResolver) Time added in v1.4.310 

func (qr *FilterPointExtendedResolver) Time(ctx context.Context) (*graphql.Time, error)

func (*FilterPointExtendedResolver) TradesCount added in v1.4.310 

func (qr *FilterPointExtendedResolver) TradesCount(ctx context.Context) (*int32, error)

func (*FilterPointExtendedResolver) Value added in v1.4.310 

func (qr *FilterPointExtendedResolver) Value(ctx context.Context) (*float64, error)

type FilterPointMetaResolver added in v1.4.2 

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

func (*FilterPointMetaResolver) Max added in v1.4.2 

func (qr *FilterPointMetaResolver) Max(ctx context.Context) (*float64, error)

func (*FilterPointMetaResolver) Min added in v1.4.2 

func (qr *FilterPointMetaResolver) Min(ctx context.Context) (*float64, error)

func (*FilterPointMetaResolver) Points added in v1.4.2 

func (qr *FilterPointMetaResolver) Points(ctx context.Context) (*[]*FilterPointResolver, error)

type FilterPointResolver 

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

func (*FilterPointResolver) Address 

func (qr *FilterPointResolver) Address(ctx context.Context) (*string, error)

func (*FilterPointResolver) Blockchain 

func (qr *FilterPointResolver) Blockchain(ctx context.Context) (*string, error)

func (*FilterPointResolver) FirstTrade added in v1.4.2 

func (qr *FilterPointResolver) FirstTrade(ctx context.Context) (*TradeResolver, error)

func (*FilterPointResolver) LastTrade added in v1.4.2 

func (qr *FilterPointResolver) LastTrade(ctx context.Context) (*TradeResolver, error)

func (*FilterPointResolver) Name 

func (qr *FilterPointResolver) Name(ctx context.Context) (*string, error)

func (*FilterPointResolver) Symbol 

func (qr *FilterPointResolver) Symbol(ctx context.Context) (*string, error)

func (*FilterPointResolver) Time 

func (qr *FilterPointResolver) Time(ctx context.Context) (*graphql.Time, error)

func (*FilterPointResolver) Value 

func (qr *FilterPointResolver) Value(ctx context.Context) (*float64, error)

type SupplyResolver 

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

func (*SupplyResolver) CirculatingSupply 

func (qr *SupplyResolver) CirculatingSupply(ctx context.Context) (*float64, error)

func (*SupplyResolver) MA 

func (qr *SupplyResolver) MA(ctx context.Context) (*graphql.Time, error)

func (*SupplyResolver) Name 

func (qr *SupplyResolver) Name(ctx context.Context) (*string, error)

func (*SupplyResolver) Source 

func (qr *SupplyResolver) Source(ctx context.Context) (*string, error)

func (*SupplyResolver) Supply 

func (qr *SupplyResolver) Supply(ctx context.Context) (*float64, error)

func (*SupplyResolver) Symbol 

func (qr *SupplyResolver) Symbol(ctx context.Context) (*string, error)

func (*SupplyResolver) Time 

func (qr *SupplyResolver) Time(ctx context.Context) (*graphql.Time, error)

type TradeBlock 

type TradeBlock struct {
	Trades []dia.Trade
}

type TradeResolver added in v1.4.2 

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

func (*TradeResolver) EstimatedUSDPrice added in v1.4.2 

func (qr *TradeResolver) EstimatedUSDPrice(ctx context.Context) (*float64, error)

func (*TradeResolver) Pair added in v1.4.2 

func (qr *TradeResolver) Pair(ctx context.Context) (*string, error)

func (*TradeResolver) Price added in v1.4.2 

func (qr *TradeResolver) Price(ctx context.Context) (*float64, error)

func (*TradeResolver) Symbol added in v1.4.2 

func (qr *TradeResolver) Symbol(ctx context.Context) (*string, error)

func (*TradeResolver) Volume added in v1.4.2 

func (qr *TradeResolver) Volume(ctx context.Context) (*float64, error)

type VWALPResolver added in v1.4.2 

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

func (*VWALPResolver) Symbol added in v1.4.2 

func (vr *VWALPResolver) Symbol(ctx context.Context) (*string, error)

func (*VWALPResolver) Time added in v1.4.2 

func (vr *VWALPResolver) Time(ctx context.Context) (*graphql.Time, error)

func (*VWALPResolver) Value added in v1.4.2 

func (vr *VWALPResolver) Value(ctx context.Context) (*float64, error)

Source Files

View all Source files

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.