Method collectUserSecretsSummary

coderd/telemetry/telemetry.go:974–1008

collectUserSecretsSummary returns a deployment-wide aggregate of user secrets configuration. Returns nil if another replica has already collected for this period. The summary has no natural per-row UUID for the telemetry server to de-duplicate on, so we elect a single replica per snapshot period vi

(ctx context.Context)

// de-duplicate on, so we elect a single replica per snapshot period
// via the telemetry_locks table.
func (r *remoteReporter) collectUserSecretsSummary(ctx context.Context) (*UserSecretsSummary, error) {
	// Claim the telemetry lock for this period. Use snapshot frequency so
	// each telemetry snapshot period gets exactly one collection across
	// replicas.
	periodEndingAt := dbtime.Time(r.options.Clock.Now()).UTC().Truncate(r.options.SnapshotFrequency)
	err := r.options.Database.InsertTelemetryLock(ctx, database.InsertTelemetryLockParams{
		EventType:      "user_secrets_summary",
		PeriodEndingAt: periodEndingAt,
	})
	if database.IsUniqueViolation(err, database.UniqueTelemetryLocksPkey) {
		r.options.Logger.Debug(ctx, "user secrets telemetry lock already claimed by another replica, skipping", slog.F("period_ending_at", periodEndingAt))
		return nil, nil //nolint:nilnil // This is simple to handle when dealing with telemetry.
	}
	if err != nil {
		return nil, xerrors.Errorf("insert user secrets telemetry lock (period_ending_at=%q): %w", periodEndingAt, err)
	}

	row, err := r.options.Database.GetUserSecretsTelemetrySummary(ctx)
	if err != nil {
		return nil, xerrors.Errorf("get user secrets telemetry summary: %w", err)
	}
	return &UserSecretsSummary{
		UsersWithSecrets:  row.UsersWithSecrets,
		TotalSecrets:      row.TotalSecrets,
		EnvNameOnly:       row.EnvNameOnly,
		FilePathOnly:      row.FilePathOnly,
		Both:              row.Both,
		Neither:           row.Neither,
		SecretsPerUserMax: row.SecretsPerUserMax,
		SecretsPerUserP25: row.SecretsPerUserP25,
		SecretsPerUserP50: row.SecretsPerUserP50,
		SecretsPerUserP75: row.SecretsPerUserP75,
		SecretsPerUserP90: row.SecretsPerUserP90,
	}, nil
}

func CollectTasks(ctx context.Context, db database.Store) ([]Task, error) {
	dbTasks, err := db.ListTasks(ctx, database.ListTasksParams{