diff --git a/collector/remote_info.go b/collector/remote_info.go index a9d0d4ce..1ffd3534 100644 --- a/collector/remote_info.go +++ b/collector/remote_info.go @@ -72,6 +72,17 @@ func NewRemoteInfo(logger log.Logger, client *http.Client, url *url.URL) *Remote }, Labels: defaultRemoteInfoLabelValues, }, + { + Type: prometheus.GaugeValue, + Desc: prometheus.NewDesc( + prometheus.BuildFQName(namespace, "remote_info", "num_proxy_sockets_connected"), + "Number of proxy sockets connected", defaulRemoteInfoLabels, nil, + ), + Value: func(remoteStats RemoteCluster) float64 { + return float64(remoteStats.NumProxySocketsConnected) + }, + Labels: defaultRemoteInfoLabelValues, + }, { Type: prometheus.GaugeValue, Desc: prometheus.NewDesc( diff --git a/collector/remote_info_response.go b/collector/remote_info_response.go index 20fdcb99..b1e9387e 100644 --- a/collector/remote_info_response.go +++ b/collector/remote_info_response.go @@ -8,6 +8,7 @@ type RemoteCluster struct { Seeds []string `json:"seeds"` Connected bool `json:"connected"` NumNodesConnected int64 `json:"num_nodes_connected"` + NumProxySocketsConnected int64 `json:"num_proxy_sockets_connected"` MaxConnectionsPerCluster int64 `json:"max_connections_per_cluster"` InitialConnectTimeout string `json:"initial_connect_timeout"` SkipUnavailable bool `json:"skip_unavailable"`