-
-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
42 changed files
with
489 additions
and
157 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
59 changes: 48 additions & 11 deletions
59
src/Polly.Core/Hedging/HedgingActionGeneratorArguments.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,20 +1,57 @@ | ||
namespace Polly.Hedging; | ||
|
||
#pragma warning disable CA1815 // Override equals and operator equals on value types | ||
|
||
/// <summary> | ||
/// Represents arguments used in the hedging resilience strategy. | ||
/// </summary> | ||
/// <typeparam name="TResult">The type of the result.</typeparam> | ||
/// <param name="PrimaryContext">The primary resilience context.</param> | ||
/// <param name="ActionContext"> | ||
/// The context that will be passed to action generated by <see cref="HedgingStrategyOptions{TResult}.HedgingActionGenerator"/>. | ||
/// This context is cloned from <paramref name="PrimaryContext"/>.</param> | ||
/// <param name="Attempt">The zero-based hedging attempt number.</param> | ||
/// <param name="Callback">The callback passed to hedging strategy.</param> | ||
/// <remarks> | ||
/// Always use the constructor when creating this struct, otherwise we do not guarantee binary compatibility. | ||
/// </remarks> | ||
public readonly record struct HedgingActionGeneratorArguments<TResult>( | ||
ResilienceContext PrimaryContext, | ||
ResilienceContext ActionContext, | ||
int Attempt, | ||
Func<ResilienceContext, ValueTask<Outcome<TResult>>> Callback); | ||
public readonly struct HedgingActionGeneratorArguments<TResult> | ||
{ | ||
/// <summary> | ||
/// Initializes a new instance of the <see cref="HedgingActionGeneratorArguments{TResult}"/> struct. | ||
/// </summary> | ||
/// <param name="primaryContext">The primary resilience context.</param> | ||
/// <param name="actionContext"> | ||
/// The context that will be passed to action generated by <see cref="HedgingStrategyOptions{TResult}.HedgingActionGenerator"/>. | ||
/// .</param> | ||
/// <param name="attempt">The zero-based hedging attempt number.</param> | ||
/// <param name="callback">The callback passed to hedging strategy.</param> | ||
public HedgingActionGeneratorArguments( | ||
ResilienceContext primaryContext, | ||
ResilienceContext actionContext, | ||
int attempt, | ||
Func<ResilienceContext, ValueTask<Outcome<TResult>>> callback) | ||
{ | ||
PrimaryContext = primaryContext; | ||
ActionContext = actionContext; | ||
Attempt = attempt; | ||
Callback = callback; | ||
} | ||
|
||
/// <summary> | ||
/// Gets the primary resilience context. | ||
/// </summary> | ||
public ResilienceContext PrimaryContext { get; } | ||
|
||
/// <summary> | ||
/// Gets the context that will be passed to action generated by <see cref="HedgingStrategyOptions{TResult}.HedgingActionGenerator"/>. | ||
/// </summary> | ||
/// <remarks> | ||
/// This context is cloned from <see cref="PrimaryContext"/>. | ||
/// </remarks> | ||
public ResilienceContext ActionContext { get; } | ||
|
||
/// <summary> | ||
/// Gets the zero-based hedging attempt number. | ||
/// </summary> | ||
public int Attempt { get; } | ||
|
||
/// <summary> | ||
/// Gets the callback passed to hedging strategy. | ||
/// </summary> | ||
public Func<ResilienceContext, ValueTask<Outcome<TResult>>> Callback { get; } | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,11 +1,33 @@ | ||
namespace Polly.Hedging; | ||
|
||
#pragma warning disable CA1815 // Override equals and operator equals on value types | ||
|
||
/// <summary> | ||
/// Arguments used by hedging delay generator. | ||
/// </summary> | ||
/// <param name="Context">The context associated with the execution of a user-provided callback.</param> | ||
/// <param name="Attempt">The zero-based hedging attempt number.</param> | ||
/// <remarks> | ||
/// Always use the constructor when creating this struct, otherwise we do not guarantee binary compatibility. | ||
/// </remarks> | ||
public readonly record struct HedgingDelayArguments(ResilienceContext Context, int Attempt); | ||
public readonly struct HedgingDelayArguments | ||
{ | ||
/// <summary> | ||
/// Initializes a new instance of the <see cref="HedgingDelayArguments"/> struct. | ||
/// </summary> | ||
/// <param name="context">The context associated with the execution of a user-provided callback.</param> | ||
/// <param name="attempt">The zero-based hedging attempt number.</param> | ||
public HedgingDelayArguments(ResilienceContext context, int attempt) | ||
{ | ||
Context = context; | ||
Attempt = attempt; | ||
} | ||
|
||
/// <summary> | ||
/// Gets the context associated with the execution of a user-provided callback. | ||
/// </summary> | ||
public ResilienceContext Context { get; } | ||
|
||
/// <summary> | ||
/// Gets the zero-based hedging attempt number. | ||
/// </summary> | ||
public int Attempt { get; } | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.