protocols

Documentation

Index

• Constants
• type ProtocolStats
• type ProtocolTotalValuesDTO
• type QueryDoer
  • func WrapQueryAPI(qApi api.QueryAPI) QueryDoer
• type QueryResult
• type Repository
  • func NewRepository(qApi QueryDoer, bucketInfinite, bucket30d, bucket24Hrs string, ...) *Repository
• type Service
  • func NewService(protocols []string, repo *Repository, logger *zap.Logger, cache cache.Cache, ...) *Service
  • func (s *Service) GetProtocolsTotalValues(ctx context.Context) []ProtocolTotalValuesDTO

Constants

const ALLBRIDGE = "ALLBRIDGE"

const AllProtocolStats24HrAgo = `` /* 1071-byte string literal not displayed */

const AllProtocolsDeltaLastDay = `` /* 1071-byte string literal not displayed */

const AllProtocolsDeltaSinceStartOfDay = `` /* 1060-byte string literal not displayed */

const CCTP = "CCTP_WORMHOLE_INTEGRATION"

const GenericRelayer = "GENERIC_RELAYER"

const MAYAN = "MAYAN"

const NTT = "NATIVE_TOKEN_TRANSFER"

const PortalTokenBridge = "PORTAL_TOKEN_BRIDGE"

const QueryLast24HrActivity = `` /* 238-byte string literal not displayed */

const QueryTemplateProtocolActivity = `` /* 447-byte string literal not displayed */

const QueryTemplateProtocolStats24HrAgo = `` /* 211-byte string literal not displayed */

const QueryTemplateProtocolStatsNow = `` /* 210-byte string literal not displayed */

const UNKNOWN = "UNKNOWN"

Types

type ProtocolStats

type ProtocolStats struct {
	Protocol                    string  `json:"protocol"`
	TotalMessages               uint64  `json:"total_messages"`
	TotalValueLocked            float64 `json:"total_value_locked,omitempty"`
	TotalValueSecured           float64 `json:"total_value_secured,omitempty"`
	TotalValueTransferred       float64 `json:"total_value_transferred"`
	LastDayMessages             uint64  `json:"last_day_messages"`
	LastDayDiffPercentage       string  `json:"last_day_diff_percentage"`
	LastDayVolumeDiffPercentage string  `json:"last_day_diff_volume_percentage"`
	Last24HourVolume            float64 `json:"last_24_hour_volume"`
}

type ProtocolTotalValuesDTO

type ProtocolTotalValuesDTO struct {
	ProtocolStats
	Error string `json:"error,omitempty"`
}

type QueryDoer

type QueryDoer interface {
	Query(ctx context.Context, query string) (QueryResult, error)
}

func WrapQueryAPI

func WrapQueryAPI(qApi api.QueryAPI) QueryDoer

type QueryResult

type QueryResult interface {
	Next() bool
	Record() *query.FluxRecord
	Err() error
	Close() error
}

type Repository

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

func NewRepository

func NewRepository(qApi QueryDoer, bucketInfinite, bucket30d, bucket24Hrs string, logger *zap.Logger) *Repository

type Service

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

func NewService

func NewService(protocols []string, repo *Repository, logger *zap.Logger, cache cache.Cache, cacheKeyPrefix string, cacheTTL int, metrics metrics.Metrics, tvlProvider tvlProvider) *Service

func (*Service) GetProtocolsTotalValues

func (s *Service) GetProtocolsTotalValues(ctx context.Context) []ProtocolTotalValuesDTO