Add release duration stats

- Add azure_devops_stats_project_release_duration metric

Author: mblaschke

README.md

@@ -83,6 +83,7 @@ Metrics
 | `azure_devops_stats_project_builds`             | stats         | Number of builds per project, definition and result (counter)                        |
 | `azure_devops_stats_project_builds_wait`        | stats         | Build wait time per project, definition and result (summary)                         |
 | `azure_devops_stats_project_builds_duration`    | stats         | Build duration per project, definition and result (summary)                          |
+| `azure_devops_stats_project_release_duration`   | stats         | Release environment duration per project, definition, environment and result (summary) |
 | `azure_devops_resourceusage_build`              | resourceusage | Usage of limited and paid Azure DevOps resources                                     |
 
 

azure-devops-client/release.go

@@ -148,12 +148,10 @@ func (r *Release) QueueDuration() time.Duration {
 	return r.StartTime.Sub(r.QueueTime)
 }
 
-func (c *AzureDevopsClient) ListLatestReleases(project string, duration time.Duration) (list ReleaseList, error error) {
+func (c *AzureDevopsClient) ListLatestReleases(project string, minTime time.Time) (list ReleaseList, error error) {
 	defer c.concurrencyUnlock()
 	c.concurrencyLock()
 
-	minTime := time.Now().Add(- duration)
-
 	url := fmt.Sprintf(
 		"%v/_apis/release/releases?api-version=%v&isDeleted=false&$expand=94&minCreatedTime=%s&$top=%v",
 		url.QueryEscape(project),

metrics_release.go

@@ -207,10 +207,11 @@ func (m *MetricsCollectorRelease) Collect(ctx context.Context, callback chan<- f
 
 	// --------------------------------------
 	// Releases
+	minTime := time.Now().Add(- time.Duration(opts.LimitReleaseDuration))
 
-	releaseList, err := AzureDevopsClient.ListLatestReleases(project.Id, time.Duration(24 * time.Hour))
+	releaseList, err := AzureDevopsClient.ListLatestReleases(project.Id, minTime)
 	if err != nil {
-		Logger.Errorf("project[%v]call[ListReleases]: %v", project.Name, err)
+		Logger.Errorf("project[%v]call[ListLatestReleases]: %v", project.Name, err)
 		return
 	}
 

metrics_stats.go

@@ -17,6 +17,7 @@ type MetricsCollectorStats struct {
 		projectBuildCount    *prometheus.CounterVec
 		projectBuildWait     *prometheus.SummaryVec
 		projectBuildDuration *prometheus.SummaryVec
+		projectReleaseDuration *prometheus.SummaryVec
 	}
 }
 
@@ -107,20 +108,63 @@ func (m *MetricsCollectorStats) Setup(collector *CollectorProject) {
 		},
 	)
 
+	m.prometheus.projectReleaseDuration = prometheus.NewSummaryVec(
+		prometheus.SummaryOpts{
+			Name:   "azure_devops_stats_project_release_duration",
+			Help:   "Azure DevOps stats project release process duration",
+			MaxAge: *opts.StatsSummaryMaxAge,
+		},
+		[]string{
+			"projectID",
+			"releaseDefinitionID",
+			"definitionEnvironmentID",
+			"status",
+		},
+	)
+
+
 	prometheus.MustRegister(m.prometheus.agentPoolBuildCount)
 	prometheus.MustRegister(m.prometheus.agentPoolBuildWait)
 	prometheus.MustRegister(m.prometheus.agentPoolBuildDuration)
 
 	prometheus.MustRegister(m.prometheus.projectBuildCount)
 	prometheus.MustRegister(m.prometheus.projectBuildWait)
 	prometheus.MustRegister(m.prometheus.projectBuildDuration)
+
+	prometheus.MustRegister(m.prometheus.projectReleaseDuration)
 }
 
 func (m *MetricsCollectorStats) Reset() {
 }
 
 func (m *MetricsCollectorStats) Collect(ctx context.Context, callback chan<- func(), project devopsClient.Project) {
 	m.CollectBuilds(ctx, callback, project)
+	m.CollectReleases(ctx, callback, project)
+}
+
+func (m *MetricsCollectorStats) CollectReleases(ctx context.Context, callback chan<- func(), project devopsClient.Project) {
+	minTime := *m.CollectorReference.collectionLastTime
+
+	releaseList, err := AzureDevopsClient.ListLatestReleases(project.Id, minTime)
+	if err != nil {
+		Logger.Errorf("project[%v]call[ListLatestReleases]: %v", project.Name, err)
+		return
+	}
+
+	for _, release := range releaseList.List {
+		for _, environment := range release.Environments {
+			timeToDeploy := environment.TimeToDeploy * 60
+
+			if timeToDeploy > 0 {
+				m.prometheus.projectReleaseDuration.With(prometheus.Labels{
+					"projectID":         release.Project.Id,
+					"releaseDefinitionID": int64ToString(release.Definition.Id),
+					"definitionEnvironmentID": int64ToString(environment.DefinitionEnvironmentId),
+					"status":            environment.Status,
+				}).Observe(timeToDeploy)
+			}
+		}
+	}
 }
 
 func (m *MetricsCollectorStats) CollectBuilds(ctx context.Context, callback chan<- func(), project devopsClient.Project) {