Redis supports failover through Sentinel

README.md

@@ -1,3 +1,17 @@
+#Changelog
+
+#####redis-sentinel example conf
+
+```
+    redis {
+       data_type=>"list"
+       db=>0
+       key=>"logstash-%{type}"
+       sentinel_hosts=>["127.0.0.1:26380"]
+       password=>"123"
+    }
+```
+
 # Logstash Plugin
 
 [![Travis Build Status](https://travis-ci.org/logstash-plugins/logstash-output-redis.svg)](https://travis-ci.org/logstash-plugins/logstash-output-redis)
@@ -95,4 +109,5 @@ Programming is not a required skill. Whatever you've seen about open source and
 
 It is more important to the community that you are able to contribute.
 
-For more information about contributing, see the [CONTRIBUTING](https://github.com/elastic/logstash/blob/master/CONTRIBUTING.md) file.
+For more information about contributing, see the [CONTRIBUTING](https://github.com/elastic/logstash/blob/master/CONTRIBUTING.md) file.
+

lib/logstash/outputs/redis.rb

@@ -92,6 +92,10 @@ class LogStash::Outputs::Redis < LogStash::Outputs::Base
   # Zero means to check on every event.
   config :congestion_interval, :validate => :number, :default => 1
 
+  config :sentinel_hosts, :validate => :array
+
+  config :master, :validate => :string, :default => "mymaster"
+
   def register
     require 'redis'
 
@@ -186,8 +190,6 @@ def connect
     end
 
     params = {
-      :host => @current_host,
-      :port => @current_port,
       :timeout => @timeout,
       :db => @db
     }
@@ -197,11 +199,33 @@ def connect
       params[:password] = @password.value
     end
 
+    if @sentinel_hosts
+      @logger.info('Connecting to sentinel')
+      hosts = []
+      for sentinel_host in @sentinel_hosts
+        host, port = sentinel_host.split(":")
+        unless port
+          port = @sentinel_port
+        end
+        hosts.push({:host => host, :port => port})
+      end
+      params[:url] = 'redis://'+@master
+      params[:sentinels] = hosts
+      params[:role] = :master
+    else
+      params[:host] = @current_host
+      params[:port] = @current_port
+    end
+
+
     Redis.new(params)
   end # def connect
 
   # A string used to identify a Redis instance in log messages
   def identity
+    if @sentinel_hosts
+      return "redis-sentinel://#{@password} #{$sentinel_hosts} #{@db} #{@data_type}:#{@key}"
+    end
     "redis://#{@password}@#{@current_host}:#{@current_port}/#{@db} #{@data_type}:#{@key}"
   end