collector

type ColumnMapping ¶ added in v0.10.1

type ColumnMapping struct {
	// contains filtered or unexported fields
}

ColumnMapping is the user-friendly representation of a prometheus descriptor map.

func (cm *ColumnMapping) UnmarshalYAML(unmarshal func(interface{}) error) error

type ColumnUsage ¶ added in v0.10.1

type ColumnUsage int

ColumnUsage should be one of several enum values which describe how a queried row is to be converted to a Prometheus metric.

func (cu *ColumnUsage) UnmarshalYAML(unmarshal func(interface{}) error) error

type CustomQuery ¶ added in v0.10.1

type CustomQuery struct {
	// contains filtered or unexported fields
}

CustomQuery - contains MySQL query parsed from YAML file.

type Exporter ¶ added in v0.10.1

type Exporter struct {
	// contains filtered or unexported fields
}

Exporter collects MySQL metrics. It implements prometheus.Collector.

func New(ctx context.Context, db *sql.DB, metrics Metrics, scrapers []Scraper) *Exporter

func (e *Exporter) Collect(ch chan<- prometheus.Metric)

func (e *Exporter) Describe(ch chan<- *prometheus.Desc)

type MetricMap ¶ added in v0.10.1

type MetricMap struct {
	// contains filtered or unexported fields
}

MetricMap stores the prometheus metric description which a given column will be mapped to by the collector.

type MetricMapNamespace ¶ added in v0.10.1

type MetricMapNamespace struct {
	// contains filtered or unexported fields
}

MetricMapNamespace groups metric maps under a shared set of labels.

type MetricResolution ¶ added in v0.10.1

type MetricResolution string

const (
	LR MetricResolution = "lr"
	MR MetricResolution = "mr"
	HR MetricResolution = "hr"
)

type Metrics ¶ added in v0.10.1

type Metrics struct {
	TotalScrapes prometheus.Counter
	ScrapeErrors *prometheus.CounterVec
	Error        prometheus.Gauge
	MySQLUp      prometheus.Gauge
}

Metrics represents exporter metrics which values can be carried between http requests.

func NewMetrics(resolution string) Metrics

type ScrapeAutoIncrementColumns ¶

type ScrapeAutoIncrementColumns struct{}

ScrapeAutoIncrementColumns collects auto_increment column information.

func (ScrapeAutoIncrementColumns) Help() string

func (ScrapeAutoIncrementColumns) Name() string

func (ScrapeAutoIncrementColumns) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeAutoIncrementColumns) Version() float64

type ScrapeBinlogSize ¶

type ScrapeBinlogSize struct{}

ScrapeBinlogSize colects from `SHOW BINARY LOGS`.

func (ScrapeBinlogSize) Help() string

func (ScrapeBinlogSize) Name() string

func (ScrapeBinlogSize) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeBinlogSize) Version() float64

type ScrapeClientStat ¶

type ScrapeClientStat struct{}

ScrapeClientStat collects from `information_schema.client_statistics`.

func (ScrapeClientStat) Help() string

func (ScrapeClientStat) Name() string

func (ScrapeClientStat) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeClientStat) Version() float64

type ScrapeCustomQuery ¶ added in v0.10.1

type ScrapeCustomQuery struct {
	Resolution MetricResolution
}

ScrapeCustomQuery colects the metrics from custom queries.

func (scq ScrapeCustomQuery) Help() string

func (scq ScrapeCustomQuery) Name() string

func (scq ScrapeCustomQuery) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (scq ScrapeCustomQuery) Version() float64

type ScrapeEngineInnodbStatus ¶

type ScrapeEngineInnodbStatus struct{}

ScrapeEngineInnodbStatus scrapes from `SHOW ENGINE INNODB STATUS`.

func (ScrapeEngineInnodbStatus) Help() string

func (ScrapeEngineInnodbStatus) Name() string

func (ScrapeEngineInnodbStatus) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeEngineInnodbStatus) Version() float64

type ScrapeEngineTokudbStatus ¶

type ScrapeEngineTokudbStatus struct{}

