We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 11aebf6 commit a775409Copy full SHA for a775409
checker/patroni_leader_checker.go
@@ -29,7 +29,7 @@ func (c *PatroniLeaderChecker) GetChangeNotificationStream(ctx context.Context,
29
select {
30
case <-ctx.Done():
31
return nil
32
- case <-time.After(time.Duration(cConf.Interval) * time.Millisecond):
+ case <-time.After(time.Duration(c.Interval) * time.Millisecond):
33
r, err := http.Get(c.Endpoints[0] + c.Key)
34
if err != nil {
35
log.Printf("patroni REST API error: %s", err)
0 commit comments