Class VirtualClusterConnection

An in memory connection that uses a rule engine to return different responses for sniffs/pings and API calls.

Either instantiate through the static Success(byte[]) or Error() for the simplest use-cases

Or use VirtualClusterWith to chain together a rule engine until
VirtualClusterConnection(Func<ConnectionConfiguration, ConnectionConfiguration>) becomes available
Inheritance
object
InMemoryConnection
VirtualClusterConnection
Implements
Inherited Members
Namespace: OpenSearch.Net.VirtualizedCluster
Assembly: OpenSearch.Net.VirtualizedCluster.dll
Syntax
public class VirtualClusterConnection : InMemoryConnection, IConnection, IDisposable

Methods

| Edit this page View Source

Error()

Declaration
public static VirtualClusterConnection Error()
Returns
Type Description
VirtualClusterConnection
| Edit this page View Source

IsPingRequest(RequestData)

Declaration
public bool IsPingRequest(RequestData requestData)
Parameters
Type Name Description
RequestData requestData
Returns
Type Description
bool
| Edit this page View Source

IsSniffRequest(RequestData)

Declaration
public bool IsSniffRequest(RequestData requestData)
Parameters
Type Name Description
RequestData requestData
Returns
Type Description
bool
| Edit this page View Source

RequestAsync<TResponse>(RequestData, CancellationToken)

Declaration
public override Task<TResponse> RequestAsync<TResponse>(RequestData requestData, CancellationToken cancellationToken) where TResponse : class, IOpenSearchResponse, new()
Parameters
Type Name Description
RequestData requestData
CancellationToken cancellationToken
Returns
Type Description
Task<TResponse>
Type Parameters
Name Description
TResponse
Overrides
| Edit this page View Source

Request<TResponse>(RequestData)

Declaration
public override TResponse Request<TResponse>(RequestData requestData) where TResponse : class, IOpenSearchResponse, new()
Parameters
Type Name Description
RequestData requestData
Returns
Type Description
TResponse
Type Parameters
Name Description
TResponse
Overrides
| Edit this page View Source

Success(byte[])

Declaration
public static VirtualClusterConnection Success(byte[] response)
Parameters
Type Name Description
byte[] response
Returns
Type Description
VirtualClusterConnection
| Edit this page View Source

UpdateCluster(VirtualCluster)

Declaration
public void UpdateCluster(VirtualCluster cluster)
Parameters
Type Name Description
VirtualCluster cluster

Implements

Extension Methods