CI、发布与监控：怎样确认这次上线可用

AvailabilityChangeEvent.publish(context, ReadinessState.REFUSING_TRAFFIC);
// 发布应用就绪状态，外部流量入口仍需观察并停止路由。
waitForIngressToObserveState(); // 应用自己的协调逻辑，要有明确截止时间。
drainInFlightOperations(); // 应用自己的收尾逻辑，不能假定事件会取消所有后台工作。
// 正常框架关闭流程和容器宽限期需要另外配置并验证。

import java.util.*;
import java.math.BigInteger;
public class Main {
    record Batch(long time,long total,long errors,boolean complete){}
    static List<String> gates(List<Batch> batches,long width,long minimum,int ppm){
        if(width<=0||minimum<=0||ppm<0||ppm>1000000)throw new IllegalArgumentException("policy");
        Deque<Batch> q=new ArrayDeque<>();List<String> out=new ArrayList<>();long total=0,errors=0,last=-1;int unknown=0;
        for(Batch b:batches){
            if(b.time()<0||b.time()<last||b.total()<0||b.errors()<0||b.errors()>b.total())throw new IllegalArgumentException("batch");last=b.time();
            while(!q.isEmpty()&&q.peekFirst().time()<=b.time()-width){Batch old=q.removeFirst();total-=old.total();errors-=old.errors();if(!old.complete())unknown--;} // 左边界批次已过期。
            q.addLast(b);total=Math.addExact(total,b.total());errors=Math.addExact(errors,b.errors());if(!b.complete())unknown++; // 缺失独立计数，不填零。
            if(unknown>0||total<minimum){out.add("HOLD");continue;}
            BigInteger left=BigInteger.valueOf(errors).multiply(BigInteger.valueOf(1000000));
            BigInteger right=BigInteger.valueOf(total).multiply(BigInteger.valueOf(ppm));
            out.add(left.compareTo(right)>0?"ROLLBACK":"PASS"); // 等于阈值按本题约定通过。
        }return out;
    }
    static void eq(List<String> e,List<String> a){if(!e.equals(a))throw new AssertionError(a);}
    public static void main(String[] args){
        eq(List.of("PASS"),gates(List.of(new Batch(1,100,1,true)),10,100,10000));
        eq(List.of("ROLLBACK"),gates(List.of(new Batch(1,100,2,true)),10,100,10000));
        eq(List.of("HOLD"),gates(List.of(new Batch(1,10,0,true)),10,100,10000));
        eq(List.of("HOLD","PASS"),gates(List.of(new Batch(0,0,0,false),new Batch(10,100,0,true)),10,100,0));
        eq(List.of(),gates(List.of(),1,1,0));
        eq(List.of("PASS"),gates(List.of(new Batch(1,Long.MAX_VALUE,Long.MAX_VALUE,true)),10,1,1000000));
        try{gates(List.of(new Batch(2,1,0,true),new Batch(1,1,0,true)),10,1,0);throw new AssertionError();}catch(IllegalArgumentException expected){}
        System.out.println("PASS 7 tests");
    }
}