fix(logspout): add etcd client request timeout

deis · Oct 6, 2014 · 15b0843 · 15b0843
1 parent 1280daf
commit 15b0843
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/logspout/logspout.go b/logspout/logspout.go
@@ -10,6 +10,7 @@ import (
 	"os"
 	"strconv"
 	"strings"
+	"time"
 
 	"code.google.com/p/go.net/websocket"
 	"github.com/coreos/go-etcd/etcd"
@@ -143,6 +144,7 @@ func main() {
 		connectionString := []string{"http://" + etcdHost + ":4001"}
 		debug("etcd:", connectionString[0])
 		etcd := etcd.NewClient(connectionString)
+		etcd.SetDialTimeout(3 * time.Second)
 		hostResp, err := etcd.Get("/deis/logs/host", false, false)
 		assert(err, "url")
 		portResp, err := etcd.Get("/deis/logs/port", false, false)