SiloAzureQueueStreamConfigurator 类

定义

public class SiloAzureQueueStreamConfigurator : Orleans.Hosting.SiloPersistentStreamConfigurator, Orleans.Hosting.IPersistentStreamConfigurator, Orleans.Hosting.ISiloAzureQueueStreamConfigurator
public class SiloAzureQueueStreamConfigurator : Orleans.Hosting.SiloPersistentStreamConfigurator, Orleans.Hosting.ISiloAzureQueueStreamConfigurator
type SiloAzureQueueStreamConfigurator = class
    inherit SiloPersistentStreamConfigurator
    interface ISiloAzureQueueStreamConfigurator
    interface IAzureQueueStreamConfigurator
    interface INamedServiceConfigurator
    interface ISiloPersistentStreamConfigurator
    interface IPersistentStreamConfigurator
Public Class SiloAzureQueueStreamConfigurator
Inherits SiloPersistentStreamConfigurator
Implements IPersistentStreamConfigurator, ISiloAzureQueueStreamConfigurator
Public Class SiloAzureQueueStreamConfigurator
Inherits SiloPersistentStreamConfigurator
Implements ISiloAzureQueueStreamConfigurator
继承
实现

构造函数

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

属性

ConfigureDelegate

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

(继承自 NamedServiceConfigurator)
Name

获取服务名称。

(继承自 NamedServiceConfigurator)

扩展方法

ConfigureAzureQueue(IAzureQueueStreamConfigurator, Action<OptionsBuilder<AzureQueueOptions>>)
ConfigureQueueDataAdapter(IAzureQueueStreamConfigurator, Func<IServiceProvider,String,IQueueDataAdapter<String,IBatchContainer>>)
ConfigureQueueDataAdapter<TQueueDataAdapter>(IAzureQueueStreamConfigurator)
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)

配置流发布/子类型。

ConfigureCacheSize(ISiloAzureQueueStreamConfigurator, Int32)
UseAzureBlobLeaseProvider(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<AzureBlobLeaseProviderOptions>>)

将接收器配置为使用 Azure Blob 租约提供程序

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>>)

配置拉取代理。

适用于