graph

Documentation

Overview

Package graph implements the GraphQL schema and resolvers.

Index

• func GenerateAmountStatisticBridgeSQL(typeArg model.StatisticType, address *string, chainID *int, ...) (*string, error)
• func GenerateAmountStatisticMessageBusSQL(typeArg model.StatisticType, compositeFilters string) (*string, error)
• func GenerateAmountStatisticSwapSQL(typeArg model.StatisticType, compositeFilters string, tokenAddress *string) (*string, error)
• func GenerateDailyStatisticByChainAllSQL(typeArg *model.DailyStatisticType, compositeFilters string, firstFilter *bool) (*string, error)
• func GenerateDailyStatisticByChainAllSQLMv(typeArg *model.DailyStatisticType, compositeFilters string, ...) (*string, error)
• func GenerateDailyStatisticByChainBridgeSQL(typeArg *model.DailyStatisticType, compositeFilters string, firstFilter *bool) (*string, error)
• func GenerateDailyStatisticByChainBridgeSQLMv(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)
• func GenerateDailyStatisticByChainMessageBusSQL(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)
• func GenerateDailyStatisticByChainSwapSQL(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)
• func GenerateRankedChainsByVolumeSQL(compositeFilters string, firstFilter *bool) string
• func GetDurationFilter(duration *model.Duration, firstFilter *bool, prefix string) string
• func GetFallbackTime() time.Duration
• func GetPartialInfoFromBridgeEventHybrid(bridgeEvent sql.HybridBridgeEvent, includePending *bool) (*model.BridgeTransaction, error)
• func GetPartialInfoFromMessageBusEventHybrid(ctx context.Context, messageBusEvent sql.HybridMessageBusEvent, pending bool) (*model.MessageBusTransaction, error)
• func GetTargetTime(hours *int) uint64
• func UnsafeSetFallbackTime(ttf time.Duration)
• type Resolver
  • func (r *Resolver) Query() resolvers.QueryResolver
• type SortBridgeTxType
  • func (s SortBridgeTxType) Len() int
  • func (s SortBridgeTxType) Less(i, j int) bool
  • func (s SortBridgeTxType) Swap(i, j int)
• type SortMessageBusTxType
  • func (s SortMessageBusTxType) Len() int
  • func (s SortMessageBusTxType) Less(i, j int) bool
  • func (s SortMessageBusTxType) Swap(i, j int)

Functions

func GenerateAmountStatisticBridgeSQL

func GenerateAmountStatisticBridgeSQL(typeArg model.StatisticType, address *string, chainID *int, tokenAddress *string) (*string, error)

GenerateAmountStatisticBridgeSQL generate sql for the bridge platform.

func GenerateAmountStatisticMessageBusSQL

func GenerateAmountStatisticMessageBusSQL(typeArg model.StatisticType, compositeFilters string) (*string, error)

GenerateAmountStatisticMessageBusSQL generates sql for getting stats on the message bus platform.

func GenerateAmountStatisticSwapSQL

func GenerateAmountStatisticSwapSQL(typeArg model.StatisticType, compositeFilters string, tokenAddress *string) (*string, error)

GenerateAmountStatisticSwapSQL generates sql to get statistics on the swap platform.

nolint:cyclop

func GenerateDailyStatisticByChainAllSQL

func GenerateDailyStatisticByChainAllSQL(typeArg *model.DailyStatisticType, compositeFilters string, firstFilter *bool) (*string, error)

GenerateDailyStatisticByChainAllSQL generates sql for getting daily stats across all chains.

func GenerateDailyStatisticByChainAllSQLMv

func GenerateDailyStatisticByChainAllSQLMv(typeArg *model.DailyStatisticType, compositeFilters string, compositeFiltersMv string) (*string, error)

GenerateDailyStatisticByChainAllSQLMv generates sql for getting daily stats across all chains.

func GenerateDailyStatisticByChainBridgeSQL

func GenerateDailyStatisticByChainBridgeSQL(typeArg *model.DailyStatisticType, compositeFilters string, firstFilter *bool) (*string, error)

