fix: increase staleThreshold to 10s
This commit is contained in:
@@ -57,7 +57,7 @@ func NewNodeDiscovery(udpPort string) *NodeDiscovery {
|
||||
return &NodeDiscovery{
|
||||
udpPort: udpPort,
|
||||
discoveredNodes: make(map[string]*NodeInfo),
|
||||
staleThreshold: 8 * time.Second, // 8 seconds to accommodate 5-second heartbeat interval
|
||||
staleThreshold: 10 * time.Second, // TODO make configurable
|
||||
logger: log.New(),
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user