File Coverage

blib/lib/Redis/Fast/Sentinel.pm

Criterion	Covered	Total	%
statement	12	24	50.0
branch	0	6	0.0
condition			n/a
subroutine	4	7	57.1
pod	3	3	100.0
total	19	40	47.5

package Redis::Fast::Sentinel;

# ABSTRACT: Redis::Fast Sentinel interface

use warnings;
use strict;

use Carp;

use base qw(Redis::Fast);

sub new {
    my ($class, %args) = @_;
    # these args are not allowed when contacting a sentinel
    delete @args{qw(sentinels service)};
    # Do not support SSL for sentinels
    $args{ssl} = 0;

    $class->SUPER::new(%args);
}

sub get_service_address {
    my ($self, $service) = @_;
    my ($ip, $port) = $self->sentinel('get-master-addr-by-name', $service);
    defined $ip
      or return;
    $ip eq 'IDONTKNOW'
      and return $ip;
    return "$ip:$port";
}

sub get_masters {
    map { +{ @$_ }; } @{ shift->sentinel('masters') || [] };
}

1;

__END__