add spi

Author: impactCn

shenyu-loadbalancer/src/main/java/org/apache/shenyu/loadbalancer/spi/PeakEWMALoadBalancer.java

@@ -18,6 +18,7 @@
 package org.apache.shenyu.loadbalancer.spi;
 
 import org.apache.shenyu.loadbalancer.entity.Upstream;
+import org.apache.shenyu.spi.Join;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -41,13 +42,14 @@
  * /dubbo-cluster-extensions/dubbo-cluster-loadbalance-peakewma/src/main/java/org/apache
  * /dubbo/rpc/cluster/loadbalance/PeakEwmaLoadBalance.java#L46
  */
+@Join
 public class PeakEWMALoadBalancer extends AbstractLoadBalancer {
 
     private static final double PENALTY = Long.MAX_VALUE >> 16;
 
     private static final double ZERO_COST = 1E-6;
 
-    private static double decayTime = 10000;
+    private static final double DECAY_TIME = 600;
 
     @Override
     protected Upstream doSelect(List<Upstream> upstreamList, String ip) {
@@ -109,7 +111,7 @@ private void observe() {
 
             final long currentTime = System.currentTimeMillis();
             long td = Math.max(currentTime - lastUpdateTime, 0);
-            double w = Math.exp(-td / decayTime);
+            double w = Math.exp( -td / DECAY_TIME);
             if (rtt > cost) {
                 cost = rtt;
             } else {

shenyu-loadbalancer/src/main/resources/META-INF/shenyu/org.apache.shenyu.loadbalancer.spi.LoadBalancer

@@ -18,4 +18,5 @@ roundRobin=org.apache.shenyu.loadbalancer.spi.RoundRobinLoadBalancer
 hash=org.apache.shenyu.loadbalancer.spi.HashLoadBalancer
 leastActive=org.apache.shenyu.loadbalancer.spi.LeastActiveLoadBalance
 p2c=org.apache.shenyu.loadbalancer.spi.P2cLoadBalancer
-shortestResponse=org.apache.shenyu.loadbalancer.spi.ShortestResponseLoadBalancer
+shortestResponse=org.apache.shenyu.loadbalancer.spi.ShortestResponseLoadBalancer
+peakEWMA=org.apache.shenyu.loadbalancer.spi.PeakEWMALoadBalancer