File Coverage

blib/lib/Search/Elasticsearch/Role/Cxn/Async/Simple.pm

Criterion	Covered	Total	%
statement	6	27	22.2
branch	0	14	0.0
condition			n/a
subroutine	2	6	33.3
pod	0	2	0.0
total	8	49	16.3

package Search::Elasticsearch::Role::Cxn::Async::Simple;

use Moo::Role;

use namespace::clean;

with 'Search::Elasticsearch::Role::Cxn';


sub pings_ok {
	my ($self, $cb) = @_;

	my $log = $self->logger;

	$log->infof('Pinging [%s]', $self->stringify)
		if $log->is_info;
	$self->perform_request(
		{
			method  => 'HEAD',
			path    => '/',
			timeout => $self->ping_timeout,
		},
		sub {
			if (@_) {
				$log->infof('Marking [%s] as live', $self->stringify)
					if $log->is_info;
				$self->mark_live();
				$cb->(1);
			}
			else {
				$log->debug($@)
					if $log->is_debug;
				$self->mark_dead();
				$cb->();
			}
		}
	);

	return;
}

sub sniff {
	my ($self, $cb) = @_;

	my $log = $self->logger;

	$log->infof('Sniffing [%s]', $self->stringify)
		if $log->is_info;
	$self->perform_request(
		{
			method  => 'GET',
			path    => '/_nodes/' . $self->protocol,
			qs      => {timeout => 1000 * $self->sniff_timeout},
			timeout => $self->sniff_request_timeout,
		},
		sub {
			if (@_) {
				$cb->($_[1]->{nodes});
			}
			else {
				$log->debug($@)
					if $log->is_debug;
				$cb->();
			}
		}
	);

	return;
}


1;


__END__