add groups endpoint (#396)

Author: Ferdudas97

CHANGELOG.md

@@ -3,6 +3,11 @@
 Lists all changes with user impact.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/).
 
+## [0.19.36]
+
+### Changed
+- Added debug endpoint, which returns current groups
+
 ## [0.19.35]
 
 ### Changed

envoy-control-runner/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/debug/SnapshotDebugController.kt

@@ -34,6 +34,7 @@ import org.springframework.web.bind.annotation.RequestBody
 import org.springframework.web.bind.annotation.RequestParam
 import org.springframework.web.bind.annotation.ResponseBody
 import org.springframework.web.bind.annotation.RestController
+import pl.allegro.tech.servicemesh.envoycontrol.groups.Group
 import io.envoyproxy.envoy.config.core.v3.Node as NodeV3
 import io.envoyproxy.envoy.extensions.filters.http.rbac.v3.RBAC as RBACFilter
 
@@ -57,6 +58,15 @@ class SnapshotDebugController(val debugService: SnapshotDebugService) {
         )
     }
 
+    @GetMapping("/groups")
+    fun globalSnapshot(@RequestParam(required = false) discoveryServiceName: String?)
+        : ResponseEntity<Collection<Group>> {
+        return ResponseEntity(
+            debugService.groups(discoveryServiceName),
+            HttpStatus.OK
+        )
+    }
+
     @GetMapping("/snapshot-global")
     fun globalSnapshot(@RequestParam(defaultValue = "false") xds: Boolean): ResponseEntity<SnapshotDebugInfo> {
         return ResponseEntity(

envoy-control-runner/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/debug/SnapshotDebugService.kt

@@ -30,6 +30,14 @@ class SnapshotDebugService(
         }
     }
 
+    fun groups(discoveryServiceName: String?): Collection<Group> {
+        return if (discoveryServiceName != null) {
+            cache.groups().filter { it.discoveryServiceName == discoveryServiceName }
+        } else {
+            cache.groups()
+        }
+    }
+
     fun globalSnapshot(xds: Boolean): SnapshotDebugInfo {
         val globalSnapshot = snapshotUpdater.getGlobalSnapshot()
         if (xds) {