TestCluster 类

定义

一个主机类,用于使用进程内接收器对 Orleans 进行本地测试。 在单独的应用域中运行主接收器和(可选)辅助接收器,在主应用域中运行客户端。 如果需要特定测试用例,还可以在进程内按需启动其他接收器。

public class TestCluster
public class TestCluster : IDisposable
public class TestCluster : IAsyncDisposable, IDisposable
type TestCluster = class
type TestCluster = class
    interface IDisposable
type TestCluster = class
    interface IDisposable
    interface IAsyncDisposable
Public Class TestCluster
Public Class TestCluster
Implements IDisposable
Public Class TestCluster
Implements IAsyncDisposable, IDisposable
继承
TestCluster
实现

注解

确保测试项目引用测试粒度和测试粒度接口项目,并对这些引用 [应为默认值] 设置了 CopyLocal=True。

构造函数

TestCluster()

配置默认的主测试接收器,以及进程内客户端。

TestCluster(ClusterConfiguration)

配置测试群集以及进程内的默认客户端。

TestCluster(ClusterConfiguration, ClientConfiguration)

使用指定的 silo 和客户端配置配置配置测试群集和进程内客户端。

TestCluster(TestClusterOptions)

配置测试群集和进程内客户端。

TestCluster(TestClusterOptions, IReadOnlyList<IConfigurationSource>)

配置测试群集和进程内客户端。

TestCluster(TestClusterOptions, IReadOnlyList<IConfigurationSource>, ITestClusterPortAllocator)

配置测试群集和进程内客户端。

属性

Client

客户端。

ClientConfiguration

初始化客户端时要使用的客户端配置

ClusterConfiguration

群集配置

ConfigurationSources

获取配置源。

CreateSiloAsync

用于创建和启动单个接收器的委托。

DeploymentId

群集的 DeploymentId

GrainFactory

在测试中使用的 GrainFactory

Options

用于配置测试群集的选项。

PortAllocator

端口分配器。

Primary

主 silo 句柄(如果适用)。

SecondarySilos

辅助接收器的句柄列表。

SerializationManager

在测试中使用的 SerializationManager

ServiceProvider

IServiceProvider用于测试的客户端。

Silos

所有已知 silo 的集合。

StreamProviderManager

客户端 StreamProviderManager

方法

DefaultCreateSiloAsync(String, IConfiguration)

CreateSiloAsync默认值,用于创建新的 silo 句柄。

Deploy()

使用指定的配置部署群集,并在进程内启动客户端。 它将启动 中 InitialSilosCount定义的 silo 数。

Deploy(IEnumerable<String>)

使用指定的配置部署群集,并在进程内启动客户端。

DeployAsync()

使用指定的配置部署群集,并在进程内启动客户端。

DeployAsync(IEnumerable<String>)

使用指定的配置部署群集,并在进程内启动客户端。

Dispose()

一个主机类,用于使用进程内接收器对 Orleans 进行本地测试。 在单独的应用域中运行主接收器和(可选)辅助接收器,在主应用域中运行客户端。 如果需要特定测试用例,还可以在进程内按需启动其他接收器。

DisposeAsync()

一个主机类,用于使用进程内接收器对 Orleans 进行本地测试。 在单独的应用域中运行主接收器和(可选)辅助接收器,在主应用域中运行客户端。 如果需要特定测试用例,还可以在进程内按需启动其他接收器。

GetActiveSilos()

获取当前活动接收器的列表。

GetLivenessStabilizationTime(ClusterMembershipOptions, Boolean)

获取超时值,用于等待 silo 活动子系统检测并处理任何最近的群集成员身份更改。

GetLivenessStabilizationTime(GlobalConfiguration, Boolean)

获取超时值,用于等待 silo 活动子系统检测并处理任何最近的群集成员身份更改。

GetLog()

获取日志。

GetSiloForAddress(SiloAddress)

查找指定 silo 地址的 silo 句柄。

InitializeClient()

初始化 grain 客户端。 这应该已经由 Deploy() 或 完成 DeployAsync(IEnumerable<String>)

InitializeClientAsync()

初始化 grain 客户端。 这应该已经由 Deploy() 或 完成 DeployAsync()

KillClient()

对客户端执行硬终止。 客户端不会清理资源。

KillClientAsync()

对客户端执行硬终止。 客户端不会清理资源。

KillSilo(SiloHandle)

立即终止指定的接收器。

KillSiloAsync(SiloHandle)

立即终止指定的接收器。

RestartSilo(SiloHandle)

执行“停止”或“终止”指定的 silo,然后重启。

RestartSiloAsync(SiloHandle)

执行“停止”或“终止”指定的 silo,然后重启。

RestartStoppedSecondarySilo(String)

重启之前已停止的 。

RestartStoppedSecondarySiloAsync(String)

重启之前已停止的 。

StartAdditionalSilo()

启动其他 silo,使其加入现有群集。

StartAdditionalSilo(Boolean)

启动其他 silo,使其加入现有群集。

StartAdditionalSiloAsync(Boolean)

启动其他 silo,使其加入现有群集。

StartAdditionalSilos(Int32)

启动多个额外的 silo,以便它们加入现有群集。

StartAdditionalSilosAsync(Int32, Boolean)

启动多个额外的 silo,以便它们加入现有群集。

StartOrleansSilo(TestCluster, Silo+SiloType, ClusterConfiguration, NodeConfiguration)

在目标群集中启动新的 silo

StartSiloAsync(Int32, TestClusterOptions, IReadOnlyList<IConfigurationSource>, Boolean)

启动新的接收器。

StartSiloAsync(TestCluster, Int32, TestClusterOptions, IReadOnlyList<IConfigurationSource>, Boolean)

在目标群集中启动新的 silo

StopAllSilos()

停止所有当前接收器。

StopAllSilosAsync()

停止所有当前接收器。

StopClusterClientAsync()

停止群集客户端作为异步操作。

StopPrimarySilo()

停止默认的“主接收器”。

StopPrimarySiloAsync()

停止默认的“主接收器”。

StopSecondarySilos()

停止任何其他接收器,不包括默认的主接收器。

StopSecondarySilosAsync()

停止任何其他接收器,不包括默认的主接收器。

StopSilo(SiloHandle)

对指定的接收器执行半正常停止。

StopSiloAsync(SiloHandle)

对指定的接收器执行半正常停止。

WaitForLivenessToStabilizeAsync(Boolean)

等待 silo liveness 子系统检测并处理任何最近的群集成员身份更改。

适用于