Merge pull request #73 from bright-room/claude/issue-58-20260309-1809

Close #58: Add WebFlux custom rollout strategy example

Author: kukv

examples/webflux/custom-rollout-strategy/build.gradle.kts

@@ -0,0 +1,9 @@
+plugins {
+    id("example-base")
+    id("spotless-java")
+}
+
+dependencies {
+    implementation(project(":spring:spring-webflux"))
+    implementation(libs.spring.boot.starter.webflux)
+}

examples/webflux/custom-rollout-strategy/src/main/java/net/brightroom/example/customrolloutstrategy/Application.java

@@ -0,0 +1,12 @@
+package net.brightroom.example.customrolloutstrategy;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class Application {
+
+  public static void main(String[] args) {
+    SpringApplication.run(Application.class, args);
+  }
+}

examples/webflux/custom-rollout-strategy/src/main/java/net/brightroom/example/customrolloutstrategy/DemoController.java

@@ -0,0 +1,16 @@
+package net.brightroom.example.customrolloutstrategy;
+
+import net.brightroom.endpointgate.core.annotation.EndpointGate;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+@RestController
+public class DemoController {
+
+  @GetMapping("/api/feature")
+  @EndpointGate("gradual-feature")
+  public Mono<String> feature() {
+    return Mono.just("You are in the rollout group for gradual-feature!");
+  }
+}

examples/webflux/custom-rollout-strategy/src/main/java/net/brightroom/example/customrolloutstrategy/RegionBasedReactiveRolloutStrategy.java

@@ -0,0 +1,26 @@
+package net.brightroom.example.customrolloutstrategy;
+
+import java.util.Map;
+import net.brightroom.endpointgate.core.context.EndpointGateContext;
+import net.brightroom.endpointgate.reactive.core.rollout.ReactiveRolloutStrategy;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+@Profile("region")
+public class RegionBasedReactiveRolloutStrategy implements ReactiveRolloutStrategy {
+
+  private static final Map<String, Integer> REGION_WEIGHT =
+      Map.of(
+          "us-east", 0,
+          "eu-west", 50,
+          "ap-northeast", 80);
+
+  @Override
+  public Mono<Boolean> isInRollout(String gateId, EndpointGateContext context, int percentage) {
+    String region = context.userIdentifier();
+    int weight = REGION_WEIGHT.getOrDefault(region, 100);
+    return Mono.just(weight < percentage);
+  }
+}

examples/webflux/custom-rollout-strategy/src/main/java/net/brightroom/example/customrolloutstrategy/RegionReactiveContextResolver.java

@@ -0,0 +1,25 @@
+package net.brightroom.example.customrolloutstrategy;
+
+import net.brightroom.endpointgate.core.context.EndpointGateContext;
+import net.brightroom.endpointgate.spring.webflux.context.ReactiveEndpointGateContextResolver;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+@Profile("region")
+public class RegionReactiveContextResolver implements ReactiveEndpointGateContextResolver {
+
+  @Override
+  public Mono<EndpointGateContext> resolve(ServerHttpRequest request) {
+    String region = request.getHeaders().getFirst("X-Region");
+    if (region == null) {
+      return Mono.empty();
+    }
+    if (region.isBlank()) {
+      return Mono.empty();
+    }
+    return Mono.just(new EndpointGateContext(region));
+  }
+}

examples/webflux/custom-rollout-strategy/src/main/java/net/brightroom/example/customrolloutstrategy/TimeBasedReactiveRolloutStrategy.java

@@ -0,0 +1,34 @@
+package net.brightroom.example.customrolloutstrategy;
+
+import java.time.LocalTime;
+import java.time.ZoneId;
+import net.brightroom.endpointgate.core.context.EndpointGateContext;
+import net.brightroom.endpointgate.reactive.core.rollout.DefaultReactiveRolloutStrategy;
+import net.brightroom.endpointgate.reactive.core.rollout.ReactiveRolloutStrategy;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+@Profile("time-based")
+public class TimeBasedReactiveRolloutStrategy implements ReactiveRolloutStrategy {
+
+  private static final LocalTime BUSINESS_START = LocalTime.of(9, 0);
+  private static final LocalTime BUSINESS_END = LocalTime.of(17, 0);
+  private static final ZoneId ZONE = ZoneId.of("Asia/Tokyo");
+
+  private final DefaultReactiveRolloutStrategy defaultStrategy =
+      new DefaultReactiveRolloutStrategy();
+
+  @Override
+  public Mono<Boolean> isInRollout(String gateId, EndpointGateContext context, int percentage) {
+    LocalTime now = LocalTime.now(ZONE);
+    if (now.isBefore(BUSINESS_START)) {
+      return Mono.just(false);
+    }
+    if (!now.isBefore(BUSINESS_END)) {
+      return Mono.just(false);
+    }
+    return defaultStrategy.isInRollout(gateId, context, percentage);
+  }
+}

examples/webflux/custom-rollout-strategy/src/main/resources/application-region.yml

@@ -0,0 +1,3 @@
+# リージョンベースのロールアウト戦略を有効化
+# X-Region ヘッダーでリージョンを指定すると、リージョンごとの重みに基づいてロールアウト判定が行われる
+# 例: us-east (weight=0) + rollout=60 → 許可、ap-northeast (weight=80) + rollout=60 → 拒否

examples/webflux/custom-rollout-strategy/src/main/resources/application-time-based.yml

@@ -0,0 +1,2 @@
+# 時間帯ベースのロールアウト戦略を有効化
+# 営業時間内 (09:00-17:00 Asia/Tokyo) のみロールアウトを適用し、時間外はアクセスを拒否する

examples/webflux/custom-rollout-strategy/src/main/resources/application.yml

@@ -0,0 +1,6 @@
+endpoint-gate:
+  default-enabled: true
+  gates:
+    gradual-feature:
+      enabled: true
+      rollout: 60

settings.gradle.kts

@@ -58,5 +58,6 @@ include(
     "examples:webflux:basic-usage",
     "examples:webflux:functional-endpoint",
     "examples:webflux:rollout",
+    "examples:webflux:custom-rollout-strategy",
     "examples:webflux:schedule",
 )