exporter

package
v0.0.0-...-2ff42f3 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KubebenchTotalName = "kubebench_total"
	KubebenchTotalHelp = "Total number of kubebench runs"
)
View Source
const (
	PgbenchScaleName = "kubebench_pgbench_scale"
	PgbenchScaleHelp = "The scale of pgbench"

	PgbenchClientsName = "kubebench_pgbench_clients"
	PgbenchClientsHelp = "The clients of pgbench"

	PgbenchThreadsName = "kubebench_pgbench_threads"
	PgbenchThreadsHelp = "The threads of pgbench"

	PgbenchMaximumTryName = "kubebench_pgbench_maximum_try"
	PgbenchMaximumTryHelp = "The maximum try of pgbench"

	PgbenchTransactionsPerClientName = "kubebench_pgbench_transactions_per_client"
	PgbenchTransactionsPerClientHelp = "The transactions per client of pgbench"

	PgbenchTransactionsProcessedName = "kubebench_pgbench_transactions_processed"
	PgbenchTransactionsProcessedHelp = "The transactions processed of pgbench"

	PgbenchTransactionsFailedName = "kubebench_pgbench_transactions_failed"
	PgbenchTransactionsFailedHelp = "The transactions failed of pgbench"

	PgbenchAvgLatencyName = "kubebench_pgbench_avg_latency"
	PgbenchAvgLatencyHelp = "The avg latency of pgbench"

	PgbenchStdLatencyName = "kubebench_pgbench_std_latency"
	PgbenchStdLatencyHelp = "The std latency of pgbench"

	PgbenchInitialConnectionsTimeName = "kubebench_pgbench_initial_connections_time"
	PgbenchInitialConnectionsTimeHelp = "The initial connections time of pgbench"

	PgbenchTpsName = "kubebench_pgbench_tps"
	PgbenchTpsHelp = "The tps of pgbench"

	PgbenchTpsSecondName = "kubebench_pgbench_tps_second"
	PgbenchTpsSecondHelp = "The tps of pgbench per second"

	PgbenchAvgLatencySecondName = "kubebench_pgbench_avg_latency_second"
	PgbenchAvgLatencySecondHelp = "The avg latency of pgbench per second"

	PgbenchStdLatencySecondName = "kubebench_pgbench_std_latency_second"
	PgbenchStdLatencySecondHelp = "The std latency of pgbench per second"

	PgbenchTransactionsFailedSecondName = "kubebench_pgbench_transactions_failed_second"
	PgbenchTransactionsFailedSecondHelp = "The transactions failed of pgbench per second"
)
View Source
const (
	Sysbench = "sysbench"
	Pgbench  = "pgbench"
)
View Source
const (
	SysbenchQueryReadName = "kubebench_sysbench_query_read"
	SysbenchQueryReadHelp = "Sysbench query read result"

	SysbenchQueryWriteName = "kubebench_sysbench_query_write"
	SysbenchQueryWriteHelp = "Sysbench query write result"

	SysbenchQueryOtherName = "kubebench_sysbench_query_other"
	SysbenchQueryOtherHelp = "Sysbench query other result"

	SysbenchQueryTotalName = "kubebench_sysbench_query_total"
	SysbenchQueryTotalHelp = "Sysbench query total result"

	SysbenchTransactionsName = "kubebench_sysbench_transactions"
	SysbenchTransactionsHelp = "Sysbench transactions"

	SysbenchQueriesName = "kubebench_sysbench_queries"
	SysbenchQueriesHelp = "Sysbench queries"

	SysbenchIgnoredErrorsName = "kubebench_sysbench_ignored_errors"
	SysbenchIgnoredErrorsHelp = "Sysbench ignored errors"

	SysbenchReconnectsName = "kubebench_sysbench_reconnects"
	SysbenchReconnectsHelp = "Sysbench reconnects"

	SysbenchTotalTimeName = "kubebench_sysbench_total_time"
	SysbenchTotalTimeHelp = "Sysbench total time"

	SysbenchTotalEventsName = "kubebench_sysbench_total_events"
	SysbenchTotalEventsHelp = "Sysbench total events"

	SysbenchLatencyMinName = "kubebench_sysbench_latency_min"
	SysbenchLatencyMinHelp = "Sysbench latency min"

	SysbenchLatencyAvgName = "kubebench_sysbench_latency_avg"
	SysbenchLatencyAvgHelp = "Sysbench latency avg"

	SysbenchLatencyMaxName = "kubebench_sysbench_latency_max"
	SysbenchLatencyMaxHelp = "Sysbench latency max"

	SysbenchLatencyNinetyNinthName = "kubebench_sysbench_latency_ninety_ninth"
	SysbenchLatencyNinetyNinthHelp = "Sysbench latency ninety ninth"

	SysbenchLatencySumName = "kubebench_sysbench_latency_sum"
	SysbenchLatencySumHelp = "Sysbench latency sum"

	SysbenchEventsAvgName = "kubebench_sysbench_events_avg"
	SysbenchEventsAvgHelp = "Sysbench events avg"

	SysbenchEventsStddevName = "kubebench_sysbench_events_stddev"
	SysbenchEventsStddevHelp = "Sysbench events stddev"

	SysbenchExecTimeAvgName = "kubebench_sysbench_exec_time_avg"
	SysbenchExecTimeAvgHelp = "Sysbench exec time avg"

	SysbenchExecTimeStddevName = "kubebench_sysbench_exec_time_stddev"
	SysbenchExecTimeStddevHelp = "Sysbench exec time stddev"

	SysbenchThreadsName = "kubebench_sysbench_threads"
	SysbenchThreadsHelp = "Sysbench threads"

	SysbenchTpsSecondName = "kubebench_sysbench_tps_second"
	SysbenchTpsSecondHelp = "Sysbench tps every second"

	SysbenchQpsSecondName = "kubebench_sysbench_qps_second"
	SysbenchQpsSecondHelp = "Sysbench qps every second"

	SysbenchReadQpsSecondName = "kubebench_sysbench_read_qps_second"
	SysbenchReadQpsSecondHelp = "Sysbench read qps every second"

	SysbenchWriteQpsSecondName = "kubebench_sysbench_write_qps_second"
	SysbenchWriteQpsSecondHelp = "Sysbench write qps every second"

	SysbenchOtherQpsSecondName = "kubebench_sysbench_other_qps_second"
	SysbenchOtherQpsSecondHelp = "Sysbench other qps every second"

	SysbenchLatencySecondName = "kubebench_sysbench_latency_second"
	SysbenchLatencySecondHelp = "Sysbench latency every second"

	SysbenchErrorsSecondName = "kubebench_sysbench_errors_second"
	SysbenchErrorsSecondHelp = "Sysbench errors every second"

	SysbenchReconnectsSecondName = "kubebench_sysbench_reconnects_second"
	SysbenchReconnectsSecondHelp = "Sysbench reconnects every second"
)

