Simplify error scenario logic (open-telemetry#1657)

* remove fractional config from rule definition Signed-off-by: Michael Beemer <beeme1mr@users.noreply.github.com> * add random failure logic to ad service Signed-off-by: Michael Beemer <beeme1mr@users.noreply.github.com> * add random failure logic to cart service Signed-off-by: Michael Beemer <beeme1mr@users.noreply.github.com> --------- Signed-off-by: Michael Beemer <beeme1mr@users.noreply.github.com>
ahealy-newr · Jul 24, 2024 · 7523233 · 7523233
1 parent ecaf3d9
commit 7523233
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 21 deletions.
diff --git a/src/adservice/src/main/java/oteldemo/AdService.java b/src/adservice/src/main/java/oteldemo/AdService.java
@@ -201,7 +201,8 @@ public void getAds(AdRequest req, StreamObserver<AdResponse> responseObserver) {
             Attributes.of(
                 adRequestTypeKey, adRequestType.name(), adResponseTypeKey, adResponseType.name()));
 
-        if (ffClient.getBooleanValue(ADSERVICE_FAILURE, false, evaluationContext)) {
+        // Throw 1/10 of the time to simulate a failure when the feature flag is enabled
+        if (ffClient.getBooleanValue(ADSERVICE_FAILURE, false, evaluationContext) && random.nextInt(10) == 0) {
           throw new StatusRuntimeException(Status.UNAVAILABLE);
         }
 

diff --git a/src/cartservice/src/services/CartService.cs b/src/cartservice/src/services/CartService.cs
@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 using System.Diagnostics;
 using System.Threading.Tasks;
+using System;
 using Grpc.Core;
 using OpenTelemetry.Trace;
 using cartservice.cartstore;
@@ -13,6 +14,7 @@ namespace cartservice.services;
 public class CartService : Oteldemo.CartService.CartServiceBase
 {
     private static readonly Empty Empty = new();
+    private readonly Random random = new Random();
     private readonly ICartStore _badCartStore;
     private readonly ICartStore _cartStore;
     private readonly IFeatureClient _featureFlagHelper;
@@ -60,7 +62,8 @@ public override async Task<Empty> EmptyCart(EmptyCartRequest request, ServerCall
 
         try
         {
-            if (await _featureFlagHelper.GetBooleanValue("cartServiceFailure", false))
+            // Throw 1/10 of the time to simulate a failure when the feature flag is enabled
+            if (await _featureFlagHelper.GetBooleanValue("cartServiceFailure", false) && random.Next(10) == 0)
             {
                 await _badCartStore.EmptyCartAsync(request.UserId);
             }

diff --git a/src/flagd/demo.flagd.json b/src/flagd/demo.flagd.json
@@ -23,19 +23,19 @@
       "description": "Triggers full manual garbage collections in the ad service",
       "state": "ENABLED",
       "variants": {
-          "on": true,
-          "off": false
-        },
-        "defaultVariant": "off"
+        "on": true,
+        "off": false
+      },
+      "defaultVariant": "off"
     },
     "adServiceHighCpu": {
       "description": "Triggers high cpu load in the ad service",
       "state": "ENABLED",
       "variants": {
-          "on": true,
-          "off": false
-        },
-        "defaultVariant": "off"
+        "on": true,
+        "off": false
+      },
+      "defaultVariant": "off"
     },
     "adServiceFailure": {
       "description": "Fail ad service",
@@ -44,22 +44,16 @@
         "on": true,
         "off": false
       },
-      "defaultVariant": "off",
-      "targeting": {
-        "fractional": [
-          ["on", 10],
-          ["off", 90]
-        ]
-      }
+      "defaultVariant": "off"
     },
     "kafkaQueueProblems": {
       "description": "Overloads Kafka queue while simultaneously introducing a consumer side delay leading to a lag spike",
       "state": "ENABLED",
       "variants": {
-          "on": 100,
-          "off": 0
-        },
-        "defaultVariant": "off"
+        "on": 100,
+        "off": 0
+      },
+      "defaultVariant": "off"
     },
     "cartServiceFailure": {
       "description": "Fail cart service",