Load Balancing policies

apple · Dec 11, 2024 · 2d1db2a · 2d1db2a
1 parent 8024d67
commit 2d1db2a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 6 deletions.
diff --git a/...lk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/DefaultLoadBalancerBuilder.java b/...lk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/DefaultLoadBalancerBuilder.java
@@ -39,7 +39,7 @@ final class DefaultLoadBalancerBuilder<ResolvedAddress, C extends LoadBalancedCo
     private Executor backgroundExecutor;
     @Nullable
     private LoadBalancerObserverFactory loadBalancerObserverFactory;
-    private LoadBalancingPolicy<ResolvedAddress, C> loadBalancingPolicy = defaultLoadBalancingPolicy();
+    private LoadBalancingPolicy<ResolvedAddress, C> loadBalancingPolicy = LoadBalancingPolicies.defaultPolicy();
     private ConnectionPoolPolicy<C> connectionPoolPolicy = ConnectionPoolPolicies.defaultPolicy();;
     private OutlierDetectorConfig outlierDetectorConfig = OutlierDetectorConfig.DEFAULT_CONFIG;
 
@@ -181,9 +181,4 @@ private Executor getExecutor() {
         return backgroundExecutor ==
                 null ? RoundRobinLoadBalancerFactory.SharedExecutor.getInstance() : backgroundExecutor;
     }
-
-    private static <ResolvedAddress, C extends LoadBalancedConnection>
-    LoadBalancingPolicy<ResolvedAddress, C> defaultLoadBalancingPolicy() {
-        return LoadBalancingPolicies.roundRobin().build();
-    }
 }
diff --git a/...icetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/LoadBalancingPolicies.java b/...icetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/LoadBalancingPolicies.java
@@ -15,6 +15,8 @@
  */
 package io.servicetalk.loadbalancer;
 
+import io.servicetalk.client.api.LoadBalancedConnection;
+
 /**
  * A collections of factories for constructing a {@link LoadBalancingPolicy}.
  */
@@ -24,6 +26,15 @@ private LoadBalancingPolicies() {
         // no instances.
     }
 
+    /**
+     * Get the recommended default {@link LoadBalancingPolicy}.
+     * @return the recommended default {@link LoadBalancingPolicy}.
+     */
+    public static <ResolvedAddress, C extends LoadBalancedConnection>
+    LoadBalancingPolicy<ResolvedAddress, C> defaultPolicy() {
+        return LoadBalancingPolicies.roundRobin().build();
+    }
+
     /**
      * Builder for the round-robin {@link LoadBalancingPolicy}.
      * Round-robin load balancing is a strategy that maximizes fairness of the request distribution. This comes at the