mirror of
https://github.com/prometheus/mysqld_exporter.git
synced 2025-04-18 09:24:02 +03:00
be5dc65671
* chore!: adopt log/slog, drop go-kit/log Requires: prometheus/common#697 This PR includes: - linter updates to enable `sloglint` linter - Go dep updates for prometheus/{client_golang,common,exporter-toolkit} libs - refactorings to adopt log/slog in favor of go-kit/log The bulk of this PR was automated by the following script which is being used to aid in converting the various exporters/projects to use slog: https://gist.github.com/tjhop/49f96fb7ebbe55b12deee0b0312d8434 Builds and passes tests locally with go workspaces and up-to-date main branch of prometheus/common. Signed-off-by: TJ Hoplock <t.hoplock@gmail.com> * build(deps): bump prometheus/common to v0.60.0 Signed-off-by: TJ Hoplock <t.hoplock@gmail.com> --------- Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
181 lines
6.4 KiB
Go
181 lines
6.4 KiB
Go
// Copyright 2018 The Prometheus Authors
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package collector
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/DATA-DOG/go-sqlmock"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
dto "github.com/prometheus/client_model/go"
|
|
"github.com/prometheus/common/promslog"
|
|
"github.com/smartystreets/goconvey/convey"
|
|
)
|
|
|
|
func TestScrapeEngineInnodbStatus(t *testing.T) {
|
|
db, mock, err := sqlmock.New()
|
|
if err != nil {
|
|
t.Fatalf("error opening a stub database connection: %s", err)
|
|
}
|
|
defer db.Close()
|
|
|
|
sample := `
|
|
=====================================
|
|
2016-09-14 19:04:38 0x7fed21462700 INNODB MONITOR OUTPUT
|
|
=====================================
|
|
Per second averages calculated from the last 30 seconds
|
|
-----------------
|
|
BACKGROUND THREAD
|
|
-----------------
|
|
srv_master_thread loops: 1 srv_active, 0 srv_shutdown, 49166 srv_idle
|
|
srv_master_thread log flush and writes: 49165
|
|
----------
|
|
SEMAPHORES
|
|
----------
|
|
OS WAIT ARRAY INFO: reservation count 15
|
|
OS WAIT ARRAY INFO: signal count 12
|
|
RW-shared spins 0, rounds 4, OS waits 2
|
|
RW-excl spins 0, rounds 0, OS waits 0
|
|
RW-sx spins 0, rounds 0, OS waits 0
|
|
Spin rounds per wait: 4.00 RW-shared, 0.00 RW-excl, 0.00 RW-sx
|
|
------------
|
|
TRANSACTIONS
|
|
------------
|
|
Trx id counter 67843
|
|
Purge done for trx's n:o < 55764 undo n:o < 0 state: running but idle
|
|
History list length 779
|
|
LIST OF TRANSACTIONS FOR EACH SESSION:
|
|
---TRANSACTION 422131596298608, not started
|
|
0 lock struct(s), heap size 1136, 0 row lock(s)
|
|
--------
|
|
FILE I/O
|
|
--------
|
|
I/O thread 0 state: waiting for completed aio requests (insert buffer thread)
|
|
I/O thread 1 state: waiting for completed aio requests (log thread)
|
|
I/O thread 2 state: waiting for completed aio requests (read thread)
|
|
I/O thread 3 state: waiting for completed aio requests (read thread)
|
|
I/O thread 4 state: waiting for completed aio requests (read thread)
|
|
I/O thread 5 state: waiting for completed aio requests (read thread)
|
|
I/O thread 6 state: waiting for completed aio requests (write thread)
|
|
I/O thread 7 state: waiting for completed aio requests (write thread)
|
|
I/O thread 8 state: waiting for completed aio requests (write thread)
|
|
I/O thread 9 state: waiting for completed aio requests (write thread)
|
|
Pending normal aio reads: [0, 0, 0, 0] , aio writes: [0, 0, 0, 0] ,
|
|
ibuf aio reads:, log i/o's:, sync i/o's:
|
|
Pending flushes (fsync) log: 0; buffer pool: 0
|
|
512 OS file reads, 57 OS file writes, 8 OS fsyncs
|
|
0.00 reads/s, 0 avg bytes/read, 0.00 writes/s, 0.00 fsyncs/s
|
|
-------------------------------------
|
|
INSERT BUFFER AND ADAPTIVE HASH INDEX
|
|
-------------------------------------
|
|
Ibuf: size 1, free list len 0, seg size 2, 0 merges
|
|
merged operations:
|
|
insert 0, delete mark 0, delete 0
|
|
discarded operations:
|
|
insert 0, delete mark 0, delete 0
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
Hash table size 34673, node heap has 0 buffer(s)
|
|
0.00 hash searches/s, 0.00 non-hash searches/s
|
|
---
|
|
LOG
|
|
---
|
|
Log sequence number 37771171
|
|
Log flushed up to 37771171
|
|
Pages flushed up to 37771171
|
|
Last checkpoint at 37771162
|
|
Max checkpoint age 80826164
|
|
Checkpoint age target 78300347
|
|
Modified age 0
|
|
Checkpoint age 9
|
|
0 pending log flushes, 0 pending chkp writes
|
|
10 log i/o's done, 0.00 log i/o's/second
|
|
----------------------
|
|
BUFFER POOL AND MEMORY
|
|
----------------------
|
|
Total large memory allocated 139722752
|
|
Dictionary memory allocated 367821
|
|
Internal hash tables (constant factor + variable factor)
|
|
Adaptive hash index 2252736 (2219072 + 33664)
|
|
Page hash 139112 (buffer pool 0 only)
|
|
Dictionary cache 922589 (554768 + 367821)
|
|
File system 839328 (812272 + 27056)
|
|
Lock system 334008 (332872 + 1136)
|
|
Recovery system 0 (0 + 0)
|
|
Buffer pool size 8191
|
|
Buffer pool size, bytes 0
|
|
Free buffers 7684
|
|
Database pages 507
|
|
Old database pages 0
|
|
Modified db pages 0
|
|
Pending reads 0
|
|
Pending writes: LRU 0, flush list 0, single page 0
|
|
Pages made young 0, not young 0
|
|
0.00 youngs/s, 0.00 non-youngs/s
|
|
Pages read 473, created 34, written 36
|
|
0.00 reads/s, 0.00 creates/s, 0.00 writes/s
|
|
No buffer pool page gets since the last printout
|
|
Pages read ahead 0.00/s, evicted without access 0.00/s, Random read ahead 0.00/s
|
|
LRU len: 507, unzip_LRU len: 0
|
|
I/O sum[0]:cur[0], unzip sum[0]:cur[0]
|
|
--------------
|
|
ROW OPERATIONS
|
|
--------------
|
|
661 queries inside InnoDB, 10 queries in queue
|
|
15 read views open inside InnoDB
|
|
0 RW transactions active inside InnoDB
|
|
Process ID=1, Main thread ID=140656308950784, state: sleeping
|
|
Number of rows inserted 0, updated 0, deleted 0, read 12
|
|
0.00 inserts/s, 0.00 updates/s, 0.00 deletes/s, 0.00 reads/s
|
|
----------------------------
|
|
END OF INNODB MONITOR OUTPUT
|
|
============================
|
|
`
|
|
columns := []string{"Type", "Name", "Status"}
|
|
rows := sqlmock.NewRows(columns).AddRow("InnoDB", "", sample)
|
|
|
|
mock.ExpectQuery(sanitizeQuery(engineInnodbStatusQuery)).WillReturnRows(rows)
|
|
inst := &instance{db: db}
|
|
ch := make(chan prometheus.Metric)
|
|
go func() {
|
|
if err = (ScrapeEngineInnodbStatus{}).Scrape(context.Background(), inst, ch, promslog.NewNopLogger()); err != nil {
|
|
t.Errorf("error calling function on test: %s", err)
|
|
}
|
|
close(ch)
|
|
}()
|
|
|
|
metricsExpected := []MetricResult{
|
|
{labels: labelMap{}, value: 661, metricType: dto.MetricType_GAUGE},
|
|
{labels: labelMap{}, value: 10, metricType: dto.MetricType_GAUGE},
|
|
{labels: labelMap{}, value: 15, metricType: dto.MetricType_GAUGE},
|
|
}
|
|
convey.Convey("Metrics comparison", t, func() {
|
|
for _, expect := range metricsExpected {
|
|
got := readMetric(<-ch)
|
|
convey.So(got, convey.ShouldResemble, expect)
|
|
}
|
|
})
|
|
|
|
// Ensure all SQL queries were executed
|
|
if err := mock.ExpectationsWereMet(); err != nil {
|
|
t.Errorf("there were unfulfilled exceptions: %s", err)
|
|
}
|
|
}
|