Interface IRequestPipeline

Namespace

Elasticsearch.Net

Assembly

Elasticsearch.Net.dll

public interface IRequestPipeline : IDisposable

Inherited Members

IDisposable.Dispose()

Properties

AuditTrail

List<Audit> AuditTrail { get; }

Property Value

List<Audit>

FirstPoolUsageNeedsSniffing

bool FirstPoolUsageNeedsSniffing { get; }

Property Value

bool

IsTakingTooLong

bool IsTakingTooLong { get; }

Property Value

bool

MaxRetries

int MaxRetries { get; }

Property Value

int

Retried

int Retried { get; }

Property Value

int

SniffsOnConnectionFailure

bool SniffsOnConnectionFailure { get; }

Property Value

bool

SniffsOnStaleCluster

bool SniffsOnStaleCluster { get; }

Property Value

bool

StaleClusterState

bool StaleClusterState { get; }

Property Value

bool

StartedOn

DateTime StartedOn { get; }

Property Value

DateTime

Methods

AuditCancellationRequested()

void AuditCancellationRequested()

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

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)

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)

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>)

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

Parameters

response TResponse

callDetails IApiCallDetails

data RequestData

seenExceptions List<PipelineException>

Returns

ElasticsearchClientException

Type Parameters

TResponse

FirstPoolUsage(SemaphoreSlim)

void FirstPoolUsage(SemaphoreSlim semaphore)

Parameters

semaphore SemaphoreSlim

FirstPoolUsageAsync(SemaphoreSlim, CancellationToken)

Task FirstPoolUsageAsync(SemaphoreSlim semaphore, CancellationToken cancellationToken)

Parameters

semaphore SemaphoreSlim

cancellationToken CancellationToken

Returns

Task

MarkAlive(Node)

void MarkAlive(Node node)

Parameters

node Node

MarkDead(Node)

void MarkDead(Node node)

Parameters

node Node

NextNode()

IEnumerable<Node> NextNode()

Returns

IEnumerable<Node>

Ping(Node)

void Ping(Node node)

Parameters

node Node

PingAsync(Node, CancellationToken)

Task PingAsync(Node node, CancellationToken cancellationToken)

Parameters

node Node

cancellationToken CancellationToken

Returns

Task

Sniff()

void Sniff()

SniffAsync(CancellationToken)

Task SniffAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

SniffOnConnectionFailure()

void SniffOnConnectionFailure()

SniffOnConnectionFailureAsync(CancellationToken)

Task SniffOnConnectionFailureAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

SniffOnStaleCluster()

void SniffOnStaleCluster()

SniffOnStaleClusterAsync(CancellationToken)

Task SniffOnStaleClusterAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

ThrowNoNodesAttempted(RequestData, List<PipelineException>)

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

Parameters

requestData RequestData

seenExceptions List<PipelineException>