Class RequestPipeline

Namespace

Elasticsearch.Net

Assembly

Elasticsearch.Net.dll

public class RequestPipeline : IRequestPipeline, IDisposable

Inheritance

object

RequestPipeline

Implements

IRequestPipeline

IDisposable

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

RequestPipeline(IConnectionConfigurationValues, IDateTimeProvider, IMemoryStreamFactory, IRequestParameters)

public RequestPipeline(IConnectionConfigurationValues configurationValues, IDateTimeProvider dateTimeProvider, IMemoryStreamFactory memoryStreamFactory, IRequestParameters requestParameters)

Parameters

configurationValues IConnectionConfigurationValues

dateTimeProvider IDateTimeProvider

memoryStreamFactory IMemoryStreamFactory

requestParameters IRequestParameters

Properties

AuditTrail

public List<Audit> AuditTrail { get; }

Property Value

List<Audit>

DepleededRetries

public bool DepleededRetries { get; }

Property Value

bool

FirstPoolUsageNeedsSniffing

public bool FirstPoolUsageNeedsSniffing { get; }

Property Value

bool

IsTakingTooLong

public bool IsTakingTooLong { get; }

Property Value

bool

MaxRetries

public int MaxRetries { get; }

Property Value

int

Refresh

public bool Refresh { get; }

Property Value

bool

Retried

public int Retried { get; }

Property Value

int

SniffNodes

public IEnumerable<Node> SniffNodes { get; }

Property Value

IEnumerable<Node>

SniffPath

public static string SniffPath { get; }

Property Value

string

SniffsOnConnectionFailure

public bool SniffsOnConnectionFailure { get; }

Property Value

bool

SniffsOnStaleCluster

public bool SniffsOnStaleCluster { get; }

Property Value

bool

StaleClusterState

public bool StaleClusterState { get; }

Property Value

bool

StartedOn

public DateTime StartedOn { get; }

Property Value

DateTime

Methods

AuditCancellationRequested()

public void AuditCancellationRequested()

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

public void BadResponse<TResponse>(ref TResponse response, IApiCallDetails callDetails, RequestData data, ElasticsearchClientException exception) where TResponse : class, IElasticsearchResponse, new()

Parameters

response TResponse

callDetails IApiCallDetails

data RequestData

exception ElasticsearchClientException

Type Parameters

TResponse

CallElasticsearchAsync<TResponse>(RequestData, CancellationToken)

public Task<TResponse> CallElasticsearchAsync<TResponse>(RequestData requestData, CancellationToken cancellationToken) where TResponse : class, IElasticsearchResponse, new()

Parameters

requestData RequestData

cancellationToken CancellationToken

Returns

Task<TResponse>

Type Parameters

TResponse

CallElasticsearch<TResponse>(RequestData)

public TResponse CallElasticsearch<TResponse>(RequestData requestData) where TResponse : class, IElasticsearchResponse, new()

Parameters

requestData RequestData

Returns

TResponse

Type Parameters

TResponse

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

public ElasticsearchClientException CreateClientException<TResponse>(TResponse response, IApiCallDetails callDetails, RequestData data, List<PipelineException> pipelineExceptions) where TResponse : class, IElasticsearchResponse, new()

Parameters

response TResponse

callDetails IApiCallDetails

data RequestData

pipelineExceptions List<PipelineException>

Returns

ElasticsearchClientException

Type Parameters

TResponse

Dispose()

protected virtual void Dispose()

FirstPoolUsage(SemaphoreSlim)

public void FirstPoolUsage(SemaphoreSlim semaphore)

Parameters

semaphore SemaphoreSlim

FirstPoolUsageAsync(SemaphoreSlim, CancellationToken)

public Task FirstPoolUsageAsync(SemaphoreSlim semaphore, CancellationToken cancellationToken)

Parameters

semaphore SemaphoreSlim

cancellationToken CancellationToken

Returns

Task

MarkAlive(Node)

public void MarkAlive(Node node)

Parameters

node Node

MarkDead(Node)

public void MarkDead(Node node)

Parameters

node Node

NextNode()

public IEnumerable<Node> NextNode()

Returns

IEnumerable<Node>

Ping(Node)

public void Ping(Node node)

Parameters

node Node

PingAsync(Node, CancellationToken)

public Task PingAsync(Node node, CancellationToken cancellationToken)

Parameters

node Node

cancellationToken CancellationToken

Returns

Task

Sniff()

public void Sniff()

SniffAsync(CancellationToken)

public Task SniffAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

SniffOnConnectionFailure()

public void SniffOnConnectionFailure()

SniffOnConnectionFailureAsync(CancellationToken)

public Task SniffOnConnectionFailureAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

SniffOnStaleCluster()

public void SniffOnStaleCluster()

SniffOnStaleClusterAsync(CancellationToken)

public Task SniffOnStaleClusterAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

ThrowNoNodesAttempted(RequestData, List<PipelineException>)

public void ThrowNoNodesAttempted(RequestData requestData, List<PipelineException> seenExceptions)

Parameters

requestData RequestData

seenExceptions List<PipelineException>