Documentation
¶
Index ¶
- Constants
- Variables
- func CommonCounterInc(benchmark, name, typ string)
- func InitEsrally()
- func InitMetrics()
- func InitPgbench()
- func InitSysbench()
- func NewCounter(name string, help string, labels []string) *prometheus.CounterVec
- func NewGauge(name string, help string, labels []string) *prometheus.GaugeVec
- func Register()
- func RegisterCommon()
- func RegisterEsrallyMetrics()
- func RegisterPgbenchMetrics()
- func RegisterSysbenchMetrics()
- func ScrapPgbench(file, benchName, jobName string)
- func Scrape(benchType, file, benchName, jobName, doneFile string, ch chan struct{})
- func ScrapeEsrally(file, doneFile, benchName, jobName string)
- func ScrapeSysbench(file, benchName, jobName string)
- func SummarizeEsrallyCSV(msg string, limit int) string
- func UpdateEsrallyMetrics(benchName, jobName, msg string) bool
- func UpdatePgbenchMetrics(benchName, jobName, msg string)
- func UpdatePgbenchMetricsSecond(benchName, jobName, msg string)
- func UpdateSysbenchMetrics(benchName, jobName, msg string)
- func UpdateSysbenchMetricsSecond(benchName, jobName, msg string)
- type EsrallyMetric
- type GeneralStatistics
- type Latency
- type PgbenchResult
- type PgbenchSecondResult
- type SQLStatistics
- type SysbenchResult
- type SysbenchSecondResult
- type ThreadsFairness
Constants ¶
View Source
const ( KubebenchTotalName = "kubebench_total" KubebenchTotalHelp = "Total number of kubebench runs" )
View Source
const ( EsrallyMetricValueName = "kubebench_esrally_metric_value" EsrallyMetricValueHelp = "Numeric Elastic Rally summary report value" )
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" Esrally = "esrally" )
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 ( EsrallyLabels = []string{"benchmark", "name", "metric", "task", "unit"} EsrallyGaugeMap = map[string]*prometheus.GaugeVec{} )
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 InitEsrally ¶
func InitEsrally()
func InitMetrics ¶
func InitMetrics()
func NewCounter ¶
func NewCounter(name string, help string, labels []string) *prometheus.CounterVec
func RegisterCommon ¶
func RegisterCommon()
func RegisterEsrallyMetrics ¶
func RegisterEsrallyMetrics()
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, doneFile string, ch chan struct{})
Scrape is a function to scrape benchmark result from log.
func ScrapeEsrally ¶
func ScrapeEsrally(file, doneFile, benchName, jobName string)
func ScrapeSysbench ¶
func ScrapeSysbench(file, benchName, jobName string)
func SummarizeEsrallyCSV ¶
func UpdateEsrallyMetrics ¶
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 EsrallyMetric ¶
func ParseEsrallyCSV ¶
func ParseEsrallyCSV(msg string) []EsrallyMetric
type GeneralStatistics ¶
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 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
Click to show internal directories.
Click to hide internal directories.