Redigera

Dela via


IAsyncProcessingPipelineBuilder Interface

Definition

Interface to register services for the async processing pipeline.

public interface class IAsyncProcessingPipelineBuilder
public interface IAsyncProcessingPipelineBuilder
type IAsyncProcessingPipelineBuilder = interface
Public Interface IAsyncProcessingPipelineBuilder

Properties

PipelineName

Gets the name of the message pipeline.

Services

Gets the IServiceCollection.

Extension Methods

AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Adds any singletons required for the async processing pipeline with the provided implementationFactory.

AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,T>)

Adds any singletons required for the async processing pipeline with the provided implementationFactory against the provided name.

AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder)

Adds any singletons required for the async processing pipeline.

AddMessageMiddleware<TMiddleware>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TMiddleware>)

Adds the IMessageMiddleware to the async processing pipeline with the provided implementation factory.

AddMessageMiddleware<TMiddleware>(IAsyncProcessingPipelineBuilder)

Adds the IMessageMiddleware to the async processing pipeline.

AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Add any singletons required with the provided implementationFactory.

AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,T>)

Add any singletons required with the provided implementationFactory against the pipelineName.

AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder)

Register any singletons required against the PipelineName.

ConfigureMessageConsumer<TConsumer>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TConsumer>)

Configures the MessageConsumer for the async processing pipeline with the provided implementation factory.

ConfigureMessageConsumer<TConsumer>(IAsyncProcessingPipelineBuilder)

Configures the MessageConsumer for the async processing pipeline.

ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TDestination>)

Configures the IMessageDestination for the async processing pipeline with the provided implementation factory.

ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,TDestination>)

Configures the IMessageDestination for the async processing pipeline with the provided name and implementation factory.

ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder)

Configures the IMessageDestination for the async processing pipeline.

ConfigureMessageSource<TSource>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TSource>)

Configures the IMessageSource for the async processing pipeline with the provided implementation factory.

ConfigureMessageSource<TSource>(IAsyncProcessingPipelineBuilder)

Configures the IMessageSource for the async processing pipeline.

ConfigureTerminalMessageDelegate(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,MessageDelegate>)

Configures the terminal MessageDelegate for the async processing pipeline with the provided implementation factory.

ConfigureTerminalMessageDelegate(IAsyncProcessingPipelineBuilder)

Configures the terminal MessageDelegate for the async processing pipeline.

ConfigureTerminalMessageDelegate<TDelegate>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TDelegate>)

Configures the terminal IMessageDelegate with TDelegate implementation to the IMessageMiddleware pipeline.

ConfigureTerminalMessageDelegate<TDelegate>(IAsyncProcessingPipelineBuilder)

Configures the terminal IMessageDelegate with TDelegate implementation to the IMessageMiddleware pipeline.

RunConsumerAsBackgroundService(IAsyncProcessingPipelineBuilder)

Configures the previously registered MessageConsumer for the async processing pipeline as a BackgroundService.

AddLatencyContextMiddleware(IAsyncProcessingPipelineBuilder)

Adds the IMessageMiddleware to register the Microsoft.Extensions.Telemetry.Latency.ILatencyContextProvider in IMessageMiddleware pipeline to create and set Microsoft.Extensions.Telemetry.Latency.ILatencyContext with the MessageContext.

AddLatencyContextMiddleware<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>, Func<IServiceProvider,IEnumerable<ILatencyDataExporter>>)

Adds the IMessageMiddleware to register the provided Microsoft.Extensions.Telemetry.Latency.ILatencyContextProvider in the IMessageMiddleware pipeline to create and set Microsoft.Extensions.Telemetry.Latency.ILatencyContext with the MessageContext.

AddLatencyContextMiddleware<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Adds the IMessageMiddleware to reuse the existing Microsoft.Extensions.Telemetry.Latency.ILatencyContext registered with the ASP.NET pipeline and set it in the MessageContext.

AddLatencyRecorderMessageMiddleware(IAsyncProcessingPipelineBuilder, MeasureToken, MeasureToken)

Adds the IMessageMiddleware for recording latency of the underlying IMessageMiddleware pipeline by obtaining the Microsoft.Extensions.Telemetry.Latency.ILatencyContext associated with MessageContext.

Applies to