Variables

View Source
var (
	KubebenchTotalLabels = []string{"benchmark", "name", "type"}
	KubebenchCounter     = NewCounter(KubebenchTotalName, KubebenchTotalHelp, KubebenchTotalLabels)
)
View Source
var (
	PgbenchLabels   = []string{"benchmark", "name"}
	PgbenchGaugeMap = map[string]*prometheus.GaugeVec{}
)
View Source
var (
	SysbenchLabels   = []string{"benchmark", "name"}
	SysbenchGaugeMap = map[string]*prometheus.GaugeVec{}
)

Functions

func CommonCounterInc

func CommonCounterInc(benchmark, name, typ string)

func InitMetrics

func InitMetrics()

func InitPgbench

func InitPgbench()

InitPgbench init the pgbench metrics

func InitSysbench

func InitSysbench()

InitSysbench init sysbench metrics

func NewCounter

func NewCounter(name string, help string, labels []string) *prometheus.CounterVec

func NewGauge

func NewGauge(name string, help string, labels []string) *prometheus.GaugeVec

func Register

func Register()

Register registers all metrics.

func RegisterCommon

func RegisterCommon()

func RegisterPgbenchMetrics

func RegisterPgbenchMetrics()

RegisterPgbenchMetrics registers the pgbench metrics

func RegisterSysbenchMetrics

func RegisterSysbenchMetrics()

RegisterSysbenchMetrics register sysbench metrics

