File Coverage

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

Criterion	Covered	Total	%
statement	12	19	63.1
branch	0	6	0.0
condition	0	3	0.0
subroutine	4	5	80.0
pod	0	1	0.0
total	16	34	47.0

package Search::Elasticsearch::Async::Simple;

use Moo;

use Search::Elasticsearch 1.10;
use Search::Elasticsearch::Util qw(parse_params);

use namespace::clean;

extends 'Search::Elasticsearch';


our $VERSION = '0.03';


sub new {
	my ($class, $pars) = parse_params(@_);

	for (qw(client cxn cxn_pool transport)) {
		next unless exists($pars->{$_}) && defined($pars->{$_});
		next if index($pars->{$_}, '+')             == 0;
		next if index($pars->{$_}, 'Async::Simple') == 0;

		$pars->{$_} = 'Async::Simple::' . $pars->{$_};
	}

	return $class->SUPER::new({
		client              => 'Async::Simple::Direct',
		transport           => 'Async::Simple',
		cxn_pool            => 'Async::Simple::Static',
		cxn                 => 'Async::Simple::AEHTTP',
		%$pars,
	});
}


1;


__END__