Используя Polly v8 и RestSharp, как мне построить Generic ResiliencePipeline для учета повторных попыток заголовка ответа, исключений и ведения журнала?

У меня есть клиентский класс API, созданный с использованием _client = new RestSharp.RestClient(...); с методами этой формы:

public async Task<TResponse> PostAsync<TRequest, TResponse>(string resource, TRequest payload) where TRequest : class
{
    var request = new RestRequest(resource);
    request.AddJsonBody(payload);
    var response = await PolicyFactory.RestSharpPolicy<B2BResponse<TResponse>>(_logger).ExecuteAsync(
        async token => await _client.ExecuteAsync<B2BResponse<TResponse>>(request, Method.Post, token));
    LogAndRaiseErrors(request, response);
    return response.Data.Data;
}

Вот метод LogAndRaiseErrors:

protected void LogAndRaiseErrors(RestRequest request, RestResponse response)
{
    if (response.StatusCode != HttpStatusCode.OK)
    {
        _logger.LogError("API Error:{response}", SerializeResponse(response));
        throw new BigCommerceException(response.Content);
    }
    _logger.LogDebug("B2B API Call:\n{response}", SerializeResponse(response));
} 

Я просмотрел документацию Polly, но она немного скудна.
Как бы я построил ResilencePipeline, используемый в методе PostAsync, для достижения следующих основных целей:

• Прочитайте response.Headers.FirstOrDefault(h=>h.Name?.ToLower() == "retry-after")?.Value и задержите на указанные секунды, чего существующий код вообще не делает.
• Я считаю, что повторная попытка должна влиять на все потоки, которые могут вызывать данный API? добавить автоматический выключатель?

Любые указатели на второстепенные цели были бы полезны:

• Регистрируйте каждый запрос (в настоящее время это делается в LogAndRaiseErrorsMethod).
• Записывать в журнал повторные попытки, включая задержку, указанную в заголовке.
• Переместите LogAndRaiseErrors(...) в политику, чтобы политика могла обрабатывать журналирование и любые исключения.
• Добавьте политику повторных попыток в случае сетевых сбоев/тайм-аутов и т. д.
• Я подозреваю, что нам нужен некоторый джиттер (для этого ли он нужен?), чтобы не все потоки одновременно загружали API?

ОБНОВЛЕНИЕ, вот что я пробовал:
Я думаю, что повторная попытка работает правильно, но не автоматический выключатель. Я перенес создание конвейера в конструктор, поэтому существует только один конвейер (журнал показывает, что он вызывается один раз).

public ApiClient(..., ILogger<B2BClient> logger)
{
    ...
    _client = client;
    _resiliencePipeline = PolicyFactory.GetRestSharpPolicy(_logger);
}

public async Task<TResponse> GetAsync<TResponse>(string resource)
{...}

public async Task<TResponse> PostAsync<TRequest, TResponse>(string resource, TRequest payload) where TRequest : class
{
    var request = new RestRequest(resource);
    request.AddJsonBody(payload);
    var response = await _resiliencePipeline.ExecuteAsync(
        async token => await _client.ExecuteAsync<BigCommerceResponse<TResponse>>(request, Method.Post, token));
    LogAndRaiseErrors(request, response);
    return response.Data.Data;
}

Вот мое создание конвейера, но я никогда не вижу записей в журнале прерывателя цепи, но вижу много записей в журнале повторных попыток.

public static class PolicyFactory
{

    public static ResiliencePipeline<RestResponse> GetRestSharpPolicy(ILogger logger)
    {
        logger.LogInformation("Building ResiliencePipeline");
        return new ResiliencePipelineBuilder<RestResponse>()
            .AddCircuitBreaker(new CircuitBreakerStrategyOptions<RestResponse>
            {
                FailureRatio = 0,
                ShouldHandle = new PredicateBuilder<RestResponse>()
                    .HandleResult(static result => result.StatusCode == HttpStatusCode.TooManyRequests),
            
                OnOpened = args =>
                {
                    logger.LogWarning("Circuit Breaker Opened on {StatusCode} for {Duration}s ({ResponseUri})",
                        args.Outcome.Result.StatusCode, args.BreakDuration.TotalSeconds, args.Outcome.Result.ResponseUri);
                    return ValueTask.CompletedTask;
                },
                OnClosed = args =>
                {
                    logger.LogWarning("Circuit Breaker Closed on {StatusCode} ({ResponseUri})",
                        args.Outcome.Result.StatusCode, args.Outcome.Result.ResponseUri);
                    return ValueTask.CompletedTask;
                }
            })
            .AddRetry(new RetryStrategyOptions<RestResponse>
            {
                ShouldHandle = new PredicateBuilder<RestResponse>()
                    .HandleResult(static result => result.StatusCode == HttpStatusCode.TooManyRequests),
                DelayGenerator = delayArgs =>
                {
                    var retryAfter = delayArgs.Outcome.Result.Headers.FirstOrDefault(h => h.Name?.ToLower() == "retry-after")?.Value.ToString();
                    return int.TryParse(retryAfter, out var seconds)
                        ? new ValueTask<TimeSpan?>(TimeSpan.FromSeconds(seconds))
                        : new ValueTask<TimeSpan?>(TimeSpan.FromSeconds(0.5));
                },
                MaxRetryAttempts = 5,
                OnRetry = args =>
                {
                    logger.LogWarning("Retry Attempt:{Attempt} Delay:{Delay}",
                        args.AttemptNumber, args.RetryDelay);
                    return ValueTask.CompletedTask;
                }
            })
            .Build();
    }
}