We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1280daf commit 15b0843Copy full SHA for 15b0843
1 file changed
logspout/logspout.go
@@ -10,6 +10,7 @@ import (
10
"os"
11
"strconv"
12
"strings"
13
+ "time"
14
15
"code.google.com/p/go.net/websocket"
16
"github.com/coreos/go-etcd/etcd"
@@ -143,6 +144,7 @@ func main() {
143
144
connectionString := []string{"http://" + etcdHost + ":4001"}
145
debug("etcd:", connectionString[0])
146
etcd := etcd.NewClient(connectionString)
147
+ etcd.SetDialTimeout(3 * time.Second)
148
hostResp, err := etcd.Get("/deis/logs/host", false, false)
149
assert(err, "url")
150
portResp, err := etcd.Get("/deis/logs/port", false, false)
0 commit comments