resolver

package
v1.4.478 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 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) GetNFT added in v1.4.2 

func (r *DiaResolver) GetNFT(ctx context.Context, args struct {
	Address    graphql.NullString
	Blockchain graphql.NullString
	TokenID    graphql.NullString
}) (*NFTResolver, error)

GetNFT returns an NFT by address, blockchain and token_id.

func (*DiaResolver) GetNFTBids added in v1.4.2 

func (r *DiaResolver) GetNFTBids(ctx context.Context, args struct {
	Address    graphql.NullString
	Blockchain graphql.NullString
	TokenID    graphql.NullString
}) (*[]*NFTBidResolver, error)

GetNFTOffers returns offers of an NFT by address, blockchain, token_id and time range

func (*DiaResolver) GetNFTOffers added in v1.4.2 

func (r *DiaResolver) GetNFTOffers(ctx context.Context, args struct {
	Address    graphql.NullString
	Blockchain graphql.NullString
	TokenID    graphql.NullString
}) (*[]*NFTOfferResolver, error)

GetNFTOffers returns offers of an NFT by address, blockchain, token_id and time range

func (*DiaResolver) GetNFTTrades added in v1.4.2 

func (r *DiaResolver) GetNFTTrades(ctx context.Context, args struct {
	Address    graphql.NullString
	Blockchain graphql.NullString
	TokenID    graphql.NullString
}) (*[]*NFTTradeResolver, error)

GetNFTTrades returns trades of an NFT by address, blockchain, token_id and time range

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 NFTBidResolver added in v1.4.2 

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

func (*NFTBidResolver) Address added in v1.4.2 

func (br *NFTBidResolver) Address(ctx context.Context) (*string, error)

func (*NFTBidResolver) BidValue added in v1.4.2 

func (br *NFTBidResolver) BidValue(ctx context.Context) (*string, error)

func (*NFTBidResolver) Blockchain added in v1.4.2 

func (br *NFTBidResolver) Blockchain(ctx context.Context) (*string, error)

func (*NFTBidResolver) Blocknumber added in v1.4.2 

func (br *NFTBidResolver) Blocknumber(ctx context.Context) (*int32, error)

func (*NFTBidResolver) CurrencyAddress added in v1.4.2 

func (br *NFTBidResolver) CurrencyAddress(ctx context.Context) (*string, error)

func (*NFTBidResolver) CurrencyDecimals added in v1.4.2 

func (br *NFTBidResolver) CurrencyDecimals(ctx context.Context) (*int32, error)

func (*NFTBidResolver) CurrencySymbol added in v1.4.2 

func (br *NFTBidResolver) CurrencySymbol(ctx context.Context) (*string, error)

func (*NFTBidResolver) Exchange added in v1.4.2 

func (br *NFTBidResolver) Exchange(ctx context.Context) (*string, error)

func (*NFTBidResolver) FromAddress added in v1.4.2 

func (br *NFTBidResolver) FromAddress(ctx context.Context) (*string, error)

func (*NFTBidResolver) Timestamp added in v1.4.2 

func (br *NFTBidResolver) Timestamp(ctx context.Context) (*graphql.Time, error)

func (*NFTBidResolver) TokenID added in v1.4.2 

func (br *NFTBidResolver) TokenID(ctx context.Context) (*string, error)

func (*NFTBidResolver) TxHash added in v1.4.2 

func (br *NFTBidResolver) TxHash(ctx context.Context) (*string, error)

type NFTOfferResolver added in v1.4.2 

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

func (*NFTOfferResolver) Address added in v1.4.2 

func (or *NFTOfferResolver) Address(ctx context.Context) (*string, error)

func (*NFTOfferResolver) AuctionType added in v1.4.2 

func (or *NFTOfferResolver) AuctionType(ctx context.Context) (*string, error)

func (*NFTOfferResolver) Blockchain added in v1.4.2 

func (or *NFTOfferResolver) Blockchain(ctx context.Context) (*string, error)

func (*NFTOfferResolver) Blocknumber added in v1.4.2 

func (or *NFTOfferResolver) Blocknumber(ctx context.Context) (*int32, error)

func (*NFTOfferResolver) CurrencyAddress added in v1.4.2 

func (or *NFTOfferResolver) CurrencyAddress(ctx context.Context) (*string, error)

func (*NFTOfferResolver) CurrencyDecimals added in v1.4.2 

func (or *NFTOfferResolver) CurrencyDecimals(ctx context.Context) (*int32, error)

