Class RequestPipeline

Inheritance

object

RequestPipeline

Implements

IRequestPipeline

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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

IRequestPipeline

IDisposable

Extension Methods

SuffixExtensions.Suffix(object, string)