GenerateDailyStatisticByChainBridgeSQL generates sql for getting data for daily stats across the bridge platform.

func GenerateDailyStatisticByChainBridgeSQLMv

func GenerateDailyStatisticByChainBridgeSQLMv(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)

GenerateDailyStatisticByChainBridgeSQLMv generates sql for getting data for daily stats across the bridge platform.

func GenerateDailyStatisticByChainMessageBusSQL

func GenerateDailyStatisticByChainMessageBusSQL(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)

GenerateDailyStatisticByChainMessageBusSQL generates sql for getting daily stats across the message bus platform.

func GenerateDailyStatisticByChainSwapSQL

func GenerateDailyStatisticByChainSwapSQL(typeArg *model.DailyStatisticType, compositeFilters string) (*string, error)

GenerateDailyStatisticByChainSwapSQL generates sql for getting daily stats across the swap platform.

func GenerateRankedChainsByVolumeSQL

func GenerateRankedChainsByVolumeSQL(compositeFilters string, firstFilter *bool) string

GenerateRankedChainsByVolumeSQL generates sql for getting all chains ranked in order of volume.

func GetDurationFilter

func GetDurationFilter(duration *model.Duration, firstFilter *bool, prefix string) string

GetDurationFilter creates a filter for the various time ranges for analysis.

func GetFallbackTime

func GetFallbackTime() time.Duration

GetFallbackTime gets the fallback time for the bridge watcher. this is intended only for testing

func GetPartialInfoFromBridgeEventHybrid

func GetPartialInfoFromBridgeEventHybrid(bridgeEvent sql.HybridBridgeEvent, includePending *bool) (*model.BridgeTransaction, error)

GetPartialInfoFromBridgeEventHybrid returns the partial info from bridge event.

nolint:cyclop

func GetPartialInfoFromMessageBusEventHybrid

func GetPartialInfoFromMessageBusEventHybrid(ctx context.Context, messageBusEvent sql.HybridMessageBusEvent, pending bool) (*model.MessageBusTransaction, error)

GetPartialInfoFromMessageBusEventHybrid returns the partial info from message bus event.

nolint:cyclop

func GetTargetTime

func GetTargetTime(hours *int) uint64

GetTargetTime converts the number of hours into a timestamp.

func UnsafeSetFallbackTime

func UnsafeSetFallbackTime(ttf time.Duration)

UnsafeSetFallbackTime sets the fallback time for the bridge watcher. it is intended for testing. Plese remember to reset this value.

Types

type Resolver

type Resolver struct {
	DB      db.ConsumerDB
	Fetcher fetcher.ScribeFetcher
	Cache   cache.Service
	// CacheMutex is a mutex used for caching. It is used to prevent multiple
	// stat queries from being made at the same time. In the future, this should be done somewhere else.
	CacheMutex  mapmutex.StringMapMutex
	Clients     map[uint32]etherClient.EVM
	Parsers     *types.ServerParsers
	Refs        *types.ServerRefs
	SwapFilters map[string]*swap.SwapFlashLoanFilterer
	Config      serverConfig.Config
}

Resolver is the root resolver.

func (*Resolver) Query

func (r *Resolver) Query() resolvers.QueryResolver

Query returns resolvers.QueryResolver implementation.

type SortBridgeTxType

type SortBridgeTxType []*model.BridgeTransaction

SortBridgeTxType sorts bridge transactions by time.

func (SortBridgeTxType) Len

func (s SortBridgeTxType) Len() int

func (SortBridgeTxType) Less

func (s SortBridgeTxType) Less(i, j int) bool

func (SortBridgeTxType) Swap

func (s SortBridgeTxType) Swap(i, j int)

type SortMessageBusTxType

type SortMessageBusTxType []*model.MessageBusTransaction

SortMessageBusTxType sorts message bus transactions by time.

func (SortMessageBusTxType) Len

func (s SortMessageBusTxType) Len() int

func (SortMessageBusTxType) Less

func (s SortMessageBusTxType) Less(i, j int) bool

func (SortMessageBusTxType) Swap

func (s SortMessageBusTxType) Swap(i, j int)