TelemetryUtil
using System;
using System.Diagnostics;
using System.Runtime.CompilerServices;
namespace Polly.Telemetry
{
[System.Runtime.CompilerServices.NullableContext(1)]
[System.Runtime.CompilerServices.Nullable(0)]
internal static class TelemetryUtil
{
internal const string PollyDiagnosticSource = "Polly";
internal const string ExecutionAttempt = "ExecutionAttempt";
[System.Runtime.CompilerServices.NullableContext(2)]
[return: System.Runtime.CompilerServices.Nullable(1)]
public static ResilienceStrategyTelemetry CreateTelemetry(DiagnosticSource diagnosticSource, string builderName, string builderInstanceName, [System.Runtime.CompilerServices.Nullable(1)] ResilienceProperties builderProperties, string strategyName)
{
return new ResilienceStrategyTelemetry(new ResilienceTelemetrySource(builderName, builderInstanceName, builderProperties, strategyName), diagnosticSource);
}
public static void ReportExecutionAttempt<[System.Runtime.CompilerServices.Nullable(2)] TResult>(ResilienceStrategyTelemetry telemetry, ResilienceContext context, [System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1
})] Outcome<TResult> outcome, int attempt, TimeSpan executionTime, bool handled)
{
if (telemetry.IsEnabled) {
ExecutionAttemptArguments executionAttemptArguments = ExecutionAttemptArguments.Get(attempt, executionTime, handled);
telemetry.Report(new ResilienceEvent(handled ? ResilienceEventSeverity.Warning : ResilienceEventSeverity.Information, "ExecutionAttempt"), new OutcomeArguments<TResult, ExecutionAttemptArguments>(context, outcome, executionAttemptArguments));
ExecutionAttemptArguments.Return(executionAttemptArguments);
}
}
}
}