func (*NFTOfferResolver) CurrencySymbol added in v1.4.2 

func (or *NFTOfferResolver) CurrencySymbol(ctx context.Context) (*string, error)

func (*NFTOfferResolver) Duration added in v1.4.2 

func (or *NFTOfferResolver) Duration(ctx context.Context) (*int32, error)

func (*NFTOfferResolver) EndValue added in v1.4.2 

func (or *NFTOfferResolver) EndValue(ctx context.Context) (*string, error)

func (*NFTOfferResolver) Exchange added in v1.4.2 

func (or *NFTOfferResolver) Exchange(ctx context.Context) (*string, error)

func (*NFTOfferResolver) FromAddress added in v1.4.2 

func (or *NFTOfferResolver) FromAddress(ctx context.Context) (*string, error)

func (*NFTOfferResolver) StartValue added in v1.4.2 

func (or *NFTOfferResolver) StartValue(ctx context.Context) (*string, error)

func (*NFTOfferResolver) Timestamp added in v1.4.2 

func (or *NFTOfferResolver) Timestamp(ctx context.Context) (*graphql.Time, error)

func (*NFTOfferResolver) TokenID added in v1.4.2 

func (or *NFTOfferResolver) TokenID(ctx context.Context) (*string, error)

func (*NFTOfferResolver) TxHash added in v1.4.2 

func (or *NFTOfferResolver) TxHash(ctx context.Context) (*string, error)

type NFTResolver added in v1.4.2 

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

func (*NFTResolver) Address added in v1.4.2 

func (nr *NFTResolver) Address(ctx context.Context) (*string, error)

func (*NFTResolver) Blockchain added in v1.4.2 

func (nr *NFTResolver) Blockchain(ctx context.Context) (*string, error)

func (*NFTResolver) CreationTime added in v1.4.2 

func (nr *NFTResolver) CreationTime(ctx context.Context) (*graphql.Time, error)

func (*NFTResolver) CreatorAddress added in v1.4.2 

func (nr *NFTResolver) CreatorAddress(ctx context.Context) (*string, error)

func (*NFTResolver) TokenID added in v1.4.2 

func (nr *NFTResolver) TokenID(ctx context.Context) (*string, error)

func (*NFTResolver) URI added in v1.4.2 

func (nr *NFTResolver) URI(ctx context.Context) (*string, error)

type NFTTradeResolver added in v1.4.2 

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

func (*NFTTradeResolver) Address added in v1.4.2 

func (tr *NFTTradeResolver) Address(ctx context.Context) (*string, error)

func (*NFTTradeResolver) Blockchain added in v1.4.2 

func (tr *NFTTradeResolver) Blockchain(ctx context.Context) (*string, error)

func (*NFTTradeResolver) Blocknumber added in v1.4.2 

func (tr *NFTTradeResolver) Blocknumber(ctx context.Context) (*int32, error)

func (*NFTTradeResolver) CurrencyAddress added in v1.4.2 

func (tr *NFTTradeResolver) CurrencyAddress(ctx context.Context) (*string, error)

func (*NFTTradeResolver) CurrencyDecimals added in v1.4.2 

func (tr *NFTTradeResolver) CurrencyDecimals(ctx context.Context) (*int32, error)

func (*NFTTradeResolver) CurrencySymbol added in v1.4.2 

func (tr *NFTTradeResolver) CurrencySymbol(ctx context.Context) (*string, error)

func (*NFTTradeResolver) Exchange added in v1.4.2 

func (tr *NFTTradeResolver) Exchange(ctx context.Context) (*string, error)

func (*NFTTradeResolver) FromAddress added in v1.4.2 

func (tr *NFTTradeResolver) FromAddress(ctx context.Context) (*string, error)

func (*NFTTradeResolver) Price added in v1.4.2 

func (tr *NFTTradeResolver) Price(ctx context.Context) (*string, error)

func (*NFTTradeResolver) Timestamp added in v1.4.2 

func (tr *NFTTradeResolver) Timestamp(ctx context.Context) (*graphql.Time, error)

func (*NFTTradeResolver) ToAddress added in v1.4.2 

func (tr *NFTTradeResolver) ToAddress(ctx context.Context) (*string, error)

func (*NFTTradeResolver) TokenID added in v1.4.2 

func (tr *NFTTradeResolver) TokenID(ctx context.Context) (*string, error)

func (*NFTTradeResolver) TxHash added in v1.4.2 

func (tr *NFTTradeResolver) TxHash(ctx context.Context) (*string, 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.