Skip to content

Commit 0f2987a

Browse files
committed
Don't exit out of watch loop if can't connect to docker
1 parent ac12a4d commit 0f2987a

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

docker_client.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import (
1313
"strconv"
1414
"strings"
1515
"syscall"
16+
"time"
1617

1718
docker "github.com/fsouza/go-dockerclient"
1819
)
@@ -127,20 +128,25 @@ func getEvents() chan *Event {
127128
c, err := newConn()
128129
if err != nil {
129130
log.Printf("cannot connect to docker: %s\n", err)
130-
return
131+
time.Sleep(10 * time.Second)
132+
goto restart
131133
}
132134
defer c.Close()
133135

134136
req, err := http.NewRequest("GET", "/events", nil)
135137
if err != nil {
136138
log.Printf("bad request for events: %s\n", err)
137-
return
139+
c.Close()
140+
time.Sleep(10 * time.Second)
141+
goto restart
138142
}
139143

140144
resp, err := c.Do(req)
141145
if err != nil {
142146
log.Printf("cannot connect to events endpoint: %s\n", err)
143-
return
147+
c.Close()
148+
time.Sleep(10 * time.Second)
149+
goto restart
144150
}
145151
defer resp.Body.Close()
146152

0 commit comments

Comments
 (0)