diff --git a/etcdserver/api/membership/metrics.go b/etcdserver/api/membership/metrics.go new file mode 100644 index 000000000000..b3212bc80cdb --- /dev/null +++ b/etcdserver/api/membership/metrics.go @@ -0,0 +1,31 @@ +// Copyright 2018 The etcd 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 membership + +import "github.com/prometheus/client_golang/prometheus" + +var ( + ClusterVersionMetrics = prometheus.NewGaugeVec(prometheus.GaugeOpts{ + Namespace: "etcd", + Subsystem: "cluster", + Name: "version", + Help: "Which version is running. 1 for 'cluster_version' label with current cluster version", + }, + []string{"cluster_version"}) +) + +func init() { + prometheus.MustRegister(ClusterVersionMetrics) +} diff --git a/etcdserver/membership/cluster.go b/etcdserver/membership/cluster.go index 4f0b1572ef68..a04bf1d3a3f0 100644 --- a/etcdserver/membership/cluster.go +++ b/etcdserver/membership/cluster.go @@ -36,6 +36,7 @@ import ( "github.com/coreos/etcd/version" "github.com/coreos/go-semver/semver" + "github.com/prometheus/client_golang/prometheus" ) // RaftCluster is a list of Members that belong to the same raft cluster @@ -376,6 +377,7 @@ func (c *RaftCluster) SetVersion(ver *semver.Version, onSet func(*semver.Version if c.be != nil { mustSaveClusterVersionToBackend(c.be, ver) } + ClusterVersionMetrics.With(prometheus.Labels{"cluster_version": ver.String()}).Set(1) onSet(ver) } diff --git a/etcdserver/server.go b/etcdserver/server.go index f46e91d3469b..581acd599fff 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -602,6 +602,7 @@ func (s *EtcdServer) start() { s.leaderChanged = make(chan struct{}) if s.ClusterVersion() != nil { plog.Infof("starting server... [version: %v, cluster version: %v]", version.Version, version.Cluster(s.ClusterVersion().String())) + membership.ClusterVersionMetrics.With(prometheus.Labels{"cluster_version": s.ClusterVersion().String()}).Set(1) } else { plog.Infof("starting server... [version: %v, cluster version: to_be_decided]", version.Version) }