| RiakCluster Class |
Represents a collection of RiakEndPoints.
Allows operations to be performed using an endpoint's connection.
Also supported rudimentary load balancing between multiple nodes.
Inheritance HierarchyNamespace: RiakClient
Assembly: RiakClient (in RiakClient.dll) Version: f9bb17a3f8ff6940b88010a52f202e3d55fe25c5
SyntaxThe RiakCluster type exposes the following members.
Constructors| Name | Description | |
|---|---|---|
 | RiakCluster(IRiakClusterConfiguration) |
Initializes a new instance of the RiakCluster class using the default connection factory.
|
| RiakCluster(IRiakClusterConfiguration, IRiakConnectionFactory) |
Initializes a new instance of the RiakCluster class.
|
Properties| Name | Description | |
|---|---|---|
 | DefaultRetryCount |
The max number of retry attempts to make when the client encounters
ResultCode.NoConnections or ResultCode.CommunicationError errors.
(Overrides RiakEndPointDefaultRetryCount.) |
 | RetryWaitTime |
Represents the TimeSpan to wait inbetween retry attempts.
(Inherited from RiakEndPoint.) |
Methods| Name | Description | |
|---|---|---|
| CreateClient |
Creates a new instance of RiakClient.
(Inherited from RiakEndPoint.) |
| Dispose |
Releases all resources used by the RiakEndPoint class.
(Inherited from RiakEndPoint.) |
 | Dispose(Boolean) | Releases the unmanaged resources used by the RiakCluster and optionally releases the managed resources (Overrides RiakEndPointDispose(Boolean).) |
| Equals | (Inherited from Object.) |
| Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) |
 | FromConfig(String) |
Creates an instance of IRiakClient populated from from the configuration section
specified by configSectionName.
|
| FromConfig(String, String) |
Creates an instance of IRiakClient populated from from the configuration section
specified by configSectionName.
|
| GetHashCode | Serves as a hash function for a particular type. (Inherited from Object.) |
| GetType | Gets the Type of the current instance. (Inherited from Object.) |
| MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) |
| ToString | Returns a string that represents the current object. (Inherited from Object.) |
| UseConnection(FuncIRiakConnection, RiakResult, Int32) |
Executes a delegate function using a IRiakConnection, and returns the results.
Retries if possible for certain error states.
(Inherited from RiakEndPoint.) |
| UseConnectionTResult(FuncIRiakConnection, RiakResultTResult, Int32) |
Executes a delegate function using a IRiakConnection, and returns the results.
Retries if possible for certain error states.
(Inherited from RiakEndPoint.) |
| UseConnectionTRiakResult(FuncIRiakConnection, TRiakResult, FuncResultCode, String, Boolean, TRiakResult, Int32) | (Overrides RiakEndPointUseConnectionTRiakResult(FuncIRiakConnection, TRiakResult, FuncResultCode, String, Boolean, TRiakResult, Int32).) |
| UseConnectionTRiakResult(FuncIRiakConnection, TRiakResult, FuncResultCode, String, Boolean, TRiakResult, Int32) | (Inherited from RiakEndPoint.) |
| UseDelayedConnectionTResult(FuncIRiakConnection, Action, RiakResultIEnumerableTResult, Int32) |
Executes a delegate function using a IRiakConnection, and returns the results.
Can retry up to "retryAttempts" times for NoRetries and ShuttingDown error states.
This method is used over UseConnection(FuncIRiakConnection, RiakResult, Int32) to keep a connection open to receive streaming results.
(Overrides RiakEndPointUseDelayedConnectionTResult(FuncIRiakConnection, Action, RiakResultIEnumerableTResult, Int32).) |
| UseDelayedConnectionTResult(FuncIRiakConnection, Action, RiakResultIEnumerableTResult, Int32) |
Executes a delegate function using a IRiakConnection, and returns the results.
Retries if possible for certain error states.
This method is used over UseConnection(FuncIRiakConnection, RiakResult, Int32) to keep a connection open to receive streaming results.
(Inherited from RiakEndPoint.) |
See Also