influxdb

package
v0.0.0-...-14ad7d4 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InfluxMultiMeasurementCommon 

func InfluxMultiMeasurementCommon(lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateCount 

func NewFluxBareAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateFirst 

func NewFluxBareAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateLast 

func NewFluxBareAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateMax 

func NewFluxBareAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateMean 

func NewFluxBareAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateMin 

func NewFluxBareAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxBareAggregateSum 

func NewFluxBareAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardAll 

func NewFluxDashboardAll(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardAvailability 

func NewFluxDashboardAvailability(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardCpuNum 

func NewFluxDashboardCpuNum(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardCpuUtilization 

func NewFluxDashboardCpuUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardDiskAllocated 

func NewFluxDashboardDiskAllocated(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardDiskUsage 

func NewFluxDashboardDiskUsage(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardDiskUtilization 

func NewFluxDashboardDiskUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardHttpRequestDuration 

func NewFluxDashboardHttpRequestDuration(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardHttpRequests 

func NewFluxDashboardHttpRequests(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardKapaCpu 

func NewFluxDashboardKapaCpu(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardKapaLoad 

func NewFluxDashboardKapaLoad(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardKapaRam 

func NewFluxDashboardKapaRam(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardMemoryTotal 

func NewFluxDashboardMemoryTotal(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardMemoryUtilization 

func NewFluxDashboardMemoryUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardNginxRequests 

func NewFluxDashboardNginxRequests(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardQueueBytes 

func NewFluxDashboardQueueBytes(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardRedisMemoryUtilization 

func NewFluxDashboardRedisMemoryUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardSystemLoad 

func NewFluxDashboardSystemLoad(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDashboardThroughput 

func NewFluxDashboardThroughput(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDevops8Hosts 

func NewFluxDevops8Hosts(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDevopsGroupBy 

func NewFluxDevopsGroupBy(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDevopsSingleHost 

func NewFluxDevopsSingleHost(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxDevopsSingleHost12hr 

func NewFluxDevopsSingleHost12hr(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateCount 

func NewFluxGroupAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateFirst 

func NewFluxGroupAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateLast 

func NewFluxGroupAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateMax 

func NewFluxGroupAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateMean 

func NewFluxGroupAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateMin 

func NewFluxGroupAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupAggregateSum 

func NewFluxGroupAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxGroupWindowTransposeCount 

func NewFluxGroupWindowTransposeCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeCountCardinality 

func NewFluxGroupWindowTransposeCountCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeFirst 

func NewFluxGroupWindowTransposeFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeFirstCardinality 

func NewFluxGroupWindowTransposeFirstCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeLast 

func NewFluxGroupWindowTransposeLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeLastCardinality 

func NewFluxGroupWindowTransposeLastCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeMax 

func NewFluxGroupWindowTransposeMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeMaxCardinality 

func NewFluxGroupWindowTransposeMaxCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeMean 

func NewFluxGroupWindowTransposeMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeMeanCardinality 

func NewFluxGroupWindowTransposeMeanCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeMin 

func NewFluxGroupWindowTransposeMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeMinCardinality 

func NewFluxGroupWindowTransposeMinCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxGroupWindowTransposeSum 

func NewFluxGroupWindowTransposeSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux Query query for "Group Window" on the standard cardinality IoT dataset

func NewFluxGroupWindowTransposeSumCardinality 

func NewFluxGroupWindowTransposeSumCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Flux query for "Group Window" on the high cardinality Metaquery dataset

func NewFluxIotAggregateDrop 

func NewFluxIotAggregateDrop(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxIotAggregateKeep 

func NewFluxIotAggregateKeep(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxIotSingleHost 

func NewFluxIotSingleHost(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxIotSortedPivot 

func NewFluxIotSortedPivot(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxIotStandAloneFilter 

func NewFluxIotStandAloneFilter(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxMetaqueryCardinality 

func NewFluxMetaqueryCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxMetaqueryFieldKeys 

func NewFluxMetaqueryFieldKeys(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxMetaqueryTagValues 

func NewFluxMetaqueryTagValues(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxMultiMeasurementOr 

func NewFluxMultiMeasurementOr(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateCount 

func NewFluxUngroupedAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateFirst 

func NewFluxUngroupedAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateLast 

func NewFluxUngroupedAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateMax 

func NewFluxUngroupedAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateMean 

func NewFluxUngroupedAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateMin 

func NewFluxUngroupedAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxUngroupedAggregateSum 

func NewFluxUngroupedAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateCount 

func NewFluxWindowAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateFirst 

func NewFluxWindowAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateLast 

func NewFluxWindowAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateMax 

func NewFluxWindowAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateMean 

func NewFluxWindowAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateMin 

func NewFluxWindowAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewFluxWindowAggregateSum 

func NewFluxWindowAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxBareAggregateQuery 

func NewInfluxBareAggregateQuery(agg Aggregate, lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxGroupAggregateQuery 

func NewInfluxGroupAggregateQuery(agg Aggregate, lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxGroupWindowTransposeQuery 

func NewInfluxGroupWindowTransposeQuery(agg Aggregate, card Cardinality, lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxIotCommon 

func NewInfluxIotCommon(lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

NewInfluxIotCommon makes an InfluxIot object ready to generate Queries.

func NewInfluxMetaqueryCommon 

func NewInfluxMetaqueryCommon(lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

queryInterval is currently not used, but may be used to include as a parameter in the future.

func NewInfluxQLBareAggregateCount 

func NewInfluxQLBareAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateFirst 

func NewInfluxQLBareAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateLast 

func NewInfluxQLBareAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateMax 

func NewInfluxQLBareAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateMean 

func NewInfluxQLBareAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateMin 

func NewInfluxQLBareAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLBareAggregateSum 

func NewInfluxQLBareAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardAll 

func NewInfluxQLDashboardAll(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardAvailability 

func NewInfluxQLDashboardAvailability(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardCpuNum 

func NewInfluxQLDashboardCpuNum(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardCpuUtilization 

func NewInfluxQLDashboardCpuUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardDiskAllocated 

func NewInfluxQLDashboardDiskAllocated(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardDiskUsage 

func NewInfluxQLDashboardDiskUsage(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardDiskUtilization 

func NewInfluxQLDashboardDiskUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardHttpRequestDuration 

func NewInfluxQLDashboardHttpRequestDuration(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardHttpRequests 

func NewInfluxQLDashboardHttpRequests(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardKapaCpu 

func NewInfluxQLDashboardKapaCpu(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardKapaLoad 

func NewInfluxQLDashboardKapaLoad(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardKapaRam 

func NewInfluxQLDashboardKapaRam(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardMemoryTotal 

func NewInfluxQLDashboardMemoryTotal(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardMemoryUtilization 

func NewInfluxQLDashboardMemoryUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardNginxRequests 

func NewInfluxQLDashboardNginxRequests(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardQueueBytes 

func NewInfluxQLDashboardQueueBytes(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardRedisMemoryUtilization 

func NewInfluxQLDashboardRedisMemoryUtilization(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardSystemLoad 

func NewInfluxQLDashboardSystemLoad(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDashboardThroughput 

func NewInfluxQLDashboardThroughput(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDevops8Hosts 

func NewInfluxQLDevops8Hosts(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDevopsGroupBy 

func NewInfluxQLDevopsGroupBy(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDevopsSingleHost 

func NewInfluxQLDevopsSingleHost(dbConfig bulkQuerygen.DatabaseConfig, interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLDevopsSingleHost12hr 

func NewInfluxQLDevopsSingleHost12hr(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateCount 

func NewInfluxQLGroupAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateFirst 

func NewInfluxQLGroupAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateLast 

func NewInfluxQLGroupAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateMax 

func NewInfluxQLGroupAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateMean 

func NewInfluxQLGroupAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateMin 

func NewInfluxQLGroupAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupAggregateSum 

func NewInfluxQLGroupAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLGroupWindowTransposeCount 

func NewInfluxQLGroupWindowTransposeCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeCountCardinality 

func NewInfluxQLGroupWindowTransposeCountCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeFirst 

func NewInfluxQLGroupWindowTransposeFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeFirstCardinality 

func NewInfluxQLGroupWindowTransposeFirstCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeLast 

func NewInfluxQLGroupWindowTransposeLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeLastCardinality 

func NewInfluxQLGroupWindowTransposeLastCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeMax 

func NewInfluxQLGroupWindowTransposeMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeMaxCardinality 

func NewInfluxQLGroupWindowTransposeMaxCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeMean 

func NewInfluxQLGroupWindowTransposeMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeMeanCardinality 

func NewInfluxQLGroupWindowTransposeMeanCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeMin 

func NewInfluxQLGroupWindowTransposeMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeMinCardinality 

func NewInfluxQLGroupWindowTransposeMinCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLGroupWindowTransposeSum 

func NewInfluxQLGroupWindowTransposeSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the standard cardinality IoT dataset

func NewInfluxQLGroupWindowTransposeSumCardinality 

func NewInfluxQLGroupWindowTransposeSumCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

InfluxQL query for "Group Window" on the high cardinality Metaquery dataset

func NewInfluxQLIotAggregateDrop 

func NewInfluxQLIotAggregateDrop(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLIotAggregateKeep 

func NewInfluxQLIotAggregateKeep(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLIotSingleHost 

func NewInfluxQLIotSingleHost(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLIotSortedPivot 

func NewInfluxQLIotSortedPivot(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLIotStandAloneFilter 

func NewInfluxQLIotStandAloneFilter(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLMetaqueryCardinality 

func NewInfluxQLMetaqueryCardinality(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLMetaqueryFieldKeys 

func NewInfluxQLMetaqueryFieldKeys(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLMetaqueryTagValues 

func NewInfluxQLMetaqueryTagValues(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLMultiMeasurementOr 

func NewInfluxQLMultiMeasurementOr(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateCount 

func NewInfluxQLUngroupedAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateFirst 

func NewInfluxQLUngroupedAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateLast 

func NewInfluxQLUngroupedAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateMax 

func NewInfluxQLUngroupedAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateMean 

func NewInfluxQLUngroupedAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateMin 

func NewInfluxQLUngroupedAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLUngroupedAggregateSum 

func NewInfluxQLUngroupedAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, _ time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateCount 

func NewInfluxQLWindowAggregateCount(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateFirst 

func NewInfluxQLWindowAggregateFirst(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateLast 

func NewInfluxQLWindowAggregateLast(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateMax 

func NewInfluxQLWindowAggregateMax(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateMean 

func NewInfluxQLWindowAggregateMean(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateMin 

func NewInfluxQLWindowAggregateMin(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxQLWindowAggregateSum 

func NewInfluxQLWindowAggregateSum(dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxUngroupedAggregateQuery 

func NewInfluxUngroupedAggregateQuery(agg Aggregate, lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, scaleVar int) bulkQuerygen.QueryGenerator

func NewInfluxWindowAggregateQuery 

func NewInfluxWindowAggregateQuery(agg Aggregate, lang Language, dbConfig bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Types

type Aggregate 

type Aggregate string
const (
	Count Aggregate = "count"
	Sum   Aggregate = "sum"
	Mean  Aggregate = "mean"
	Min   Aggregate = "min"
	Max   Aggregate = "max"
	First Aggregate = "first"
	Last  Aggregate = "last"
)

type Cardinality 

type Cardinality string
const (
	HighCardinality Cardinality = "high-card"
	LowCardinality  Cardinality = "low-card"
)

type InfluxBareAggregateQuery 

type InfluxBareAggregateQuery struct {
	InfluxCommon
	// contains filtered or unexported fields
}

func (*InfluxBareAggregateQuery) BareAggregateQuery 

func (d *InfluxBareAggregateQuery) BareAggregateQuery(qi bulkQuerygen.Query)

func (*InfluxBareAggregateQuery) Dispatch 

func (d *InfluxBareAggregateQuery) Dispatch(i int) bulkQuerygen.Query

type InfluxCommon 

type InfluxCommon struct {
	bulkQuerygen.CommonParams

	DatabaseName string
	// contains filtered or unexported fields
}

type InfluxDashboard 

type InfluxDashboard struct {
	InfluxCommon
	ClustersCount int
	bulkQuerygen.TimeWindow
}

InfluxDashboard produces Influx-specific queries for all the devops query types.

func (*InfluxDashboard) Dispatch 

func (d *InfluxDashboard) Dispatch(i int) bulkQuerygen.Query

Dispatch fulfills the QueryGenerator interface.

func (*InfluxDashboard) DispatchCommon 

func (d *InfluxDashboard) DispatchCommon(i int) (*bulkQuerygen.HTTPQuery, *bulkQuerygen.TimeInterval)

func (*InfluxDashboard) GetRandomClusterId 

func (d *InfluxDashboard) GetRandomClusterId() string

func (*InfluxDashboard) GetTimeConstraint 

func (d *InfluxDashboard) GetTimeConstraint(interval *bulkQuerygen.TimeInterval) string

type InfluxDashboardAll 

type InfluxDashboardAll struct {
	InfluxDashboard
	Gens []bulkQuerygen.QueryGenerator
}

InfluxDashboardAll produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardAll) Dispatch 

func (d *InfluxDashboardAll) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardAvailability 

type InfluxDashboardAvailability struct {
	InfluxDashboard
}

InfluxDashboardAvailability produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardAvailability) Dispatch 

func (d *InfluxDashboardAvailability) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardCpuNum 

type InfluxDashboardCpuNum struct {
	InfluxDashboard
}

InfluxDashboardCpuNum produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardCpuNum) Dispatch 

func (d *InfluxDashboardCpuNum) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardCpuUtilization 

type InfluxDashboardCpuUtilization struct {
	InfluxDashboard
}

InfluxDashboardCpuUtilization produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardCpuUtilization) Dispatch 

func (d *InfluxDashboardCpuUtilization) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardDiskAllocated 

type InfluxDashboardDiskAllocated struct {
	InfluxDashboard
}

InfluxDashboardDiskAllocated produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardDiskAllocated) Dispatch 

func (d *InfluxDashboardDiskAllocated) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardDiskUsage 

type InfluxDashboardDiskUsage struct {
	InfluxDashboard
}

InfluxDashboardDiskUsage produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardDiskUsage) Dispatch 

func (d *InfluxDashboardDiskUsage) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardDiskUtilization 

type InfluxDashboardDiskUtilization struct {
	InfluxDashboard
}

InfluxDashboardDiskUtilization produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardDiskUtilization) Dispatch 

func (d *InfluxDashboardDiskUtilization) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardHttpRequestDuration 

type InfluxDashboardHttpRequestDuration struct {
	InfluxDashboard
}

InfluxDashboardHttpRequestDuration produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardHttpRequestDuration) Dispatch 

func (d *InfluxDashboardHttpRequestDuration) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardHttpRequests 

type InfluxDashboardHttpRequests struct {
	InfluxDashboard
}

InfluxDashboardHttpRequests produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardHttpRequests) Dispatch 

func (d *InfluxDashboardHttpRequests) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardKapaCpu 

type InfluxDashboardKapaCpu struct {
	InfluxDashboard
}

InfluxDashboardKapaCpu produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardKapaCpu) Dispatch 

func (d *InfluxDashboardKapaCpu) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardKapaLoad 

type InfluxDashboardKapaLoad struct {
	InfluxDashboard
}

InfluxDashboardKapaLoad produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardKapaLoad) Dispatch 

func (d *InfluxDashboardKapaLoad) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardKapaRam 

type InfluxDashboardKapaRam struct {
	InfluxDashboard
}

InfluxDashboardKapaRam produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardKapaRam) Dispatch 

func (d *InfluxDashboardKapaRam) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardMemoryTotal 

type InfluxDashboardMemoryTotal struct {
	InfluxDashboard
}

InfluxDashboardMemoryTotal produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardMemoryTotal) Dispatch 

func (d *InfluxDashboardMemoryTotal) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardMemoryUtilization 

type InfluxDashboardMemoryUtilization struct {
	InfluxDashboard
}

InfluxDashboardMemoryUtilization produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardMemoryUtilization) Dispatch 

func (d *InfluxDashboardMemoryUtilization) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardNginxRequests 

type InfluxDashboardNginxRequests struct {
	InfluxDashboard
}

InfluxDashboardNginxRequests produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardNginxRequests) Dispatch 

func (d *InfluxDashboardNginxRequests) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardQueueBytes 

type InfluxDashboardQueueBytes struct {
	InfluxDashboard
}

InfluxDashboardQueueBytes produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardQueueBytes) Dispatch 

func (d *InfluxDashboardQueueBytes) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardRedisMemoryUtilization 

type InfluxDashboardRedisMemoryUtilization struct {
	InfluxDashboard
}

InfluxDashboardRedisMemoryUtilization produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardRedisMemoryUtilization) Dispatch 

func (d *InfluxDashboardRedisMemoryUtilization) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardSystemLoad 

type InfluxDashboardSystemLoad struct {
	InfluxDashboard
}

InfluxDashboardSystemLoad produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardSystemLoad) Dispatch 

func (d *InfluxDashboardSystemLoad) Dispatch(i int) bulkQuerygen.Query

type InfluxDashboardThroughput 

type InfluxDashboardThroughput struct {
	InfluxDashboard
}

InfluxDashboardThroughput produces Influx-specific queries for the dashboard single-host case.

func (*InfluxDashboardThroughput) Dispatch 

func (d *InfluxDashboardThroughput) Dispatch(i int) bulkQuerygen.Query

type InfluxDevops 

type InfluxDevops struct {
	InfluxCommon
}

InfluxDevops produces Influx-specific queries for all the devops query types.

func (*InfluxDevops) Dispatch 

func (d *InfluxDevops) Dispatch(i int) bulkQuerygen.Query

Dispatch fulfills the QueryGenerator interface.

func (*InfluxDevops) MaxCPUUsage12HoursByMinuteOneHost 

func (d *InfluxDevops) MaxCPUUsage12HoursByMinuteOneHost(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteEightHosts 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteEightHosts(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteFourHosts 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteFourHosts(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteOneHost 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteOneHost(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteSixteenHosts 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteSixteenHosts(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteThirtyTwoHosts 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteThirtyTwoHosts(q bulkQuerygen.Query)

func (*InfluxDevops) MaxCPUUsageHourByMinuteTwoHosts 

func (d *InfluxDevops) MaxCPUUsageHourByMinuteTwoHosts(q bulkQuerygen.Query)

func (*InfluxDevops) MeanCPUUsageDayByHourAllHostsGroupbyHost 

func (d *InfluxDevops) MeanCPUUsageDayByHourAllHostsGroupbyHost(qi bulkQuerygen.Query)

MeanCPUUsageDayByHourAllHosts populates a Query with a query that looks like: SELECT mean(usage_user) from cpu where time >= '$DAY_START' and time < '$DAY_END' group by time(1h),hostname

type InfluxDevops8Hosts 

type InfluxDevops8Hosts struct {
	InfluxDevops
}

InfluxDevops8Hosts produces Influx-specific queries for the devops groupby case.

func (*InfluxDevops8Hosts) Dispatch 

func (d *InfluxDevops8Hosts) Dispatch(i int) bulkQuerygen.Query

type InfluxDevopsGroupby 

type InfluxDevopsGroupby struct {
	InfluxDevops
}

InfluxDevopsGroupby produces Influx-specific queries for the devops groupby case.

func (*InfluxDevopsGroupby) Dispatch 

func (d *InfluxDevopsGroupby) Dispatch(i int) bulkQuerygen.Query

type InfluxDevopsSingleHost 

type InfluxDevopsSingleHost struct {
	InfluxDevops
}

InfluxDevopsSingleHost produces Influx-specific queries for the devops single-host case.

func (*InfluxDevopsSingleHost) Dispatch 

func (d *InfluxDevopsSingleHost) Dispatch(i int) bulkQuerygen.Query

type InfluxDevopsSingleHost12hr 

type InfluxDevopsSingleHost12hr struct {
	InfluxDevops
}

InfluxDevopsSingleHost12hr produces Influx-specific queries for the devops single-host case over a 12hr period.

func (*InfluxDevopsSingleHost12hr) Dispatch 

func (d *InfluxDevopsSingleHost12hr) Dispatch(i int) bulkQuerygen.Query

type InfluxGroupAggregateQuery 

type InfluxGroupAggregateQuery struct {
	InfluxCommon
	// contains filtered or unexported fields
}

func (*InfluxGroupAggregateQuery) Dispatch 

func (d *InfluxGroupAggregateQuery) Dispatch(i int) bulkQuerygen.Query

func (*InfluxGroupAggregateQuery) GroupAggregateQuery 

func (d *InfluxGroupAggregateQuery) GroupAggregateQuery(qi bulkQuerygen.Query)

type InfluxGroupWindowTransposeQuery 

type InfluxGroupWindowTransposeQuery struct {
	InfluxCommon
	// contains filtered or unexported fields
}

func (*InfluxGroupWindowTransposeQuery) Dispatch 

func (d *InfluxGroupWindowTransposeQuery) Dispatch(i int) bulkQuerygen.Query

func (*InfluxGroupWindowTransposeQuery) GroupWindowTransposeCardinalityQuery 

func (d *InfluxGroupWindowTransposeQuery) GroupWindowTransposeCardinalityQuery(qi bulkQuerygen.Query)

GroupWindowTransposeCardinalityQuery generates a query based on the Metaquery data generator, which is much higher in cardinality.

func (*InfluxGroupWindowTransposeQuery) GroupWindowTransposeQuery 

func (d *InfluxGroupWindowTransposeQuery) GroupWindowTransposeQuery(qi bulkQuerygen.Query)

GroupWindowTransposeQuery generates a query based on the IoT data generator, which represents a relatively low amount of cardinality.

type InfluxIot 

type InfluxIot struct {
	InfluxCommon
}

InfluxIot produces Influx-specific queries for all the devops query types.

func (*InfluxIot) AverageTemperatureDayByHourOneHome 

func (d *InfluxIot) AverageTemperatureDayByHourOneHome(q bulkQuerygen.Query)

func (*InfluxIot) Dispatch 

func (d *InfluxIot) Dispatch(i int) bulkQuerygen.Query

Dispatch fulfills the QueryGenerator interface.

func (*InfluxIot) IotAggregateDrop 

func (d *InfluxIot) IotAggregateDrop(qi bulkQuerygen.Query, timeRange time.Duration)

func (*InfluxIot) IotAggregateKeep 

func (d *InfluxIot) IotAggregateKeep(qi bulkQuerygen.Query, timeRange time.Duration)

func (*InfluxIot) IotSortedPivot 

func (d *InfluxIot) IotSortedPivot(qi bulkQuerygen.Query, timeInterval time.Duration)

func (*InfluxIot) StandAloneFilter 

func (d *InfluxIot) StandAloneFilter(qi bulkQuerygen.Query)

type InfluxIotAggregateDrop 

type InfluxIotAggregateDrop struct {
	InfluxIot
	// contains filtered or unexported fields
}

InfluxIotAggregateDrop produces queries that will test performance on Flux statements with drop() |> aggregateWindow()

func (*InfluxIotAggregateDrop) Dispatch 

func (d *InfluxIotAggregateDrop) Dispatch(i int) bulkQuerygen.Query

type InfluxIotAggregateKeep 

type InfluxIotAggregateKeep struct {
	InfluxIot
	// contains filtered or unexported fields
}

InfluxIotAggregateKeep produces queries that will test performance on Flux statements with keep() |> aggregateWindow()

func (*InfluxIotAggregateKeep) Dispatch 

func (d *InfluxIotAggregateKeep) Dispatch(i int) bulkQuerygen.Query

type InfluxIotSingleHost 

type InfluxIotSingleHost struct {
	InfluxIot
}

InfluxIotSingleHost produces Influx-specific queries for the devops single-host case.

func (*InfluxIotSingleHost) Dispatch 

func (d *InfluxIotSingleHost) Dispatch(i int) bulkQuerygen.Query

type InfluxIotSortedPivot 

type InfluxIotSortedPivot struct {
	InfluxIot
	// contains filtered or unexported fields
}

InfluxIotSortedPivot produces queries that will test performance on Flux pivot function

func (*InfluxIotSortedPivot) Dispatch 

func (d *InfluxIotSortedPivot) Dispatch(i int) bulkQuerygen.Query

type InfluxIotStandAloneFilter 

type InfluxIotStandAloneFilter struct {
	InfluxIot
}

func (*InfluxIotStandAloneFilter) Dispatch 

func (d *InfluxIotStandAloneFilter) Dispatch(i int) bulkQuerygen.Query

type InfluxMetaquery 

type InfluxMetaquery struct {
	InfluxCommon
}

func (*InfluxMetaquery) Dispatch 

func (d *InfluxMetaquery) Dispatch(i int) bulkQuerygen.Query

Dispatch is to satisfy the bulkQuerygen.QueryGenerator interface. Specific query-types will implement their own Dispatch methods which will supercede this one. Returning the query without setting it for this root method follows the convention in influx_dashboard_common.go

func (*InfluxMetaquery) MetaqueryCardinality 

func (d *InfluxMetaquery) MetaqueryCardinality(qi bulkQuerygen.Query)

MetaqueryCardinality calculates the series cardinality for all data in a bucket. The Flux query uses an arbitrarily large time range to ensure that all shards are within that time range, in order to be comparable to InfluxQL which does not use a time range for cardinality estimation.

func (*InfluxMetaquery) MetaqueryFieldKeys 

func (d *InfluxMetaquery) MetaqueryFieldKeys(qi bulkQuerygen.Query)

MetaqueryFieldKeys generates a query that returns a list of field keys for a specific measurement.

func (*InfluxMetaquery) MetaqueryTagValues 

func (d *InfluxMetaquery) MetaqueryTagValues(qi bulkQuerygen.Query)

MetaqueryTagValues generates a query that returns a list of tag values for a specific tag key. The InfluxQL query is very simple and is constant. The Flux query is slightly more complicated and is intended to replicate an equivalent query that would be generated by the InfluxDB UI for getting "all" the tag values for a specific tag key.

type InfluxMetaqueryCardinality 

type InfluxMetaqueryCardinality struct {
	InfluxMetaquery
}

func (*InfluxMetaqueryCardinality) Dispatch 

func (d *InfluxMetaqueryCardinality) Dispatch(i int) bulkQuerygen.Query

type InfluxMetaqueryFieldKeys 

type InfluxMetaqueryFieldKeys struct {
	InfluxMetaquery
}

InfluxMetaqueryFieldKeys produces metaqueries that will return a list of all field keys associated with a measurement.

func (*InfluxMetaqueryFieldKeys) Dispatch 

func (d *InfluxMetaqueryFieldKeys) Dispatch(i int) bulkQuerygen.Query

type InfluxMetaqueryTagValues 

type InfluxMetaqueryTagValues struct {
	InfluxMetaquery
}

InfluxMetaqueryTagValues produces metaqueries that will return a list of all tag values for a specific tag key name.

func (*InfluxMetaqueryTagValues) Dispatch 

func (d *InfluxMetaqueryTagValues) Dispatch(i int) bulkQuerygen.Query

type InfluxMultiMeasurement 

type InfluxMultiMeasurement struct {
	InfluxCommon
}

func (*InfluxMultiMeasurement) Dispatch 

func (d *InfluxMultiMeasurement) Dispatch(i int) bulkQuerygen.Query

type InfluxMultiMeasurementOr 

type InfluxMultiMeasurementOr struct {
	InfluxMultiMeasurement
	// contains filtered or unexported fields
}

func (*InfluxMultiMeasurementOr) Dispatch 

func (d *InfluxMultiMeasurementOr) Dispatch(i int) bulkQuerygen.Query

func (*InfluxMultiMeasurementOr) MultiMeasurementOr 

func (d *InfluxMultiMeasurementOr) MultiMeasurementOr(qi bulkQuerygen.Query, queryInterval time.Duration)

type InfluxUngroupedAggregateQuery 

type InfluxUngroupedAggregateQuery struct {
	InfluxCommon
	// contains filtered or unexported fields
}

func (*InfluxUngroupedAggregateQuery) Dispatch 

func (d *InfluxUngroupedAggregateQuery) Dispatch(i int) bulkQuerygen.Query

func (*InfluxUngroupedAggregateQuery) UngroupedAggregateQuery 

func (d *InfluxUngroupedAggregateQuery) UngroupedAggregateQuery(qi bulkQuerygen.Query)

type InfluxWindowAggregateQuery 

type InfluxWindowAggregateQuery struct {
	InfluxCommon
	// contains filtered or unexported fields
}

func (*InfluxWindowAggregateQuery) Dispatch 

func (d *InfluxWindowAggregateQuery) Dispatch(i int) bulkQuerygen.Query

func (*InfluxWindowAggregateQuery) WindowAggregateQuery 

func (d *InfluxWindowAggregateQuery) WindowAggregateQuery(qi bulkQuerygen.Query)

type Language 

type Language bool
const (
	InfluxQL Language = false
	Flux     Language = true
)

func (Language) String 

func (lang Language) String() string

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.