influxdb

package
v0.0.0-...-730c616 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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 NewFluxIotSingleHost

func NewFluxIotSingleHost(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

NewInfluxDevops makes an InfluxDevops object ready to generate Queries.

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 NewInfluxQLIotSingleHost

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

Types

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 (*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

type InfluxDashboardCpuNum

type InfluxDashboardCpuNum struct {
	InfluxDashboard
}

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

func (*InfluxDashboardCpuNum) Dispatch

type InfluxDashboardCpuUtilization

type InfluxDashboardCpuUtilization struct {
	InfluxDashboard
}

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

func (*InfluxDashboardCpuUtilization) Dispatch

type InfluxDashboardDiskAllocated

type InfluxDashboardDiskAllocated struct {
	InfluxDashboard
}

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

func (*InfluxDashboardDiskAllocated) Dispatch

type InfluxDashboardDiskUsage

type InfluxDashboardDiskUsage struct {
	InfluxDashboard
}

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

func (*InfluxDashboardDiskUsage) Dispatch

type InfluxDashboardDiskUtilization

type InfluxDashboardDiskUtilization struct {
	InfluxDashboard
}

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

func (*InfluxDashboardDiskUtilization) Dispatch

type InfluxDashboardHttpRequestDuration

type InfluxDashboardHttpRequestDuration struct {
	InfluxDashboard
}

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

func (*InfluxDashboardHttpRequestDuration) Dispatch

type InfluxDashboardHttpRequests

type InfluxDashboardHttpRequests struct {
	InfluxDashboard
}

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

func (*InfluxDashboardHttpRequests) Dispatch

type InfluxDashboardKapaCpu

type InfluxDashboardKapaCpu struct {
	InfluxDashboard
}

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

func (*InfluxDashboardKapaCpu) Dispatch

type InfluxDashboardKapaLoad

type InfluxDashboardKapaLoad struct {
	InfluxDashboard
}

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

func (*InfluxDashboardKapaLoad) Dispatch

type InfluxDashboardKapaRam

type InfluxDashboardKapaRam struct {
	InfluxDashboard
}

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

func (*InfluxDashboardKapaRam) Dispatch

type InfluxDashboardMemoryTotal

type InfluxDashboardMemoryTotal struct {
	InfluxDashboard
}

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

func (*InfluxDashboardMemoryTotal) Dispatch

type InfluxDashboardMemoryUtilization

type InfluxDashboardMemoryUtilization struct {
	InfluxDashboard
}

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

func (*InfluxDashboardMemoryUtilization) Dispatch

type InfluxDashboardNginxRequests

type InfluxDashboardNginxRequests struct {
	InfluxDashboard
}

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

func (*InfluxDashboardNginxRequests) Dispatch

type InfluxDashboardQueueBytes

type InfluxDashboardQueueBytes struct {
	InfluxDashboard
}

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

func (*InfluxDashboardQueueBytes) Dispatch

type InfluxDashboardRedisMemoryUtilization

type InfluxDashboardRedisMemoryUtilization struct {
	InfluxDashboard
}

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

func (*InfluxDashboardRedisMemoryUtilization) Dispatch

type InfluxDashboardSystemLoad

type InfluxDashboardSystemLoad struct {
	InfluxDashboard
}

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

func (*InfluxDashboardSystemLoad) Dispatch

type InfluxDashboardThroughput

type InfluxDashboardThroughput struct {
	InfluxDashboard
}

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

func (*InfluxDashboardThroughput) Dispatch

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

type InfluxDevopsSingleHost12hr

type InfluxDevopsSingleHost12hr struct {
	InfluxDevops
}

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

func (*InfluxDevopsSingleHost12hr) Dispatch

type InfluxIot

type InfluxIot struct {
	InfluxCommon
}

InfluxDevops 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.

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 Language

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

func (Language) String

func (lang Language) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL