TestCluster Class

Definition

Namespace:

Orleans.TestingHost

Assembly:

Orleans.TestingHost.dll

Package:

Microsoft.Orleans.TestingHost v8.2.0

A host class for local testing with Orleans using in-process silos. Runs a Primary and optionally secondary silos in separate app domains, and client in the main app domain. Additional silos can also be started in-process on demand if required for particular test cases.

public class TestCluster : IAsyncDisposable, IDisposable

type TestCluster = class
    interface IDisposable
    interface IAsyncDisposable

Public Class TestCluster
Implements IAsyncDisposable, IDisposable

Inheritance

Object

TestCluster

Implements

IDisposable IAsyncDisposable

Remarks

Make sure that your test project references your test grains and test grain interfaces projects, and has CopyLocal=True set on those references [which should be the default].

Constructors

TestCluster(TestClusterOptions, IReadOnlyList<IConfigurationSource>, ITestClusterPortAllocator)

Configures the test cluster plus client in-process.

Properties

Client	The client.
ConfigurationSources	Gets the configuration sources.
CreateSiloAsync	Delegate used to create and start an individual silo.
GrainFactory	GrainFactory to use in the tests
Options	Options used to configure the test cluster.
PortAllocator	The port allocator.
Primary	Primary silo handle, if applicable.
SecondarySilos	List of handles to the secondary silos.
ServiceProvider	Client-side IServiceProvider to use in the tests.
Silos	Collection of all known silos.

Methods

DefaultCreateSiloAsync(String, IConfiguration)	Default value for CreateSiloAsync, which creates a new silo handle.
Deploy()	Deploys the cluster using the specified configuration and starts the client in-process. It will start the number of silos defined in InitialSilosCount.
DeployAsync()	Deploys the cluster using the specified configuration and starts the client in-process.
Dispose()	Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
DisposeAsync()	Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.
GetActiveSilos()	Get the list of current active silos.
GetLivenessStabilizationTime(ClusterMembershipOptions, Boolean)	Get the timeout value to use to wait for the silo liveness sub-system to detect and act on any recent cluster membership changes.
GetLog()	Gets the log.
GetSiloForAddress(SiloAddress)	Find the silo handle for the specified silo address.
InitializeClientAsync()	Initialize the grain client. This should be already done by Deploy() or DeployAsync()
KillClientAsync()	Performs a hard kill on client. Client will not cleanup resources.
KillSiloAsync(SiloHandle)	Do an immediate Kill of the specified silo.
RestartSiloAsync(SiloHandle)	Do a Stop or Kill of the specified silo, followed by a restart.
RestartStoppedSecondarySiloAsync(String)	Restart a previously stopped.
StartAdditionalSilo(Boolean)	Start an additional silo, so that it joins the existing cluster.
StartAdditionalSiloAsync(Boolean)	Start an additional silo, so that it joins the existing cluster.
StartAdditionalSilosAsync(Int32, Boolean)	Start a number of additional silo, so that they join the existing cluster.
StartSiloAsync(Int32, TestClusterOptions, IReadOnlyList<IConfigurationSource>, Boolean)	Starts a new silo.
StartSiloAsync(TestCluster, Int32, TestClusterOptions, IReadOnlyList<IConfigurationSource>, Boolean)	Start a new silo in the target cluster
StopAllSilos()	Stop all current silos.
StopAllSilosAsync()	Stop all current silos.
StopClusterClientAsync()	Stop cluster client as an asynchronous operation.
StopPrimarySiloAsync()	Stops the default Primary silo.
StopSecondarySilosAsync()	Stop any additional silos, not including the default Primary silo.
StopSiloAsync(SiloHandle)	Do a semi-graceful Stop of the specified silo.
WaitForLivenessToStabilizeAsync(Boolean)	Wait for the silo liveness sub-system to detect and act on any recent cluster membership changes.