Search Results for

    Show / Hide Table of Contents

    Interface IRequestPipeline

    Inherited Members
    IDisposable.Dispose()
    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

    SuffixExtensions.Suffix(object, string)
    • Edit this page
    • View Source
    In this article
    • Properties
      • AuditTrail
      • FirstPoolUsageNeedsSniffing
      • IsTakingTooLong
      • MaxRetries
      • Retried
      • SniffsOnConnectionFailure
      • SniffsOnStaleCluster
      • StaleClusterState
      • StartedOn
    • Methods
      • AuditCancellationRequested()
      • BadResponse<TResponse>(ref TResponse, IApiCallDetails, RequestData, OpenSearchClientException)
      • CallOpenSearchAsync<TResponse>(RequestData, CancellationToken)
      • CallOpenSearch<TResponse>(RequestData)
      • CreateClientException<TResponse>(TResponse, IApiCallDetails, RequestData, List<PipelineException>)
      • FirstPoolUsage(SemaphoreSlim)
      • FirstPoolUsageAsync(SemaphoreSlim, CancellationToken)
      • MarkAlive(Node)
      • MarkDead(Node)
      • NextNode()
      • Ping(Node)
      • PingAsync(Node, CancellationToken)
      • Sniff()
      • SniffAsync(CancellationToken)
      • SniffOnConnectionFailure()
      • SniffOnConnectionFailureAsync(CancellationToken)
      • SniffOnStaleCluster()
      • SniffOnStaleClusterAsync(CancellationToken)
      • ThrowNoNodesAttempted(RequestData, List<PipelineException>)
    • Extension Methods
    Back to top Generated by DocFX