Zabbix

/*

** Zabbix

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software; you can redistribute it and/or modify

** it under the terms of the GNU General Public License as published by

** the Free Software Foundation; either version 2 of the License, or

** (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

** GNU General Public License for more details.

**

** You should have received a copy of the GNU General Public License

** along with this program; if not, write to the Free Software

** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

**/

​

package mysql

​

import (

    "context"

​

    "golang.zabbix.com/sdk/errs"

    "golang.zabbix.com/sdk/metric"

    "golang.zabbix.com/sdk/plugin"

    "golang.zabbix.com/sdk/uri"

)

​

const (

    keyCustomQuery            = "mysql.custom.query"

    keyDatabasesDiscovery     = "mysql.db.discovery"

    keyDatabaseSize           = "mysql.db.size"

    keyPing                   = "mysql.ping"

    keyReplicationDiscovery   = "mysql.replication.discovery"

    keyReplicationSlaveStatus = "mysql.replication.get_slave_status"

    keyStatusVars             = "mysql.get_status_variables"

    keyVersion                = "mysql.version"

​

    uriParam        = "URI"

    tlsConnectParam = "TLSConnect"

    tlsCAParam      = "TLSCAFile"

    tlsCertParam    = "TLSCertFile"

    tlsKeyParam     = "TLSKeyFile"

    masterHostParam = "Master"

)

​

var (

    uriDefaults = &uri.Defaults{Scheme: "tcp", Port: "3306"}

​

    // Common params: [URI|Session][,User][,Password]

    paramURI = metric.NewConnParam(uriParam, "URI to connect or session name.").

            WithDefault(uriDefaults.Scheme + "://localhost:" + uriDefaults.Port).WithSession().

            WithValidator(uri.URIValidator{Defaults: uriDefaults, AllowedSchemes: []string{"tcp", "unix"}})

    paramUsername    = metric.NewConnParam("User", "MySQL user.").WithDefault("root")

    paramPassword    = metric.NewConnParam("Password", "User's password.").WithDefault("")

    paramTLSConnect  = metric.NewSessionOnlyParam(tlsConnectParam, "DB connection encryption type.").WithDefault("")

    paramTLSCaFile   = metric.NewSessionOnlyParam(tlsCAParam, "TLS ca file path.").WithDefault("")

    paramTLSCertFile = metric.NewSessionOnlyParam(tlsCertParam, "TLS cert file path.").WithDefault("")

    paramTLSKeyFile  = metric.NewSessionOnlyParam(tlsKeyParam, "TLS key file path.").WithDefault("")

​

    metrics = metric.MetricSet{