Class BulkheadPolicy<TResult>

Namespace

Polly.Bulkhead

Assembly

Polly.dll

A bulkhead-isolation policy which can be applied to delegates returning a value of type TResult.

public class BulkheadPolicy<TResult> : Policy<TResult>, IAsyncPolicy<TResult>, ISyncPolicy<TResult>, IBulkheadPolicy<TResult>, IBulkheadPolicy, IsPolicy, IDisposable

Type Parameters

TResult

Inheritance

object

Policy<TResult>

BulkheadPolicy<TResult>

Implements

IAsyncPolicy<TResult>

ISyncPolicy<TResult>

IBulkheadPolicy<TResult>

IBulkheadPolicy

IsPolicy

IDisposable

Inherited Members

Policy<TResult>.Handle<TException>()

Policy<TResult>.Handle<TException>(Func<TException, bool>)

Policy<TResult>.HandleResult(Func<TResult, bool>)

Policy<TResult>.HandleResult(TResult)

Policy<TResult>.WithPolicyKey(string)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>, bool)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>, IDictionary<string, object>)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>, Context)

Policy<TResult>.ExecuteAsync(Func<Context, Task<TResult>>, IDictionary<string, object>)

Policy<TResult>.ExecuteAsync(Func<Context, Task<TResult>>, Context)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>, IDictionary<string, object>, bool)

Policy<TResult>.ExecuteAsync(Func<Task<TResult>>, Context, bool)

Policy<TResult>.ExecuteAsync(Func<Context, Task<TResult>>, IDictionary<string, object>, bool)

Policy<TResult>.ExecuteAsync(Func<Context, Task<TResult>>, Context, bool)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, CancellationToken)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, CancellationToken, bool)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, Context, CancellationToken)

Policy<TResult>.ExecuteAsync(Func<Context, CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAsync(Func<Context, CancellationToken, Task<TResult>>, Context, CancellationToken)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken, bool)

Policy<TResult>.ExecuteAsync(Func<CancellationToken, Task<TResult>>, Context, CancellationToken, bool)

Policy<TResult>.ExecuteAsync(Func<Context, CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken, bool)

Policy<TResult>.ExecuteAsync(Func<Context, CancellationToken, Task<TResult>>, Context, CancellationToken, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>, IDictionary<string, object>)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>, Context)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, Task<TResult>>, IDictionary<string, object>)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, Task<TResult>>, Context)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>, IDictionary<string, object>, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Task<TResult>>, Context, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, Task<TResult>>, IDictionary<string, object>, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, Task<TResult>>, Context, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, CancellationToken)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, CancellationToken, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, Context, CancellationToken)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, CancellationToken, Task<TResult>>, Context, CancellationToken)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<CancellationToken, Task<TResult>>, Context, CancellationToken, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, CancellationToken, Task<TResult>>, IDictionary<string, object>, CancellationToken, bool)

Policy<TResult>.ExecuteAndCaptureAsync(Func<Context, CancellationToken, Task<TResult>>, Context, CancellationToken, bool)

Policy<TResult>.Execute(Func<TResult>)

Policy<TResult>.Execute(Func<TResult>, IDictionary<string, object>)

Policy<TResult>.Execute(Func<TResult>, Context)

Policy<TResult>.Execute(Func<Context, TResult>, IDictionary<string, object>)

Policy<TResult>.Execute(Func<Context, TResult>, Context)

Policy<TResult>.Execute(Func<CancellationToken, TResult>, CancellationToken)

Policy<TResult>.Execute(Func<CancellationToken, TResult>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.Execute(Func<CancellationToken, TResult>, Context, CancellationToken)

Policy<TResult>.Execute(Func<Context, CancellationToken, TResult>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.Execute(Func<Context, CancellationToken, TResult>, Context, CancellationToken)

Policy<TResult>.ExecuteAndCapture(Func<TResult>)

Policy<TResult>.ExecuteAndCapture(Func<TResult>, IDictionary<string, object>)

Policy<TResult>.ExecuteAndCapture(Func<TResult>, Context)

Policy<TResult>.ExecuteAndCapture(Func<Context, TResult>, IDictionary<string, object>)

Policy<TResult>.ExecuteAndCapture(Func<Context, TResult>, Context)

Policy<TResult>.ExecuteAndCapture(Func<CancellationToken, TResult>, CancellationToken)

Policy<TResult>.ExecuteAndCapture(Func<CancellationToken, TResult>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAndCapture(Func<CancellationToken, TResult>, Context, CancellationToken)

Policy<TResult>.ExecuteAndCapture(Func<Context, CancellationToken, TResult>, IDictionary<string, object>, CancellationToken)

Policy<TResult>.ExecuteAndCapture(Func<Context, CancellationToken, TResult>, Context, CancellationToken)

Policy<TResult>.Wrap(Policy)

Policy<TResult>.Wrap(Policy<TResult>)

Policy<TResult>.WrapAsync(Policy)

Policy<TResult>.WrapAsync(Policy<TResult>)

Policy<TResult>.PolicyKey

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Properties

BulkheadAvailableCount

Gets the number of slots currently available for executing actions through the bulkhead.

public int BulkheadAvailableCount { get; }

Property Value

int

QueueAvailableCount

Gets the number of slots currently available for queuing actions for execution through the bulkhead.

public int QueueAvailableCount { get; }

Property Value

int

Methods

Dispose()

Disposes of the BulkheadPolicy, allowing it to dispose its internal resources.
Only call Dispose() on a BulkheadPolicy after all actions executed through the policy have completed. If actions are still executing through the policy when Dispose() is called, an ObjectDisposedException may be thrown on the actions' threads when those actions complete.

public void Dispose()