使用ip地址作为HashingLoadBalancer的hash key (#38)

flomesh-io · Sep 4, 2023 · 79bddca · 79bddca
1 parent f224780
commit 79bddca
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pjs/http/forward.js b/pjs/http/forward.js
@@ -148,6 +148,7 @@
   _unhealthCache: null,
   _healthCheckTarget: null,
   _targetResource: null,
+  _balancerKey: undefined,
 })
 
 .import({
@@ -212,7 +213,8 @@
       _cookieId ? (
         __target = _cookieId
       ) : (
-        (_targetResource = _targetBalancer?.borrow?.(undefined, undefined, _unhealthCache)) && (
+        (__service?.Algorithm === 'HashingLoadBalancer') && (_balancerKey = __inbound.remoteAddress),
+        (_targetResource = _targetBalancer?.borrow?.(undefined, _balancerKey, _unhealthCache)) && (
           __target = _targetResource?.id
         )
       ),