Skip to content

Commit f3ddae9

Browse files
add reasonable reconnect parameters
1 parent 5895b20 commit f3ddae9

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

main.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,14 @@ func main() {
2020
select {
2121
case <-ticker.C:
2222
var err error
23-
conn, err = memphis.Connect(configuration.MEMPHIS_HOST, configuration.ROOT_USER, configuration.CONNECTION_TOKEN)
23+
conn, err = memphis.Connect(
24+
configuration.MEMPHIS_HOST,
25+
configuration.ROOT_USER,
26+
configuration.CONNECTION_TOKEN,
27+
memphis.Reconnect(true),
28+
memphis.MaxReconnect(10),
29+
memphis.ReconnectInterval(3*time.Second),
30+
)
2431
if err == nil {
2532
ticker.Stop()
2633
goto serverInit

version.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
0.1.1
1+
0.1.2

0 commit comments

Comments
 (0)