Implement basic Redis sentinel support

frosenberg · Nov 6, 2015 · 9488737 · 9488737
1 parent 09e58ec
commit 9488737
Show file tree

Hide file tree

Showing 9 changed files with 663 additions and 65 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -1,13 +1,14 @@
 language: go
 go:
 - 1.5
+services:
+- redis-server
 before_install:
+- redis-server etc/sentinel.conf --sentinel &
 - go get golang.org/x/tools/cmd/cover github.com/mattn/goveralls github.com/pierrre/gotestcover
 script:
 - gotestcover -covermode=count -coverprofile=coverage.out  ./...
 - goveralls -coverprofile=coverage.out -service=travis-ci -repotoken $COVERALLS_TOKEN
-services:
-- redis-server
 env:
   global:
     secure: hRWT25felfS2lfiSa9XJ/2ZOJS0wGIDSqTWVjBmZ+tGzZWK49oZQ7Gsbxj5SYxKma+m/Ko/AY/kzMVERXc+/4bFE5+NvTYizXXEbY8upAZl2QfQrwKbkmmjip+R3Q97I8lQrz2e12IJEGL66FXxY2oBwbH5h1D1XOyLTqPs14DK/ET9uL5YX9qrByHcdUyUS7DLHg8hUya01xkHf0Gg7UVBHKuoWYoOnpZwW1u1v87+qbrJixiax6KOKyf8jcGbktGRaPIIaLKkC7t82PB0Mb5qNWTvwGNnXlaldBXbria8HCGfCjI2nHhYvWeftVIpS6LW6G2GG7iuLXTDmGU5+w5H2T1MdkaYDgG4f6hJ8uHkqN2qT/s3NrEW2WVBnZ+rgG7KkJgIOkkdUrZVD+qbM5bv4IIg/Q+iyCq3A5XdMo/WijptFw132qdIq/N2sbg5M9osoeUW47MDWEEIQu35TSUFf1f0VLpe0FTBtheH2JABUozrPUzBeNcrpzSfuh6/GBeHEqaNvZD0f+YnOyNwJJDLVbvlj2oO3cUDnxhpTSsaz6R7tWUy1oAEKzt4rRM+Fjks9GwOtt+GlPai6LOYzLjH3J77p1o0EcbmWUarYeE/WDD3tl0dKLh612V5XCtH5/0vqclRqmHwXbolohiqEasKkG/M7jSuR+74LoYhDlsc=
diff --git a/Godeps/Godeps.json b/Godeps/Godeps.json
diff --git a/Godeps/_workspace/src/github.com/mediocregopher/radix.v2/sentinel/sentinel.go b/Godeps/_workspace/src/github.com/mediocregopher/radix.v2/sentinel/sentinel.go
diff --git a/api/types.go b/api/types.go
@@ -10,7 +10,7 @@ type Transport struct {
 // The TransportInterface allows connecting and disconnecting to a particular
 // Transport and managing its connectivity.
 type TransportInterface interface {
-	Connect() (err error)
+	Connect() (error)
 	Disconnect()
 }
 
@@ -21,7 +21,7 @@ type InputChannel interface {
 
 // An OutputChannel allows to send a Message to the channel.
 type OutputChannel interface {
-	Send(m *Message) (err error)
+	Send(m *Message) (error)
 }
 
 // An InputOutputChannel allow to receive and send message.