Add path promotion files count metrics

Author: ligangty

addons/promote/common/pom.xml

@@ -61,6 +61,10 @@
       <groupId>org.commonjava.atlas</groupId>
       <artifactId>atlas-identities</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.commonjava.indy</groupId>
+      <artifactId>indy-subsys-metrics-reporter</artifactId>
+    </dependency>
   </dependencies>
 
   <build>

addons/promote/common/src/main/java/org/commonjava/indy/promote/data/PromotionManager.java

@@ -30,6 +30,7 @@
 import org.commonjava.indy.data.IndyDataException;
 import org.commonjava.indy.data.StoreDataManager;
 import org.commonjava.indy.measure.annotation.Measure;
+import org.commonjava.indy.metrics.IndyMetricsManager;
 import org.commonjava.indy.model.core.ArtifactStore;
 import org.commonjava.indy.model.core.Group;
 import org.commonjava.indy.model.core.HostedRepository;
@@ -64,6 +65,7 @@
 import java.io.InputStream;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ -93,6 +95,9 @@ public class PromotionManager
 
     private final Logger logger = LoggerFactory.getLogger( getClass() );
 
+    @Inject
+    private IndyMetricsManager metricsManager;
+
     @Inject
     private PromoteConfig config;
 
@@ -511,8 +516,10 @@ private PathsPromoteResult doPathsPromotion( PathsPromoteRequest request, String
         }
         else if ( validation.isValid() )
         {
-            return runPathPromotions( request, pending, Collections.emptySet(), Collections.emptySet(), contents,
-                                      validation, validationRequest );
+            PathsPromoteResult result = runPathPromotions( request, pending, Collections.emptySet(), Collections.emptySet(), contents,
+                                                           validation, validationRequest );
+            doPathPromoteMetrics( contents.size(), result );
+            return result;
         }
         else
         {
@@ -521,6 +528,22 @@ else if ( validation.isValid() )
         }
     }
 
+    private void doPathPromoteMetrics( int total, PathsPromoteResult result )
+    {
+        try
+        {
+            Map<String, Integer> pathPromoteMetrics = new HashMap<>();
+            pathPromoteMetrics.put( "total", total );
+            pathPromoteMetrics.put( "complete", result.getCompletedPaths().size() );
+            pathPromoteMetrics.put( "skipped", result.getSkippedPaths().size() );
+            metricsManager.addGauges( this.getClass(), "path.promote", pathPromoteMetrics );
+        }
+        catch ( Throwable e )
+        {
+            logger.warn( "Failed to get path promote files metrics. Reason: {} ", e.getMessage() );
+        }
+    }
+
     private Future<PathsPromoteResult> submitPathsPromoteRequest( PathsPromoteRequest request, final String baseUrl )
             throws IndyWorkflowException
     {

subsys/metrics/reporter/src/main/java/org/commonjava/indy/metrics/IndyMetricsManager.java

@@ -41,6 +41,7 @@
 
 import static com.codahale.metrics.MetricRegistry.name;
 import static org.apache.commons.lang.StringUtils.isNotBlank;
+import static org.commonjava.indy.metrics.IndyMetricsConstants.DEFAULT;
 import static org.commonjava.indy.metrics.IndyMetricsConstants.EXCEPTION;
 import static org.commonjava.indy.metrics.IndyMetricsConstants.METER;
 import static org.commonjava.indy.metrics.IndyMetricsConstants.SKIP_METRIC;
@@ -252,4 +253,13 @@ public <T> T wrapWithStandardMetrics( final Supplier<T> method, final Supplier<S
         }
     }
 
+    public <T> void addGauges( Class<?> className, String method, Map<String, T> gauges )
+    {
+        String defaultName = IndyMetricsConstants.getDefaultName( className, method );
+        gauges.forEach( ( k, t ) -> {
+            String name = IndyMetricsConstants.getName( config.getNodePrefix(), DEFAULT, defaultName, k );
+            metricRegistry.gauge( name, () -> () -> t );
+        } );
+    }
+
 }