Interface IRequestPipeline

Inherited Members
Namespace: OpenSearch.Net
Assembly: OpenSearch.Net.dll
Syntax
public interface IRequestPipeline : IDisposable

Properties

| Edit this page View Source

AuditTrail

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

FirstPoolUsageNeedsSniffing

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

IsTakingTooLong

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

MaxRetries

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

Retried

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

SniffsOnConnectionFailure

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

SniffsOnStaleCluster

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

StaleClusterState

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

StartedOn

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

Methods

| Edit this page View Source

AuditCancellationRequested()

Declaration
void AuditCancellationRequested()
| Edit this page View Source

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

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

FirstPoolUsage(SemaphoreSlim)

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

FirstPoolUsageAsync(SemaphoreSlim, CancellationToken)

Declaration
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
void MarkAlive(Node node)
Parameters
Type Name Description
Node node
| Edit this page View Source

MarkDead(Node)

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

NextNode()

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

Ping(Node)

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

PingAsync(Node, CancellationToken)

Declaration
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
void Sniff()
| Edit this page View Source

SniffAsync(CancellationToken)

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

SniffOnConnectionFailure()

Declaration
void SniffOnConnectionFailure()
| Edit this page View Source

SniffOnConnectionFailureAsync(CancellationToken)

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

SniffOnStaleCluster()

Declaration
void SniffOnStaleCluster()
| Edit this page View Source

SniffOnStaleClusterAsync(CancellationToken)

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

ThrowNoNodesAttempted(RequestData, List<PipelineException>)

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

Extension Methods