"min_reconnect_interval" renamed to "reconnect_interval"

Author: iph0

README

@@ -1,4 +1,4 @@
-AnyEvent-RipeRedis version 0.24
+AnyEvent-RipeRedis version 0.25_01
 ======================
 
 INSTALLATION

examples/unix_socket.pl

@@ -10,12 +10,12 @@
 
 my $redis;
 $redis = AnyEvent::RipeRedis->new(
-  host                   => 'unix/',
-  port                   => '/var/run/redis/redis.sock',
-  password               => 'redis_pass',
-  connection_timeout     => 5,
-  read_timeout           => 5,
-  min_reconnect_interval => 5,
+  host               => 'unix/',
+  port               => '/var/run/redis/redis.sock',
+  password           => 'redis_pass',
+  connection_timeout => 5,
+  read_timeout       => 5,
+  reconnect_interval => 5,
 
   on_connect => sub {
     print "Connected to Redis server\n";

lib/AnyEvent/RipeRedis.pm

@@ -5,7 +5,7 @@ use strict;
 use warnings;
 use base qw( Exporter );
 
-our $VERSION = '0.24';
+our $VERSION = '0.25_01';
 
 use AnyEvent::RipeRedis::Error;
 
@@ -114,7 +114,7 @@ sub new {
 
   $self->connection_timeout( $params{connection_timeout} );
   $self->read_timeout( $params{read_timeout} );
-  $self->min_reconnect_interval( $params{min_reconnect_interval} );
+  $self->reconnect_interval( $params{reconnect_interval} );
   $self->on_error( $params{on_error} );
 
   $self->_reset_internals;
@@ -182,7 +182,7 @@ sub on_error {
   }
 
   foreach my $name ( qw( connection_timeout read_timeout
-      min_reconnect_interval ) )
+      reconnect_interval ) )
   {
     *{$name} = sub {
       my $self = shift;
@@ -562,12 +562,12 @@ sub _execute {
       $self->_connect;
     }
     elsif ( $self->{reconnect} ) {
-      if ( defined $self->{min_reconnect_interval}
-        && $self->{min_reconnect_interval} > 0 )
+      if ( defined $self->{reconnect_interval}
+        && $self->{reconnect_interval} > 0 )
       {
         unless ( defined $self->{_reconnect_timer} ) {
           $self->{_reconnect_timer} = AE::timer(
-            $self->{min_reconnect_interval}, 0,
+            $self->{reconnect_interval}, 0,
             sub {
               undef $self->{_reconnect_timer};
               $self->_connect;
@@ -1065,14 +1065,14 @@ Requires Redis 1.2 or higher, and any supported event loop.
 =head2 new( %params )
 
   my $redis = AnyEvent::RipeRedis->new(
-    host                   => 'localhost',
-    port                   => 6379,
-    password               => 'yourpass',
-    database               => 7,
-    connection_timeout     => 5,
-    read_timeout           => 5,
-    lazy                   => 1,
-    min_reconnect_interval => 5,
+    host               => 'localhost',
+    port               => 6379,
+    password           => 'yourpass',
+    database           => 7,
+    connection_timeout => 5,
+    read_timeout       => 5,
+    lazy               => 1,
+    reconnect_interval => 5,
 
     on_connect => sub {
       # handling...
@@ -1161,12 +1161,12 @@ you need. Such behavior allows to control reconnection procedure.
 
 Enabled by default.
 
-=item min_reconnect_interval => $fractional_seconds
+=item reconnect_interval => $fractional_seconds
 
-If the parameter is specified, the client will try to reconnect not often, than
-after this interval. Commands executed between reconnections will be queued.
+If the parameter is specified, the client will try to reconnect only after
+this interval. Commands executed between reconnections will be queued.
 
-  min_reconnect_interval => 5,
+  reconnect_interval => 5,
 
 Not set by default.
 
@@ -1792,9 +1792,9 @@ Get or set the C<read_timeout> of the client.
 
 Enables or disables reconnection mode of the client.
 
-=head2 min_reconnect_interval( [ $fractional_seconds ] )
+=head2 reconnect_interval( [ $fractional_seconds ] )
 
-Get or set C<min_reconnect_interval> of the client.
+Get or set C<reconnect_interval> of the client.
 
 =head2 on_connect( [ $callback ] )
 

lib/AnyEvent/RipeRedis/Error.pm

@@ -4,7 +4,7 @@ use 5.008000;
 use strict;
 use warnings;
 
-our $VERSION = '0.24';
+our $VERSION = '0.25_01';
 
 our %ERROR_CODES = (
   E_CANT_CONN                  => 1,

t/02-accessors.t

@@ -7,12 +7,11 @@ use AnyEvent::RipeRedis qw( :err_codes );
 use AnyEvent::RipeRedis::Error;
 
 my $redis = AnyEvent::RipeRedis->new(
-  password               => 'test',
-  connection_timeout     => 10,
-  read_timeout           => 5,
-  reconnect              => 1,
-  min_reconnect_interval => 5,
-  encoding               => 'utf8',
+  password           => 'test',
+  connection_timeout => 10,
+  read_timeout       => 5,
+  reconnect          => 1,
+  reconnect_interval => 5,
 
   on_connect => sub {
     return 1;
@@ -44,7 +43,7 @@ t_database($redis);
 t_conn_timeout($redis);
 t_read_timeout($redis);
 t_reconnect($redis);
-t_min_reconnect_interval($redis);
+t_reconnect_interval($redis);
 t_utf8($redis);
 t_on_connect($redis);
 t_on_disconnect($redis);
@@ -118,17 +117,17 @@ sub t_reconnect {
   return;
 }
 
-sub t_min_reconnect_interval {
+sub t_reconnect_interval {
   my $redis = shift;
 
-  is( $redis->min_reconnect_interval, 5, q{get "min_reconnect_interval"} );
+  is( $redis->reconnect_interval, 5, q{get "reconnect_interval"} );
 
-  $redis->min_reconnect_interval(undef);
-  is( $redis->min_reconnect_interval, undef,
-      q{disable "min_reconnect_interval"} );
+  $redis->reconnect_interval(undef);
+  is( $redis->reconnect_interval, undef,
+      q{disable "reconnect_interval"} );
 
-  $redis->min_reconnect_interval(10);
-  is( $redis->min_reconnect_interval, 10, q{set "min_reconnect_interval"} );
+  $redis->reconnect_interval(10);
+  is( $redis->reconnect_interval, 10, q{set "reconnect_interval"} );
 
   return;
 }

t/10-exceptions.t

@@ -8,7 +8,7 @@ use AnyEvent::RipeRedis;
 
 t_conn_timeout();
 t_read_timeout();
-t_min_reconnect_interval();
+t_reconnect_interval();
 t_not_allowed_after_multi();
 t_on_message();
 
@@ -97,43 +97,43 @@ sub t_read_timeout {
   return;
 }
 
-sub t_min_reconnect_interval {
+sub t_reconnect_interval {
   like(
     exception {
       my $redis = AnyEvent::RipeRedis->new(
-        min_reconnect_interval => 'invalid',
+        reconnect_interval => 'invalid',
       );
     },
-    qr/"min_reconnect_interval" must be a positive number/,
-    q{invalid "min_reconnect_interval" (character string; constructor)},
+    qr/"reconnect_interval" must be a positive number/,
+    q{invalid "reconnect_interval" (character string; constructor)},
   );
 
   like(
     exception {
       my $redis = AnyEvent::RipeRedis->new(
-        min_reconnect_interval => -5,
+        reconnect_interval => -5,
       );
     },
-    qr/"min_reconnect_interval" must be a positive number/,
-    q{invalid "min_reconnect_interval" (negative number; constructor)},
+    qr/"reconnect_interval" must be a positive number/,
+    q{invalid "reconnect_interval" (negative number; constructor)},
   );
 
   my $redis = AnyEvent::RipeRedis->new();
 
   like(
     exception {
-      $redis->min_reconnect_interval('invalid');
+      $redis->reconnect_interval('invalid');
     },
-    qr/"min_reconnect_interval" must be a positive number/,
-    q{invalid "min_reconnect_interval" (character string; accessor)},
+    qr/"reconnect_interval" must be a positive number/,
+    q{invalid "reconnect_interval" (character string; accessor)},
   );
 
   like(
     exception {
-      $redis->min_reconnect_interval(-5);
+      $redis->reconnect_interval(-5);
     },
-    qr/"min_reconnect_interval" must be a positive number/,
-    q{invalid "min_reconnect_interval" (negative number; accessor)},
+    qr/"reconnect_interval" must be a positive number/,
+    q{invalid "reconnect_interval" (negative number; accessor)},
   );
 
   return;