cq

Documentation

Index

• Constants
• func CreateAssetVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateBurnFeeCqs(dbName string) ([]*cq.ContinuousQuery, error)
• func CreateCountryCqs(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateIntegrationVolumeCq(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateReserveVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateSummaryCqs(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateUserVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)
• func CreateWalletFeeCqs(dbName string) ([]*cq.ContinuousQuery, error)
• func CreateWalletStatsCqs(dbName string) ([]*cq.ContinuousQuery, error)
• type RsvFieldsType

Constants

const (
	//IntegrationVolumeMeasurement is the name for Integration Volume Measurement
	IntegrationVolumeMeasurement = "integration_volume"
)

Functions

func CreateAssetVolumeCqs

func CreateAssetVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)

CreateAssetVolumeCqs return a set of cqs required for asset volume aggregation

func CreateBurnFeeCqs

func CreateBurnFeeCqs(dbName string) ([]*cq.ContinuousQuery, error)

CreateBurnFeeCqs return a set of cqs required for burnfee aggregation

func CreateCountryCqs

func CreateCountryCqs(dbName string) ([]*libcq.ContinuousQuery, error)

CreateCountryCqs return a set of cqs required for country trade aggregation

func CreateIntegrationVolumeCq

func CreateIntegrationVolumeCq(dbName string) ([]*libcq.ContinuousQuery, error)

CreateIntegrationVolumeCq return a set of cqs required for KyberSwap and non KyberSwap Summary aggregation

func CreateReserveVolumeCqs

func CreateReserveVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)

CreateReserveVolumeCqs return a set of cqs required for asset volume aggregation

func CreateSummaryCqs

func CreateSummaryCqs(dbName string) ([]*libcq.ContinuousQuery, error)

CreateSummaryCqs return a set of cqs required for trade Summary aggregation

func CreateUserVolumeCqs

func CreateUserVolumeCqs(dbName string) ([]*libcq.ContinuousQuery, error)

CreateUserVolumeCqs continueous query for aggregate user volume

func CreateWalletFeeCqs

func CreateWalletFeeCqs(dbName string) ([]*cq.ContinuousQuery, error)

CreateWalletFeeCqs return a set of cqs required for burnfee aggregation

func CreateWalletStatsCqs

func CreateWalletStatsCqs(dbName string) ([]*cq.ContinuousQuery, error)

CreateWalletStatsCqs return a new set of cqs required for wallet stats aggregation

Types

type RsvFieldsType

type RsvFieldsType struct {
	// AmountType: it can be dst_amount or src_amount
	AmountType string
	// RsvAddressType: it can be dst_rsv_amount or src_rsv_amount
	RsvAddressType string
	// Addresstype: it can be dst_addr or src_addr
	AddressType string
}

RsvFieldsType declare the set of names requires to completed a reserveVolume Cqs