package Search::Elasticsearch::CxnPool::Static::NoPing; $Search::Elasticsearch::CxnPool::Static::NoPing::VERSION = '1.10'; use Moo; with 'Search::Elasticsearch::Role::CxnPool::Static::NoPing', 'Search::Elasticsearch::Role::Is_Sync'; use Search::Elasticsearch::Util qw(throw); use namespace::clean; #=================================== sub next_cxn { #=================================== my $self = shift; my $cxns = $self->cxns; my $total = @$cxns; my $dead = $self->_dead_cxns; while ( $total-- ) { my $cxn = $cxns->[ $self->next_cxn_num ]; return $cxn if $cxn->is_live || $cxn->next_ping < time(); push @$dead, $cxn unless grep { $_ eq $cxn } @$dead; } if ( @$dead and $self->retries <= $self->max_retries ) { $_->force_ping for @$dead; return shift @$dead; } throw( "NoNodes", "No nodes are available: [" . $self->cxns_str . ']' ); } 1; =pod =encoding UTF-8 =head1 NAME Search::Elasticsearch::CxnPool::Static::NoPing - A CxnPool for connecting to a remote cluster without the ability to ping. =head1 VERSION version 1.10 =head1 SYNOPSIS $e = Search::Elasticsearch->new( cxn_pool => 'Static::NoPing' nodes => [ 'search1:9200', 'search2:9200' ], ); =head1 DESCRIPTION The L connection pool (like the L pool) should be used when your access to the cluster is limited. However, the C pool needs to be able to ping nodes in the cluster, with a C request. If you can't ping your nodes, then you should use the C connection pool instead. Because the cluster cannot be pinged, this CxnPool cannot use a short ping request to determine whether nodes are live or not - it just has to send requests to the nodes to determine whether they are alive or not. Most of the time, a dead node will cause the request to fail quickly. However, in situations where node failure takes time (eg malfunctioning routers or firewalls), a failure may not be reported until the request itself times out (see L). Failed nodes will be retried regularly to check if they have recovered. This class does L and L. =head1 CONFIGURATION =head2 C The list of nodes to use to serve requests. Can accept a single node, multiple nodes, and defaults to C if no C are specified. See L for details of the node specification. =head2 See also =over =item * L =item * L =item * L =back =head2 Inherited configuration From L =over =item * L =back From L =over =item * L =back =head1 METHODS =head2 C $cxn = $cxn_pool->next_cxn Returns the next available node in round robin fashion - either a live node which has previously responded successfully, or a previously failed node which should be retried. If all nodes are dead, it will throw a C error. =head2 Inherited methods From L =over =item * L =item * L =back From L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =item * L =back =head1 AUTHOR Clinton Gormley =head1 COPYRIGHT AND LICENSE This software is Copyright (c) 2014 by Elasticsearch BV. This is free software, licensed under: The Apache License, Version 2.0, January 2004 =cut __END__ # ABSTRACT: A CxnPool for connecting to a remote cluster without the ability to ping.