Add new metrics for repository (#183)

* Fix the commit count metric

* Add a new index for repo

* Add new metrics for active repositories count

* Add docs for metrics

Author: Noah Hanjun Lee

docs/concepts/metrics.md

@@ -41,3 +41,5 @@ Gitploy provides the following Gitploy metrics. *Note that Some metrics are prov
 * **gitploy_total_commit_count**<br/> The total commit count of production deployments.
 * **gitploy_member_count**<br/> The total count of members.
 * **gitploy_member_limit**<br/> The limit count of members.
+* **gitploy_total_active_repo_count**<br/> The count of active repositories.
+* **gitploy_total_repo_count**<br/> The count of repositories.

ent/migrate/schema.go

@@ -69,5 +69,7 @@ func (Repo) Indexes() []ent.Index {
 		index.Fields("namespace", "name").
 			Unique(),
 		index.Fields("name"),
+		// Count active repositories for metrics.
+		index.Fields("active"),
 	}
 }

ent/schema/repo.go

@@ -14,11 +14,11 @@ import (
 
 type (
 	Store interface {
+		CountUsers(context.Context) (int, error)
 		ListUsers(ctx context.Context, login string, page, perPage int) ([]*ent.User, error)
 		FindUserByID(ctx context.Context, id int64) (*ent.User, error)
 		FindUserByHash(ctx context.Context, hash string) (*ent.User, error)
 		FindUserByLogin(ctx context.Context, login string) (*ent.User, error)
-		CountUsers(context.Context) (int, error)
 		CreateUser(ctx context.Context, u *ent.User) (*ent.User, error)
 		UpdateUser(ctx context.Context, u *ent.User) (*ent.User, error)
 		DeleteUser(ctx context.Context, u *ent.User) error
@@ -28,6 +28,8 @@ type (
 		UpdateChatUser(ctx context.Context, cu *ent.ChatUser) (*ent.ChatUser, error)
 		DeleteChatUser(ctx context.Context, cu *ent.ChatUser) error
 
+		CountActiveRepos(ctx context.Context) (int, error)
+		CountRepos(ctx context.Context) (int, error)
 		ListReposOfUser(ctx context.Context, u *ent.User, q, namespace, name string, sorted bool, page, perPage int) ([]*ent.Repo, error)
 		FindRepoOfUserByID(ctx context.Context, u *ent.User, id int64) (*ent.Repo, error)
 		FindRepoOfUserByNamespaceName(ctx context.Context, u *ent.User, namespace, name string) (*ent.Repo, error)

internal/interactor/interface.go

@@ -11,6 +11,19 @@ import (
 	"github.com/gitploy-io/gitploy/vo"
 )
 
+func (s *Store) CountActiveRepos(ctx context.Context) (int, error) {
+	return s.c.Repo.
+		Query().
+		Where(repo.ActiveEQ(true)).
+		Count(ctx)
+}
+
+func (s *Store) CountRepos(ctx context.Context) (int, error) {
+	return s.c.Repo.
+		Query().
+		Count(ctx)
+}
+
 func (s *Store) ListReposOfUser(ctx context.Context, u *ent.User, q, namespace, name string, sorted bool, page, perPage int) ([]*ent.Repo, error) {
 	// Build the query with parameters.
 	qry := s.c.Repo.

internal/interactor/mock/pkg.go

@@ -10,6 +10,8 @@ import (
 
 type (
 	Interactor interface {
+		CountActiveRepos(ctx context.Context) (int, error)
+		CountRepos(ctx context.Context) (int, error)
 		ListAllDeploymentStatistics(ctx context.Context) ([]*ent.DeploymentStatistics, error)
 		ListDeploymentStatisticsGreaterThanTime(ctx context.Context, updated time.Time) ([]*ent.DeploymentStatistics, error)
 		GetLicense(ctx context.Context) (*vo.License, error)

internal/pkg/store/repo.go

@@ -221,7 +221,7 @@ func (c *collector) Collect(ch chan<- prometheus.Metric) {
 					nil,
 				),
 				prometheus.GaugeValue,
-				float64(dc.LeadTimeSeconds),
+				float64(dc.CommitCount),
 				dc.Edges.Repo.Namespace, dc.Edges.Repo.Name, dc.Env,
 			)
 		}
@@ -267,4 +267,48 @@ func (c *collector) Collect(ch chan<- prometheus.Metric) {
 			string(lic.Kind),
 		)
 	}
+
+	{
+		acnt, err := c.i.CountActiveRepos(ctx)
+		if err != nil {
+			c.log.Error("It has failed to count active repositories.", zap.Error(err))
+			return
+		}
+
+		cnt, err := c.i.CountRepos(ctx)
+		if err != nil {
+			c.log.Error("It has failed to count total repositories.", zap.Error(err))
+			return
+		}
+
+		ch <- prometheus.MustNewConstMetric(
+			prometheus.NewDesc(
+				prometheus.BuildFQName(
+					namespace,
+					"",
+					"total_active_repo_count",
+				),
+				"The count of active repositories.",
+				nil,
+				nil,
+			),
+			prometheus.GaugeValue,
+			float64(acnt),
+		)
+
+		ch <- prometheus.MustNewConstMetric(
+			prometheus.NewDesc(
+				prometheus.BuildFQName(
+					namespace,
+					"",
+					"total_repo_count",
+				),
+				"The count of repositories.",
+				nil,
+				nil,
+			),
+			prometheus.GaugeValue,
+			float64(cnt),
+		)
+	}
 }