Method RunsTotal

app/controlplane/pkg/data/orgmetrics.go:48–72

(ctx context.Context, orgID uuid.UUID, tw *biz.TimeWindow, projectIDs []uuid.UUID)

}

func (repo *OrgMetricsRepo) RunsTotal(ctx context.Context, orgID uuid.UUID, tw *biz.TimeWindow, projectIDs []uuid.UUID) (int32, error) {
	ctx, span := otelx.Start(ctx, orgMetricsRepoTracer, "OrgMetricsRepo.RunsTotal")
	defer span.End()

	wfQuery := orgScopedQuery(repo.data.DB, orgID).
		QueryWorkflows()

	if projectIDs != nil {
		wfQuery = wfQuery.Where(workflow.ProjectIDIn(projectIDs...))
	}

	total, err := wfQuery.WithProject().
		QueryWorkflowruns().
		Where(
			workflowrun.CreatedAtGTE(tw.From),
			workflowrun.CreatedAtLTE(tw.To),
		).
		Count(ctx)

	if err != nil {
		return 0, err
	}

	return int32(total), nil
}

func (repo *OrgMetricsRepo) RunsByStatusTotal(ctx context.Context, orgID uuid.UUID, tw *biz.TimeWindow, projectIDs []uuid.UUID) (map[string]int32, error) {
	ctx, span := otelx.Start(ctx, orgMetricsRepoTracer, "OrgMetricsRepo.RunsByStatusTotal")