Documentation ¶
Index ¶
- Constants
- Variables
- func CommonCounterInc(benchmark, name, typ string)
- 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 RegisterPgbenchMetrics()
- func RegisterSysbenchMetrics()
- func ScrapPgbench(file, benchName, jobName string)
- func Scrape(benchType, file, benchName, jobName string, ch chan struct{})
- func ScrapeSysbench(file, benchName, jobName string)
- 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 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 ( 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 NewCounter ¶
func NewCounter(name string, help string, labels []string) *prometheus.CounterVec
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 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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.