File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -102,7 +102,7 @@ func handleNode() {
102102 if err != nil {
103103 panic (err )
104104 }
105- ns .AppendMetrics ( & meters )
105+ meters = append ( meters , ns .Metrics () ... )
106106 d .WithNodeServer (ns )
107107 err = d .Run ()
108108 if err != nil {
@@ -113,7 +113,7 @@ func handleNode() {
113113func handleController () {
114114 d := rclone .NewDriver (nodeID , endpoint )
115115 cs := rclone .NewControllerServer (d .CSIDriver )
116- cs .AppendMetrics ( & meters )
116+ meters = append ( meters , cs .Metrics () ... )
117117 d .WithControllerServer (cs )
118118 err := d .Run ()
119119 if err != nil {
Original file line number Diff line number Diff line change @@ -96,20 +96,27 @@ func NewControllerServer(csiDriver *csicommon.CSIDriver) *controllerServer {
9696 }
9797}
9898
99- func (ns * nodeServer ) AppendMetrics (meters * []metrics.Observable ) {
99+ func (ns * nodeServer ) Metrics () []metrics.Observable {
100+ var meters []metrics.Observable
101+
100102 // What should we meter?
101- return
103+
104+ return meters
102105}
103106
104- func (cs * controllerServer ) AppendMetrics (meters * []metrics.Observable ) {
107+ func (cs * controllerServer ) Metrics () []metrics.Observable {
108+ var meters []metrics.Observable
109+
105110 meter := prometheus .NewGauge (prometheus.GaugeOpts {
106- Name : "rclone_active_volume_count " ,
111+ Name : "csi_rclone_active_volume_count " ,
107112 Help : "Number of active (Mounted) volumes." ,
108113 })
109- * meters = append (* meters ,
114+ meters = append (meters ,
110115 func () { meter .Set (float64 (len (cs .active_volumes ))) },
111116 )
112117 prometheus .MustRegister (meter )
118+
119+ return meters
113120}
114121
115122func (d * Driver ) WithNodeServer (ns * nodeServer ) * Driver {
You can’t perform that action at this time.
0 commit comments