ScrapeEngineTokudbStatus scrapes from `SHOW ENGINE TOKUDB STATUS`.

func (ScrapeEngineTokudbStatus) Help() string

func (ScrapeEngineTokudbStatus) Name() string

func (ScrapeEngineTokudbStatus) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeEngineTokudbStatus) Version() float64

type ScrapeGlobalStatus ¶

type ScrapeGlobalStatus struct{}

ScrapeGlobalStatus collects from `SHOW GLOBAL STATUS`.

func (ScrapeGlobalStatus) Help() string

func (ScrapeGlobalStatus) Name() string

func (ScrapeGlobalStatus) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeGlobalStatus) Version() float64

type ScrapeGlobalVariables ¶

type ScrapeGlobalVariables struct{}

ScrapeGlobalVariables collects from `SHOW GLOBAL VARIABLES`.

func (ScrapeGlobalVariables) Help() string

func (ScrapeGlobalVariables) Name() string

func (ScrapeGlobalVariables) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeGlobalVariables) Version() float64

type ScrapeHeartbeat ¶ added in v0.10.0

type ScrapeHeartbeat struct{}

ScrapeHeartbeat scrapes from the heartbeat table. This is mainly targeting pt-heartbeat, but will work with any heartbeat implementation that writes to a table with two columns: CREATE TABLE heartbeat (

ts                    varchar(26) NOT NULL,
server_id             int unsigned NOT NULL PRIMARY KEY,

);

func (ScrapeHeartbeat) Help() string

func (ScrapeHeartbeat) Name() string

func (ScrapeHeartbeat) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeHeartbeat) Version() float64

type ScrapeInfoSchemaInnodbTablespaces ¶

type ScrapeInfoSchemaInnodbTablespaces struct{}

ScrapeInfoSchemaInnodbTablespaces collects from `information_schema.innodb_sys_tablespaces`.

func (ScrapeInfoSchemaInnodbTablespaces) Help() string

func (ScrapeInfoSchemaInnodbTablespaces) Name() string

func (ScrapeInfoSchemaInnodbTablespaces) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeInfoSchemaInnodbTablespaces) Version() float64

type ScrapeInnodbCmp ¶ added in v0.10.1

type ScrapeInnodbCmp struct{}

ScrapeInnodbCmp collects from `information_schema.innodb_cmp`.

func (ScrapeInnodbCmp) Help() string

func (ScrapeInnodbCmp) Name() string

func (ScrapeInnodbCmp) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeInnodbCmp) Version() float64

type ScrapeInnodbCmpMem ¶ added in v0.10.1

type ScrapeInnodbCmpMem struct{}

ScrapeInnodbCmpMem collects from `information_schema.innodb_cmpmem`.

func (ScrapeInnodbCmpMem) Help() string

func (ScrapeInnodbCmpMem) Name() string

func (ScrapeInnodbCmpMem) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeInnodbCmpMem) Version() float64

type ScrapeInnodbMetrics ¶

type ScrapeInnodbMetrics struct{}

ScrapeInnodbMetrics collects from `information_schema.innodb_metrics`.

func (ScrapeInnodbMetrics) Help() string

func (ScrapeInnodbMetrics) Name() string

func (ScrapeInnodbMetrics) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeInnodbMetrics) Version() float64

type ScrapePerfEventsStatements ¶

type ScrapePerfEventsStatements struct{}

ScrapePerfEventsStatements collects from `performance_schema.events_statements_summary_by_digest`.

func (ScrapePerfEventsStatements) Help() string

func (ScrapePerfEventsStatements) Name() string

func (ScrapePerfEventsStatements) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfEventsStatements) Version() float64

type ScrapePerfEventsWaits ¶

type ScrapePerfEventsWaits struct{}

ScrapePerfEventsWaits collects from `performance_schema.events_waits_summary_global_by_event_name`.

func (ScrapePerfEventsWaits) Help() string

func (ScrapePerfEventsWaits) Name() string

func (ScrapePerfEventsWaits) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfEventsWaits) Version() float64

type ScrapePerfFileEvents ¶

