feat: implement MeshCircuitBreaker policy plugin (#5493)

* feat(*): implement MeshCircuitBreaker policy Signed-off-by: Bart Smykla <bartek@smykla.com>
kumahq · Dec 20, 2022 · 6d42311 · 6d42311
1 parent f29860f
commit 6d42311
Show file tree

Hide file tree

Showing 66 changed files with 7,296 additions and 1,230 deletions.
diff --git a/app/kumactl/cmd/completion/testdata/bash.golden b/app/kumactl/cmd/completion/testdata/bash.golden
@@ -1585,6 +1585,76 @@ _kumactl_get_meshaccesslogs()
     noun_aliases=()
 }
 
+_kumactl_get_meshcircuitbreaker()
+{
+    last_command="kumactl_get_meshcircuitbreaker"
+
+    command_aliases=()
+
+    commands=()
+
+    flags=()
+    two_word_flags=()
+    local_nonpersistent_flags=()
+    flags_with_completion=()
+    flags_completion=()
+
+    flags+=("--mesh=")
+    two_word_flags+=("--mesh")
+    two_word_flags+=("-m")
+    flags+=("--api-timeout=")
+    two_word_flags+=("--api-timeout")
+    flags+=("--config-file=")
+    two_word_flags+=("--config-file")
+    flags+=("--log-level=")
+    two_word_flags+=("--log-level")
+    flags+=("--no-config")
+    flags+=("--output=")
+    two_word_flags+=("--output")
+    two_word_flags+=("-o")
+
+    must_have_one_flag=()
+    must_have_one_noun=()
+    noun_aliases=()
+}
+
+_kumactl_get_meshcircuitbreakers()
+{
+    last_command="kumactl_get_meshcircuitbreakers"
+
+    command_aliases=()
+
+    commands=()
+
+    flags=()
+    two_word_flags=()
+    local_nonpersistent_flags=()
+    flags_with_completion=()
+    flags_completion=()
+
+    flags+=("--mesh=")
+    two_word_flags+=("--mesh")
+    two_word_flags+=("-m")
+    flags+=("--offset=")
+    two_word_flags+=("--offset")
+    flags+=("--size=")
+    two_word_flags+=("--size")
+    flags+=("--api-timeout=")
+    two_word_flags+=("--api-timeout")
+    flags+=("--config-file=")
+    two_word_flags+=("--config-file")
+    flags+=("--log-level=")
+    two_word_flags+=("--log-level")
+    flags+=("--no-config")
+    flags+=("--output=")
+    two_word_flags+=("--output")
+    two_word_flags+=("-o")
+
+    must_have_one_flag=()
+    must_have_one_noun=()
+    noun_aliases=()
+}
+
 _kumactl_get_meshes()
 {
     last_command="kumactl_get_meshes"
@@ -2974,6 +3044,8 @@ _kumactl_get()
     commands+=("mesh")
     commands+=("meshaccesslog")
     commands+=("meshaccesslogs")
+    commands+=("meshcircuitbreaker")
+    commands+=("meshcircuitbreakers")
     commands+=("meshes")
     commands+=("meshgateway")
     commands+=("meshgatewayroute")
@@ -3256,6 +3328,36 @@ _kumactl_inspect_meshaccesslog()
     noun_aliases=()
 }
 
+_kumactl_inspect_meshcircuitbreaker()
+{
+    last_command="kumactl_inspect_meshcircuitbreaker"
+
+    command_aliases=()
+
+    commands=()
+
+    flags=()
+    two_word_flags=()
+    local_nonpersistent_flags=()
+    flags_with_completion=()
+    flags_completion=()
+
+    flags+=("--api-timeout=")
+    two_word_flags+=("--api-timeout")
+    flags+=("--config-file=")
+    two_word_flags+=("--config-file")
+    flags+=("--log-level=")
+    two_word_flags+=("--log-level")
+    flags+=("--no-config")
+    flags+=("--output=")
+    two_word_flags+=("--output")
+    two_word_flags+=("-o")
+
+    must_have_one_flag=()
+    must_have_one_noun=()
+    noun_aliases=()
+}
+
 _kumactl_inspect_meshes()
 {
     last_command="kumactl_inspect_meshes"
@@ -3876,6 +3978,7 @@ _kumactl_inspect()
     commands+=("fault-injection")
     commands+=("healthcheck")
     commands+=("meshaccesslog")
+    commands+=("meshcircuitbreaker")
     commands+=("meshes")
     commands+=("meshgateway")
     commands+=("meshratelimit")

diff --git a/app/kumactl/cmd/install/testdata/install-control-plane.cni-enabled.golden.yaml b/app/kumactl/cmd/install/testdata/install-control-plane.cni-enabled.golden.yaml
@@ -207,6 +207,7 @@ rules:
       - meshgatewayroutes
       - meshgatewayinstances
       - meshaccesslogs
+      - meshcircuitbreakers
       - meshratelimits
       - meshtimeouts
       - meshtraces
@@ -503,7 +504,7 @@ spec:
     metadata:
       annotations:
         checksum/config: fd9d1d8386f97f2bd49e50f476520816168a1c9f60bbc43dec1347a64d239155
-        checksum/tls-secrets: dc0b7b56b099dd8de36ea187e11bf18eeed173fb3e0a9fc200e46fd074c0b7c9
+        checksum/tls-secrets: 55f9d265ab0ff82030b42333df4bd4b1673414f93d4d25df744fd13a35abc5dd
       labels: 
         app: kuma-control-plane
         app.kubernetes.io/name: kuma
@@ -666,6 +667,7 @@ webhooks:
         resources:
           - meshes
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces
@@ -704,6 +706,7 @@ webhooks:
           - traffictraces
           - virtualoutbounds
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces
@@ -824,6 +827,7 @@ webhooks:
           - zones
           - containerpatches
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces

diff --git a/app/kumactl/cmd/install/testdata/install-control-plane.cni-experimental-enabled.golden.yaml b/app/kumactl/cmd/install/testdata/install-control-plane.cni-experimental-enabled.golden.yaml
@@ -207,6 +207,7 @@ rules:
       - meshgatewayroutes
       - meshgatewayinstances
       - meshaccesslogs
+      - meshcircuitbreakers
       - meshratelimits
       - meshtimeouts
       - meshtraces
@@ -521,7 +522,7 @@ spec:
     metadata:
       annotations:
         checksum/config: fd9d1d8386f97f2bd49e50f476520816168a1c9f60bbc43dec1347a64d239155
-        checksum/tls-secrets: dc0b7b56b099dd8de36ea187e11bf18eeed173fb3e0a9fc200e46fd074c0b7c9
+        checksum/tls-secrets: 55f9d265ab0ff82030b42333df4bd4b1673414f93d4d25df744fd13a35abc5dd
       labels: 
         app: kuma-control-plane
         app.kubernetes.io/name: kuma
@@ -688,6 +689,7 @@ webhooks:
         resources:
           - meshes
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces
@@ -726,6 +728,7 @@ webhooks:
           - traffictraces
           - virtualoutbounds
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces
@@ -846,6 +849,7 @@ webhooks:
           - zones
           - containerpatches
           - meshaccesslogs
+          - meshcircuitbreakers
           - meshratelimits
           - meshtimeouts
           - meshtraces