Plugin::KeyValueStore: support Redis sentinel

diff --git a/src/newslash_web/lib/Newslash/Plugin/KeyValueStore.pm b/src/newslash_web/lib/Newslash/Plugin/KeyValueStore.pm
index 18c1f74..9b4cc8e 100644 (file)
--- a/src/newslash_web/lib/Newslash/Plugin/KeyValueStore.pm
+++ b/src/newslash_web/lib/Newslash/Plugin/KeyValueStore.pm
@@ -62,7 +62,14 @@ sub _connect {
     if ($self->{_r}) {
         return $self->{_r};
     }
-    my $r = Redis->new(server => $self->{conf}->{host});
+    my $r;
+    if ($self->{conf}->{sentinels}) {
+       $r = Redis->new(sentinels => $self->{conf}->{sentinels},
+                       service => $self->{conf}->{service});
+    }
+    else {
+       $r = Redis->new(server => $self->{conf}->{host});
+    }
     $r->connect;
     $self->{_r} = $r;
     if (defined $self->{index_number}) {