SiloPersistentStreamConfigurator 类

定义

public class SiloPersistentStreamConfigurator : Orleans.Streams.ISiloPersistentStreamConfigurator
type SiloPersistentStreamConfigurator = class
    interface ISiloPersistentStreamConfigurator
Public Class SiloPersistentStreamConfigurator
Implements ISiloPersistentStreamConfigurator
继承
SiloPersistentStreamConfigurator
派生
实现

构造函数

SiloPersistentStreamConfigurator(String, Action<Action<IServiceCollection>>, Func<IServiceProvider,String,IQueueAdapterFactory>)

字段

configureDelegate
name

方法

Configure<TOptions>(Action<OptionsBuilder<TOptions>>)
ConfigureComponent<TComponent>(Func<IServiceProvider,String,TComponent>)
ConfigureComponent<TOptions,TComponent>(Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)
TryConfigureDefaults()

扩展方法

UseAzureDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)

使用 Azure 部署信息进行负载均衡的流式队列均衡器。 需要在 Azure 中运行的孤岛。 此负载均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案,并尝试支持理想的分发

UseClusterConfigDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)
UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

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

UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

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

UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
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>>)
ConfigureStreamPubSub(ISiloPersistentStreamConfigurator, StreamPubSubType)

适用于