diff options
| author |   Vladimir Lavor <vlavor@cisco.com> | 2021-03-22 13:34:37 +0100 |
|---|---|---|
| committer |   Ondrej Fabry <ofabry@cisco.com> | 2021-04-07 11:30:08 +0000 |
| commit | 671f16c7b4ca24788fc503b4344fa22306548a3b (patch) | |
| tree | f34bd0631ceec47c3065bdd6b611f7bf186bbc61 /examples/stats-client | |
| parent | 8ff6fc436ce5a5be694e7d4cc9e56ded10184d80 (diff) | |
Add statsclient options and fix wait for socket
Change-Id: Ib5674fee5862a2b16f4b0044b6f6af533a7b6b33
Signed-off-by: Vladimir Lavor <vlavor@cisco.com>
Diffstat (limited to 'examples/stats-client')
| -rw-r--r-- | examples/stats-client/stats_api.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/examples/stats-client/stats_api.go b/examples/stats-client/stats_api.go index 0ccfa89..fa39b54 100644 --- a/examples/stats-client/stats_api.go +++ b/examples/stats-client/stats_api.go @@ -67,7 +67,8 @@ func main() { if *async { var statsChan chan core.ConnectionEvent - client = statsclient.NewStatsClient(*statsSocket) + client = statsclient.NewStatsClient(*statsSocket, statsclient.SetSocketRetryPeriod(1*time.Second), + statsclient.SetSocketRetryTimeout(10*time.Second)) c, statsChan, err = core.AsyncConnectStats(client, core.DefaultMaxReconnectAttempts, core.DefaultReconnectInterval) if err != nil { log.Fatalln("Asynchronous connecting failed:", err) |