type ScrapePerfFileEvents struct{}

ScrapePerfFileEvents collects from `performance_schema.file_summary_by_event_name`.

func (ScrapePerfFileEvents) Help() string

func (ScrapePerfFileEvents) Name() string

func (ScrapePerfFileEvents) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfFileEvents) Version() float64

type ScrapePerfFileInstances ¶ added in v0.10.0

type ScrapePerfFileInstances struct{}

ScrapePerfFileInstances collects from `performance_schema.file_summary_by_instance`.

func (ScrapePerfFileInstances) Help() string

func (ScrapePerfFileInstances) Name() string

func (ScrapePerfFileInstances) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfFileInstances) Version() float64

type ScrapePerfIndexIOWaits ¶

type ScrapePerfIndexIOWaits struct{}

ScrapePerfIndexIOWaits collects for `performance_schema.table_io_waits_summary_by_index_usage`.

func (ScrapePerfIndexIOWaits) Help() string

func (ScrapePerfIndexIOWaits) Name() string

func (ScrapePerfIndexIOWaits) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfIndexIOWaits) Version() float64

type ScrapePerfTableIOWaits ¶

type ScrapePerfTableIOWaits struct{}

ScrapePerfTableIOWaits collects from `performance_schema.table_io_waits_summary_by_table`.

func (ScrapePerfTableIOWaits) Help() string

func (ScrapePerfTableIOWaits) Name() string

func (ScrapePerfTableIOWaits) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfTableIOWaits) Version() float64

type ScrapePerfTableLockWaits ¶

type ScrapePerfTableLockWaits struct{}

ScrapePerfTableLockWaits collects from `performance_schema.table_lock_waits_summary_by_table`.

func (ScrapePerfTableLockWaits) Help() string

func (ScrapePerfTableLockWaits) Name() string

func (ScrapePerfTableLockWaits) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapePerfTableLockWaits) Version() float64

type ScrapeProcesslist ¶

type ScrapeProcesslist struct{}

ScrapeProcesslist collects from `information_schema.processlist`.

func (ScrapeProcesslist) Help() string

func (ScrapeProcesslist) Name() string

func (ScrapeProcesslist) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeProcesslist) Version() float64

type ScrapeQueryResponseTime ¶

type ScrapeQueryResponseTime struct{}

ScrapeQueryResponseTime collects from `information_schema.query_response_time`.

func (ScrapeQueryResponseTime) Help() string

func (ScrapeQueryResponseTime) Name() string

func (ScrapeQueryResponseTime) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeQueryResponseTime) Version() float64

type ScrapeSlaveStatus ¶

type ScrapeSlaveStatus struct{}

ScrapeSlaveStatus collects from `SHOW SLAVE STATUS`.

func (ScrapeSlaveStatus) Help() string

func (ScrapeSlaveStatus) Name() string

func (ScrapeSlaveStatus) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeSlaveStatus) Version() float64

type ScrapeTableSchema ¶

type ScrapeTableSchema struct{}

ScrapeTableSchema collects from `information_schema.tables`.

func (ScrapeTableSchema) Help() string

func (ScrapeTableSchema) Name() string

func (ScrapeTableSchema) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) (e error)

func (ScrapeTableSchema) Version() float64

type ScrapeTableStat ¶

type ScrapeTableStat struct{}

ScrapeTableStat collects from `information_schema.table_statistics`.

func (ScrapeTableStat) Help() string

func (ScrapeTableStat) Name() string

func (ScrapeTableStat) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeTableStat) Version() float64

type ScrapeUserStat ¶

type ScrapeUserStat struct{}

ScrapeUserStat collects from `information_schema.user_statistics`.

func (ScrapeUserStat) Help() string

func (ScrapeUserStat) Name() string

func (ScrapeUserStat) Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

func (ScrapeUserStat) Version() float64

type Scraper ¶ added in v0.10.1

type Scraper interface {
	Scrape(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error
	Name() string
	Help() string
	Version() float64
}

func NewStandardGo() Scraper

func NewStandardProcess() Scraper