Class StickySniffingConnectionPool

Namespace

Elasticsearch.Net

Assembly

Elasticsearch.Net.dll

public class StickySniffingConnectionPool : SniffingConnectionPool, IConnectionPool, IDisposable

Inheritance

object

StaticConnectionPool

SniffingConnectionPool

StickySniffingConnectionPool

Implements

IConnectionPool

IDisposable

Inherited Members

SniffingConnectionPool.Reseed(IEnumerable<Node>)

SniffingConnectionPool.DisposeManagedResources()

SniffingConnectionPool.Nodes

StaticConnectionPool.GlobalCursor

StaticConnectionPool.RetryInternalNodes(int, Action<AuditEvent, Node>)

StaticConnectionPool.SelectAliveNodes(int, List<Node>, Action<AuditEvent, Node>)

StaticConnectionPool.SortNodes(IEnumerable<Node>)

StaticConnectionPool.DateTimeProvider

StaticConnectionPool.Random

StaticConnectionPool.Randomize

StaticConnectionPool.InternalNodes

StaticConnectionPool.AliveNodes

StaticConnectionPool.MaxRetries

StaticConnectionPool.UsingSsl

StaticConnectionPool.SniffedOnStartup

StaticConnectionPool.LastUpdate

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

StickySniffingConnectionPool(IEnumerable<Node>, Func<Node, float>, IDateTimeProvider)

public StickySniffingConnectionPool(IEnumerable<Node> nodes, Func<Node, float> nodeScorer, IDateTimeProvider dateTimeProvider = null)

Parameters

nodes IEnumerable<Node>

nodeScorer Func<Node, float>

dateTimeProvider IDateTimeProvider

StickySniffingConnectionPool(IEnumerable<Uri>, Func<Node, float>, IDateTimeProvider)

public StickySniffingConnectionPool(IEnumerable<Uri> uris, Func<Node, float> nodeScorer, IDateTimeProvider dateTimeProvider = null)

Parameters

uris IEnumerable<Uri>

nodeScorer Func<Node, float>

dateTimeProvider IDateTimeProvider

Properties

SupportsPinging

public override bool SupportsPinging { get; }

Property Value

bool

SupportsReseeding

Signals that this implemenation can accept new nodes

public override bool SupportsReseeding { get; }

Property Value

bool

Methods

CreateView(Action<AuditEvent, Node>)

Creates a view of all the live nodes with changing starting positions that wraps over on each call e.g Thread A might get 1,2,3,4,5 and thread B will get 2,3,4,5,1. if there are no live nodes yields a different dead node to try once

public override IEnumerable<Node> CreateView(Action<AuditEvent, Node> audit = null)

Parameters

audit Action<AuditEvent, Node>

Returns

IEnumerable<Node>