66 lines
3.2 KiB
C#
66 lines
3.2 KiB
C#
using System.Text;
|
|
|
|
namespace QuestionsApi.Services;
|
|
|
|
public sealed class ServiceMetrics
|
|
{
|
|
private long _attemptsCreated;
|
|
private long _attemptDuplicates;
|
|
private long _counterFailures;
|
|
private long _ratingFailures;
|
|
private long _reconciliations;
|
|
private long _lastReconciliationUnixSeconds;
|
|
private long _httpRequests;
|
|
private long _httpDurationMicroseconds;
|
|
private long _answerStatisticsBackfillComplete;
|
|
|
|
public void AttemptCreated() => Interlocked.Increment(ref _attemptsCreated);
|
|
public void AttemptDuplicate() => Interlocked.Increment(ref _attemptDuplicates);
|
|
public void CounterFailure() => Interlocked.Increment(ref _counterFailures);
|
|
public void RatingFailure() => Interlocked.Increment(ref _ratingFailures);
|
|
public void AnswerStatisticsBackfillCompleted() => Interlocked.Exchange(ref _answerStatisticsBackfillComplete, 1);
|
|
public void Reconciled()
|
|
{
|
|
Interlocked.Increment(ref _reconciliations);
|
|
Interlocked.Exchange(ref _lastReconciliationUnixSeconds, DateTimeOffset.UtcNow.ToUnixTimeSeconds());
|
|
}
|
|
public void HttpRequest(TimeSpan duration)
|
|
{
|
|
Interlocked.Increment(ref _httpRequests);
|
|
Interlocked.Add(ref _httpDurationMicroseconds, (long)(duration.TotalMilliseconds * 1000));
|
|
}
|
|
|
|
public string RenderPrometheus()
|
|
{
|
|
var output = new StringBuilder();
|
|
AppendCounter(output, "step3_question_attempts_created_total", Interlocked.Read(ref _attemptsCreated));
|
|
AppendCounter(output, "step3_question_attempt_duplicates_total", Interlocked.Read(ref _attemptDuplicates));
|
|
AppendCounter(output, "step3_answer_counter_failures_total", Interlocked.Read(ref _counterFailures));
|
|
AppendCounter(output, "step3_rating_failures_total", Interlocked.Read(ref _ratingFailures));
|
|
AppendCounter(output, "step3_answer_reconciliations_total", Interlocked.Read(ref _reconciliations));
|
|
AppendCounter(output, "step3_http_requests_total", Interlocked.Read(ref _httpRequests));
|
|
output.AppendLine("# TYPE step3_http_request_duration_seconds summary");
|
|
output.Append("step3_http_request_duration_seconds_count ")
|
|
.Append(Interlocked.Read(ref _httpRequests))
|
|
.AppendLine();
|
|
output.Append("step3_http_request_duration_seconds_sum ")
|
|
.Append((Interlocked.Read(ref _httpDurationMicroseconds) / 1_000_000.0).ToString("0.######", System.Globalization.CultureInfo.InvariantCulture))
|
|
.AppendLine();
|
|
output.AppendLine("# TYPE step3_answer_last_reconciliation_unixtime gauge");
|
|
output.Append("step3_answer_last_reconciliation_unixtime ")
|
|
.Append(Interlocked.Read(ref _lastReconciliationUnixSeconds))
|
|
.AppendLine();
|
|
output.AppendLine("# TYPE step3_answer_statistics_v2_backfill_complete gauge");
|
|
output.Append("step3_answer_statistics_v2_backfill_complete ")
|
|
.Append(Interlocked.Read(ref _answerStatisticsBackfillComplete))
|
|
.AppendLine();
|
|
return output.ToString();
|
|
}
|
|
|
|
private static void AppendCounter(StringBuilder output, string name, long value)
|
|
{
|
|
output.Append("# TYPE ").Append(name).AppendLine(" counter");
|
|
output.Append(name).Append(' ').Append(value).AppendLine();
|
|
}
|
|
}
|