Skip to content
This repository was archived by the owner on Aug 23, 2023. It is now read-only.

Commit ca4439c

Browse files
committed
Clarify comments
1 parent 3922e53 commit ca4439c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

api/cluster.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -304,8 +304,9 @@ func (s *Server) peerQuery(ctx context.Context, data cluster.Traceable, name, pa
304304

305305
// peerQuerySpeculative takes a request and the path to request it on, then fans it out
306306
// across the cluster, except to the local peer. If any peer fails requests to
307-
// other peers are aborted. If 95% of peers have been heard from, and we are missing
308-
// the others, try to speculatively query ANOTHER member of the shard group.
307+
// other peers are aborted. If enough peers have been heard from (based on
308+
// speculation-threshold configuration), and we are missing the others, try to
309+
// speculatively query other members of the shard group.
309310
// ctx: request context
310311
// data: request to be submitted
311312
// name: name to be used in logging & tracing

0 commit comments

Comments
 (0)