通过

SiloEventHubStreamConfigurator 类

  • 参考

定义

命名空间:
Orleans.Hosting
程序集:
Orleans.Streaming.EventHubs.dll
包:
Microsoft.Orleans.OrleansServiceBus v3.6.5
包:
Microsoft.Orleans.Streaming.EventHubs v7.2.5
包:
Microsoft.Orleans.Streaming.EventHubs v8.0.0
包:
Microsoft.Orleans.Streaming.EventHubs v8.1.0
包:
Microsoft.Orleans.Streaming.EventHubs v8.2.0
Source:
EventHubStreamBuilder.cs
public class SiloEventHubStreamConfigurator : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.IPersistentStreamConfigurator, Orleans.Hosting.ISiloEventHubStreamConfigurator
public class SiloEventHubStreamConfigurator : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.ISiloEventHubStreamConfigurator
type SiloEventHubStreamConfigurator = class
    inherit SiloRecoverableStreamConfigurator
    interface ISiloEventHubStreamConfigurator
    interface IEventHubStreamConfigurator
    interface INamedServiceConfigurator
    interface ISiloRecoverableStreamConfigurator
    interface ISiloPersistentStreamConfigurator
    interface IPersistentStreamConfigurator
Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator
Implements IPersistentStreamConfigurator, ISiloEventHubStreamConfigurator
Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator
Implements ISiloEventHubStreamConfigurator
继承
Object
NamedServiceConfigurator
SiloPersistentStreamConfigurator
SiloRecoverableStreamConfigurator
SiloEventHubStreamConfigurator
实现
IEventHubStreamConfigurator INamedServiceConfigurator IPersistentStreamConfigurator ISiloEventHubStreamConfigurator ISiloPersistentStreamConfigurator ISiloRecoverableStreamConfigurator

构造函数

SiloEventHubStreamConfigurator(String, Action<Action<IServiceCollection>>, Action<Action<IApplicationPartManager>>)
SiloEventHubStreamConfigurator(String, Action<Action<IServiceCollection>>)

属性

ConfigureDelegate

获取用于配置服务的委托。

(继承自 NamedServiceConfigurator)
Name

获取服务名称。

(继承自 NamedServiceConfigurator)

扩展方法

ConfigureEventHub(IEventHubStreamConfigurator, Action<OptionsBuilder<EventHubOptions>>)
UseDataAdapter(IEventHubStreamConfigurator, Func<IServiceProvider,String,IEventHubDataAdapter>)
UseDataAdapter(IEventHubStreamConfigurator, Func<IServiceProvider,String,IEventHubDataAdapter>)
Configure<TOptions>(INamedServiceConfigurator, Action<OptionsBuilder<TOptions>>)

配置命名服务的选项。
ConfigureComponent<TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>)

将单一实例组件添加到命名服务。
ConfigureComponent<TOptions,TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)

将单一实例组件添加到命名服务，并为命名服务配置选项。
ConfigureLifecycle<T>(INamedServiceConfigurator)
ConfigureStreamPubSub(IPersistentStreamConfigurator, StreamPubSubType)

配置流发布/子类型。
UseAzureBlobLeaseProvider(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<AzureBlobLeaseProviderOptions>>)

将接收器配置为使用 Azure Blob 租约提供程序
ConfigureCachePressuring(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubStreamCachePressureOptions>>)
ConfigureCheckpointer<TOptions>(ISiloEventHubStreamConfigurator, Func<IServiceProvider,String,IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)
ConfigurePartitionReceiver(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubReceiverOptions>>)
UseAzureTableCheckpointer(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)

将流提供程序配置为使用一致的环形队列负载均衡器。
UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

流式处理队列均衡器，该负载均衡器使用成员身份 oracle 中的 Azure 部署信息和孤岛状态进行负载均衡。
需要在 Azure 中运行的孤岛。 此均衡器使用 Azure 角色代码报告的有关完整接收器集的信息，以及来自成员身份 oracle 中当前活动（活动）接收器的信息，以及从非活动接收器重新平衡队列的信息。
UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

将流提供程序配置为使用动态群集配置部署均衡器。
UseLeaseBasedQueueBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)

将流提供程序配置为使用基于租约的队列均衡器。
UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

使用 Azure 部署信息的流式处理队列均衡器进行负载均衡。 需要在 Azure 中运行的孤岛。 此负载均衡器使用 Azure 角色代码报告的有关完整接收器集的信息，但不会使用成员身份 oracle 中有关当前活动接收器的信息。 也就是说，它不会根据群集成员身份中的动态更改重新平衡队列。
UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

将流提供程序配置为使用静态群集配置部署均衡器。
ConfigureBackoffProvider(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IMessageDeliveryBackoffProvider>)

配置拉取代理的消息传递回退提供程序。
ConfigureBackoffProvider(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IQueueReaderBackoffProvider>)

配置拉取代理的队列读取器退避提供程序。
ConfigureLifecycle(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamLifecycleOptions>>)

配置生命周期。
ConfigurePartitionBalancing(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>)

配置分区均衡。
ConfigurePartitionBalancing<TOptions>(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>, Action<OptionsBuilder<TOptions>>)

配置分区均衡。
ConfigurePullingAgent(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamPullingAgentOptions>>)

配置拉取代理。
ConfigureCacheEviction(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamCacheEvictionOptions>>)

为可靠流提供程序配置缓存逐出选项。
ConfigureStatistics(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamStatisticOptions>>)

配置可靠流提供程序的统计信息选项。

适用于