Class RequestPipeline

Inheritance
object
RequestPipeline
Implements
Inherited Members
Namespace: OpenSearch.Net
Assembly: OpenSearch.Net.dll
Syntax
public class RequestPipeline : IRequestPipeline, IDisposable

Constructors

| Edit this page View Source

RequestPipeline(IConnectionConfigurationValues, IDateTimeProvider, IMemoryStreamFactory, IRequestParameters)

Declaration
public RequestPipeline(IConnectionConfigurationValues configurationValues, IDateTimeProvider dateTimeProvider, IMemoryStreamFactory memoryStreamFactory, IRequestParameters requestParameters)
Parameters
Type Name Description
IConnectionConfigurationValues configurationValues
IDateTimeProvider dateTimeProvider
IMemoryStreamFactory memoryStreamFactory
IRequestParameters requestParameters

Properties

| Edit this page View Source

AuditTrail

Declaration
public List<Audit> AuditTrail { get; }
Property Value
Type Description
List<Audit>
| Edit this page View Source

DepletedRetries

Declaration
public bool DepletedRetries { get; }
Property Value
Type Description
bool
| Edit this page View Source

FirstPoolUsageNeedsSniffing

Declaration
public bool FirstPoolUsageNeedsSniffing { get; }
Property Value
Type Description
bool
| Edit this page View Source

IsTakingTooLong

Declaration
public bool IsTakingTooLong { get; }
Property Value
Type Description
bool
| Edit this page View Source

MaxRetries

Declaration
public int MaxRetries { get; }
Property Value
Type Description
int
| Edit this page View Source

Refresh

Declaration
public bool Refresh { get; }
Property Value
Type Description
bool
| Edit this page View Source

Retried

Declaration
public int Retried { get; }
Property Value
Type Description
int
| Edit this page View Source

SniffNodes

Declaration
public IEnumerable<Node> SniffNodes { get; }
Property Value
Type Description
IEnumerable<Node>
| Edit this page View Source

SniffPath

Declaration
public static string SniffPath { get; }
Property Value
Type Description
string
| Edit this page View Source

SniffsOnConnectionFailure

Declaration
public bool SniffsOnConnectionFailure { get; }
Property Value
Type Description
bool
| Edit this page View Source

SniffsOnStaleCluster

Declaration
public bool SniffsOnStaleCluster { get; }
Property Value
Type Description
bool
| Edit this page View Source

StaleClusterState

Declaration
public bool StaleClusterState { get; }
Property Value
Type Description
bool
| Edit this page View Source

StartedOn

Declaration
public DateTime StartedOn { get; }
Property Value
Type Description
DateTime

Methods

| Edit this page View Source

AuditCancellationRequested()

Declaration
public void AuditCancellationRequested()
| Edit this page View Source

BadResponse<TResponse>(ref TResponse, IApiCallDetails, RequestData, OpenSearchClientException)

Declaration
public void BadResponse<TResponse>(ref TResponse response, IApiCallDetails callDetails, RequestData data, OpenSearchClientException exception) where TResponse : class, IOpenSearchResponse, new()
Parameters
Type Name Description
TResponse response
IApiCallDetails callDetails
RequestData data
OpenSearchClientException exception
Type Parameters
Name Description
TResponse
| Edit this page View Source

CallOpenSearchAsync<TResponse>(RequestData, CancellationToken)

Declaration
public Task<TResponse> CallOpenSearchAsync<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
| Edit this page View Source

CallOpenSearch<TResponse>(RequestData)

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

CreateClientException<TResponse>(TResponse, IApiCallDetails, RequestData, List<PipelineException>)

Declaration
public OpenSearchClientException CreateClientException<TResponse>(TResponse response, IApiCallDetails callDetails, RequestData data, List<PipelineException> pipelineExceptions) where TResponse : class, IOpenSearchResponse, new()
Parameters
Type Name Description
TResponse response
IApiCallDetails callDetails
RequestData data
List<PipelineException> pipelineExceptions
Returns
Type Description
OpenSearchClientException
Type Parameters
Name Description
TResponse
| Edit this page View Source

Dispose()

Declaration
protected virtual void Dispose()
| Edit this page View Source

FirstPoolUsage(SemaphoreSlim)

Declaration
public void FirstPoolUsage(SemaphoreSlim semaphore)
Parameters
Type Name Description
SemaphoreSlim semaphore
| Edit this page View Source

FirstPoolUsageAsync(SemaphoreSlim, CancellationToken)

Declaration
public Task FirstPoolUsageAsync(SemaphoreSlim semaphore, CancellationToken cancellationToken)
Parameters
Type Name Description
SemaphoreSlim semaphore
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

MarkAlive(Node)

Declaration
public void MarkAlive(Node node)
Parameters
Type Name Description
Node node
| Edit this page View Source

MarkDead(Node)

Declaration
public void MarkDead(Node node)
Parameters
Type Name Description
Node node
| Edit this page View Source

NextNode()

Declaration
public IEnumerable<Node> NextNode()
Returns
Type Description
IEnumerable<Node>
| Edit this page View Source

Ping(Node)

Declaration
public void Ping(Node node)
Parameters
Type Name Description
Node node
| Edit this page View Source

PingAsync(Node, CancellationToken)

Declaration
public Task PingAsync(Node node, CancellationToken cancellationToken)
Parameters
Type Name Description
Node node
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

Sniff()

Declaration
public void Sniff()
| Edit this page View Source

SniffAsync(CancellationToken)

Declaration
public Task SniffAsync(CancellationToken cancellationToken)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

SniffOnConnectionFailure()

Declaration
public void SniffOnConnectionFailure()
| Edit this page View Source

SniffOnConnectionFailureAsync(CancellationToken)

Declaration
public Task SniffOnConnectionFailureAsync(CancellationToken cancellationToken)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

SniffOnStaleCluster()

Declaration
public void SniffOnStaleCluster()
| Edit this page View Source

SniffOnStaleClusterAsync(CancellationToken)

Declaration
public Task SniffOnStaleClusterAsync(CancellationToken cancellationToken)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ThrowNoNodesAttempted(RequestData, List<PipelineException>)

Declaration
public void ThrowNoNodesAttempted(RequestData requestData, List<PipelineException> seenExceptions)
Parameters
Type Name Description
RequestData requestData
List<PipelineException> seenExceptions

Implements

Extension Methods