Skip to content

Commit 2f5f1b4

Browse files
committed
Added parsing of reply of "CLUSTER INFO" command
1 parent 8466f24 commit 2f5f1b4

File tree

1 file changed

+13
-6
lines changed

1 file changed

+13
-6
lines changed

lib/AnyEvent/RipeRedis.pm

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,10 @@ my %NEED_PREPROCESS = (
6666
);
6767

6868
my %NEED_POSTPROCESS = (
69-
info => 1,
70-
select => 1,
71-
quit => 1,
69+
info => 1,
70+
cluster_info => 1,
71+
select => 1,
72+
quit => 1,
7273
);
7374

7475
my %ERR_PREFS_MAP = (
@@ -850,9 +851,10 @@ sub _process_success {
850851
shift @{ $self->{_processing_queue} };
851852

852853
if ( exists $NEED_POSTPROCESS{ $cmd->{name} } ) {
853-
if ( $cmd->{name} eq 'info' ) {
854-
$reply = { map { split( m/:/, $_, 2 ) }
855-
grep { m/^[^#]/ } split( EOL, $reply ) };
854+
if ( $cmd->{name} eq 'info'
855+
|| $cmd->{name} eq 'cluster_info' )
856+
{
857+
$reply = _parse_info($reply);
856858
}
857859
elsif ( $cmd->{name} eq 'select' ) {
858860
$self->{database} = $cmd->{args}[0];
@@ -868,6 +870,11 @@ sub _process_success {
868870
return;
869871
}
870872

873+
sub _parse_info {
874+
return { map { split( m/:/, $_, 2 ) }
875+
grep { m/^[^#]/ } split( EOL, $_[0] ) };
876+
}
877+
871878
sub _disconnect {
872879
my $self = shift;
873880
my $err = shift;

0 commit comments

Comments
 (0)