client plugin webflux添加接口

Author: saleson

spring-cloud-gray-plugins/spring-cloud-gray-plugin-webflux/src/main/java/cn/springcloud/gray/web/configuration/GrayClientWebAutoConfiguration.java

@@ -4,6 +4,7 @@
 import cn.springcloud.gray.GrayManager;
 import cn.springcloud.gray.client.config.GrayClientAutoConfiguration;
 import cn.springcloud.gray.web.resources.DiscoveryInstanceResource;
+import cn.springcloud.gray.web.resources.GrayListResource;
 import org.springframework.boot.autoconfigure.AutoConfigureAfter;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.context.annotation.Bean;
@@ -15,8 +16,14 @@
 public class GrayClientWebAutoConfiguration {
 
     @Bean
-    public DiscoveryInstanceResource discoveryInstanceResource(){
+    public DiscoveryInstanceResource discoveryInstanceResource() {
         return new DiscoveryInstanceResource();
     }
 
+
+    @Bean
+    public GrayListResource grayListResource() {
+        return new GrayListResource();
+    }
+
 }

spring-cloud-gray-plugins/spring-cloud-gray-plugin-webflux/src/main/java/cn/springcloud/gray/web/resources/GrayListResource.java

@@ -0,0 +1,60 @@
+package cn.springcloud.gray.web.resources;
+
+import cn.springcloud.gray.GrayManager;
+import cn.springcloud.gray.api.ApiRes;
+import cn.springcloud.gray.model.GrayInstance;
+import cn.springcloud.gray.model.GrayTrackDefinition;
+import cn.springcloud.gray.request.track.GrayTrackHolder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+import java.util.Collection;
+import java.util.Map;
+
+/**
+ * @author saleson
+ * @date 2019-11-24 12:12
+ */
+@RestController
+@RequestMapping("/gray/list")
+public class GrayListResource {
+
+
+    @Autowired
+    private GrayTrackHolder grayTrackHolder;
+
+
+    @Autowired
+    private GrayManager grayManager;
+
+    /**
+     * 返回实例中维护的所有灰度服务及实例信息
+     *
+     * @return
+     */
+    @GetMapping("/service/allInfos")
+    public Mono<ApiRes<Map<String, Collection<GrayInstance>>>> getAllGrayServiceInfos() {
+        return Mono.just(
+                ApiRes.<Map<String, Collection<GrayInstance>>>builder()
+                        .code(ApiRes.CODE_SUCCESS)
+                        .data(grayManager.getMapByAllGrayServices())
+                        .build());
+    }
+
+    /**
+     * 返回维护的所有灰度追踪信息
+     *
+     * @return
+     */
+    @GetMapping("/track/allDefinitions")
+    public Mono<ApiRes<Collection<GrayTrackDefinition>>> getAllGrayTracks() {
+        return Mono.just(
+                ApiRes.<Collection<GrayTrackDefinition>>builder()
+                        .code(ApiRes.CODE_SUCCESS)
+                        .data(grayTrackHolder.getTrackDefinitions())
+                        .build());
+    }
+}