func ScrapPgbench

func ScrapPgbench(file, benchName, jobName string)

func Scrape

func Scrape(benchType, file, benchName, jobName string, ch chan struct{})

Scrape is a function to scrape benchmark result from log.

func ScrapeSysbench

func ScrapeSysbench(file, benchName, jobName string)

func UpdatePgbenchMetrics

func UpdatePgbenchMetrics(benchName, jobName, msg string)

func UpdatePgbenchMetricsSecond

func UpdatePgbenchMetricsSecond(benchName, jobName, msg string)

func UpdateSysbenchMetrics

func UpdateSysbenchMetrics(benchName, jobName, msg string)

func UpdateSysbenchMetricsSecond

func UpdateSysbenchMetricsSecond(benchName, jobName, msg string)

Types

type GeneralStatistics

type GeneralStatistics struct {
	TotalTime   float64 `json:"totalTime"`
	TotalEvents int     `json:"totalEvents"`
}

type Latency

type Latency struct {
	Min         float64 `json:"min"`
	Avg         float64 `json:"avg"`
	Max         float64 `json:"max"`
	NinetyNinth float64 `json:"ninetyNinth"`
	Sum         float64 `json:"sum"`
}

type PgbenchResult

type PgbenchResult struct {
	Scale                  int     `json:"scale"`
	QueryMode              string  `json:"queryMode"`
	Clients                int     `json:"clients"`
	Threads                int     `json:"threads"`
	MaximumTry             int     `json:"maximumTry"`
	TransactionsPerClient  int     `json:"transactionsPerClient"`
	TransactionsProcessed  int     `json:"transactionsSum"`
	TransactionsFailed     int     `json:"failedTransactionsSum"`
	AvgLatency             float64 `json:"avgLatency"`
	StdLatency             float64 `json:"stdLatency"`
	InitialConnectionsTime float64 `json:"initialConnectionsTime"`
	TPS                    float64 `json:"tps"`
}

func ParsePgbenchResult

func ParsePgbenchResult(msg string) *PgbenchResult

type PgbenchSecondResult

type PgbenchSecondResult struct {
	TPS                   float64 `json:"tps"`
	AvgLatency            float64 `json:"avgLatency"`
	StdLatency            float64 `json:"stdLatency"`
	FailedTransactionsSum int     `json:"failedTransactionsSum"`
}

func ParsePgbenchSecondResult

func ParsePgbenchSecondResult(msg string) *PgbenchSecondResult

type SQLStatistics

type SQLStatistics struct {
	Read  int `json:"read"`
	Write int `json:"write"`
	Other int `json:"other"`
	Total int `json:"total"`
}

type SysbenchResult

type SysbenchResult struct {
	SQL             SQLStatistics     `json:"sql"`
	General         GeneralStatistics `json:"general"`
	Latency         Latency           `json:"latency"`
	ThreadsFairness ThreadsFairness   `json:"threadsFairness"`
	Transactions    int               `json:"transactions"`
	Queries         int               `json:"queries"`
	IgnoreErrors    int               `json:"ignoreErrors"`
	Reconnects      int               `json:"reconnects"`
}

func ParseSysBenchResult

func ParseSysBenchResult(msg string) *SysbenchResult

type SysbenchSecondResult

type SysbenchSecondResult struct {
	Threads     int     `json:"threads"`
	TPS         float64 `json:"tps"`
	QPS         float64 `json:"qps"`
	Read        float64 `json:"read"`
	Write       float64 `json:"write"`
	Other       float64 `json:"other"`
	NinetyNinth float64 `json:"ninetyNinth"`
	Errors      float64 `json:"errs"`
	Reconnects  float64 `json:"reconnects"`
}

func ParseSysbenchSecondResult

func ParseSysbenchSecondResult(msg string) *SysbenchSecondResult

type ThreadsFairness

type ThreadsFairness struct {
	EventsAvg    float64 `json:"eventsAvg"`
	EventsStddev float64 `json:"eventsStddev"`
	ExecTimeAvg  float64 `json:"execTimeAvg"`
	ExecTimeStd  float64 `json:"execTimeStd"`
}

Jump to

Keyboard shortcuts

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