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"
)
Variables ¶
This section is empty.
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
Source Files