Method UseIngestionThrottle

Namespace

Qavren.Edge.Ingestion

Assembly

Qavren.Edge.Ingestion.dll

UseIngestionThrottle(EdgeBuilder, Func<IServiceProvider, IIngestionThrottle>)

Replaces FixedIngestionThrottle with a consumer's policy.

public static EdgeBuilder UseIngestionThrottle(this EdgeBuilder builder, Func<IServiceProvider, IIngestionThrottle> factory)

Parameters

builder EdgeBuilder

The Qavren.Edge builder.

factory Func<IServiceProvider, IIngestionThrottle>

Builds the throttle.

Returns

EdgeBuilder

The builder, for chaining.