Refactor EndpointSet (thanos-io#5538)

* Refactor EndpointSet This commit refactors the EndpointSet struct in order to make it easier to understand and work with. Signed-off-by: Filip Petkovski <[email protected]> * Handle context cancellation in endpoint mock Signed-off-by: Filip Petkovski <[email protected]> * Make additions and removals of refs atomic. Signed-off-by: Filip Petkovski <[email protected]>
hzwwww · Jul 27, 2022 · fd275f8 · fd275f8
1 parent 15decfe
commit fd275f8
Show file tree

Hide file tree

Showing 4 changed files with 692 additions and 255 deletions.
diff --git a/cmd/thanos/query.go b/cmd/thanos/query.go
@@ -420,6 +420,7 @@ func runQuery(
 
 	var (
 		endpoints = query.NewEndpointSet(
+			time.Now,
 			logger,
 			reg,
 			func() (specs []*query.GRPCEndpointSpec) {
-Original file line number
+Diff line change
@@ Expand Up / @@ -420,6 +420,7 @@ func runQuery( @@
     	var (
     		endpoints = query.NewEndpointSet(
+    			time.Now,
     			logger,
     			reg,
     			func() (specs []*query.GRPCEndpointSpec) {
@@ Expand Down @@