Merge pull request #1 from shaileshpadave/forResiliency4j

Added few endpoints for checking diff patterns from resiliency4j

src/main/java/org/conductoross/grpcbin/HelloWorldServiceImpl.java

@@ -1,9 +1,18 @@
 package org.conductoross.grpcbin;
 
 import complex.Complex;
+import io.grpc.Status;
+import io.grpc.StatusRuntimeException;
 import io.grpc.stub.StreamObserver;
 
+import java.util.Random;
+import java.util.concurrent.Semaphore;
+import java.util.concurrent.TimeUnit;
+
 public class HelloWorldServiceImpl extends HelloWorldServiceGrpc.HelloWorldServiceImplBase {
+    private static final Random random = new Random();
+    private static final Semaphore semaphore = new Semaphore(5);// Limit to 5 concurrent requests
+
     @Override
     public void sayHello(HelloRequest request, StreamObserver<HelloResponse> responseObserver) {
         HelloResponse response = HelloResponse.newBuilder()
@@ -16,8 +25,154 @@ public void sayHello(HelloRequest request, StreamObserver<HelloResponse> respons
     @Override
     public void complexRequest(Complex.ComplexMessage request, StreamObserver<Complex.ComplexMessage> responseObserver) {
         var response = Complex.ComplexMessage.newBuilder(request)
-                        .setName("response_value")
-                                .build();
+                .setName("response_value")
+                .build();
+        responseObserver.onNext(response);
+        responseObserver.onCompleted();
+    }
+
+    @Override
+    public void sayHelloWithDelay(HelloRequest request, StreamObserver<HelloResponse> responseObserver) {
+        try {
+            // Generate a random number between 0 and 100
+            int delayChance = random.nextInt(100) + 1;
+
+            // Determine the delay based on the random number
+            long delayInSeconds;
+            if (delayChance <= 85) {
+                delayInSeconds = 5;  // 85% chance for ~5 seconds delay
+            } else if (delayChance <= 95) {
+                delayInSeconds = 10; // 10% chance for ~10 seconds delay
+            } else if (delayChance <= 99) {
+                delayInSeconds = 15; // 4% chance for ~15 seconds delay
+            } else {
+                delayInSeconds = 20; // 1% chance for ~20 seconds delay
+            }
+
+            System.out.println("Delaying for " + delayInSeconds + " seconds...");
+            TimeUnit.SECONDS.sleep(delayInSeconds);
+
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+
+        String message = "Hello, " + request.getName();
+        HelloResponse response = HelloResponse.newBuilder()
+                .setMessage(message)
+                .build();
+        responseObserver.onNext(response);
+        responseObserver.onCompleted();
+    }
+
+    @Override
+    public void sayHelloIntermittentFailures(HelloRequest request, StreamObserver<HelloResponse> responseObserver) {
+        // Randomly simulate a failure
+        if (random.nextBoolean()) {
+            responseObserver.onError(new RuntimeException("Simulated failure"));
+            return;
+        }
+
+        String message = "Hello, " + request.getName();
+        HelloResponse response = HelloResponse.newBuilder()
+                .setMessage(message)
+                .build();
+        responseObserver.onNext(response);
+        responseObserver.onCompleted();
+    }
+
+    @Override
+    public void sayHelloServiceDown(org.conductoross.grpcbin.HelloRequest request,
+                                    io.grpc.stub.StreamObserver<org.conductoross.grpcbin.HelloResponse> responseObserver) {
+        responseObserver.onError(new RuntimeException("Service is down"));
+    }
+
+    @Override
+    public void sayHelloOverloaded(org.conductoross.grpcbin.HelloRequest request,
+                                   io.grpc.stub.StreamObserver<org.conductoross.grpcbin.HelloResponse> responseObserver) {
+        try {
+            // Acquire a permit before processing
+            if (!semaphore.tryAcquire()) {
+                responseObserver.onError(new RuntimeException("Service is overloaded"));
+                return;
+            }
+
+            // Simulate some processing (delay) to emulate load
+            int delay = new Random().nextInt(5) + 1;  // Random delay between 1 and 5 seconds
+            TimeUnit.SECONDS.sleep(delay);
+
+            // Simulate some processing time
+            String message = "Hello, " + request.getName();
+            HelloResponse response = HelloResponse.newBuilder()
+                    .setMessage(message)
+                    .build();
+            responseObserver.onNext(response);
+            responseObserver.onCompleted();
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        } finally {
+            // Release the permit after processing
+            semaphore.release();
+        }
+    }
+
+    @Override
+    public void sayHelloWithFailureTypes(org.conductoross.grpcbin.HelloRequest request,
+                                         io.grpc.stub.StreamObserver<org.conductoross.grpcbin.HelloResponse> responseObserver) {
+        Random random = new Random();
+
+        // 10% chance of bad request (400)
+        if (random.nextInt(100) < 10) {
+            responseObserver.onError(new StatusRuntimeException(Status.INVALID_ARGUMENT.withDescription("Bad Request")));
+            return;
+        }
+
+        // 20% chance of service unavailable (503)
+        if (random.nextInt(100) < 20) {
+            responseObserver.onError(new StatusRuntimeException(Status.UNAVAILABLE.withDescription("Service Unavailable")));
+            return;
+        }
+
+        // 5% chance of rate limiting (429)
+        if (random.nextInt(100) < 5) {
+            responseObserver.onError(new StatusRuntimeException(Status.RESOURCE_EXHAUSTED.withDescription("Rate limit exceeded")));
+            return;
+        }
+
+        // Normal response
+        String message = "Hello, " + request.getName();
+        HelloResponse response = HelloResponse.newBuilder()
+                .setMessage(message)
+                .build();
+        responseObserver.onNext(response);
+        responseObserver.onCompleted();
+
+    }
+
+    @Override
+    public void sayHelloWithExternalDependency(org.conductoross.grpcbin.HelloRequest request,
+                                               io.grpc.stub.StreamObserver<org.conductoross.grpcbin.HelloResponse> responseObserver) {
+        // Simulate external system delay (API, DB)
+        int externalDelay = random.nextInt(10) + 1; // 1 to 10 seconds
+        try {
+            System.out.println("Simulating external API delay: " + externalDelay + " seconds");
+            TimeUnit.SECONDS.sleep(externalDelay);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+
+        // Simulate a 10% chance of failure from the external system
+        if (random.nextInt(100) < 10) {
+            responseObserver.onError(new RuntimeException("External API failure"));
+            return;
+        }
+
+        // Generate response based on the external system’s success
+        String message = "Hello, " + request.getName() + ". Data retrieved successfully from external service!";
+
+        // Build the response with dynamic content
+        HelloResponse response = HelloResponse.newBuilder()
+                .setMessage(message)
+                .build();
         responseObserver.onNext(response);
         responseObserver.onCompleted();
     }

src/main/proto/helloworld.proto

@@ -9,6 +9,12 @@ package helloworld;
 
 service HelloWorldService {
   rpc SayHello (HelloRequest) returns (HelloResponse) {}
+  rpc SayHelloWithDelay (HelloRequest) returns (HelloResponse) {}
+  rpc SayHelloIntermittentFailures (HelloRequest) returns (HelloResponse) {}
+  rpc SayHelloServiceDown (HelloRequest) returns (HelloResponse) {}
+  rpc sayHelloWithFailureTypes (HelloRequest) returns (HelloResponse) {}
+  rpc SayHelloOverloaded (HelloRequest) returns (HelloResponse) {}
+  rpc sayHelloWithExternalDependency (HelloRequest) returns (HelloResponse) {}
   rpc ComplexRequest(complex.ComplexMessage) returns (complex.ComplexMessage) {}
   rpc ComplexRequestStream(complex.ComplexMessage) returns (stream complex.ComplexMessage) {}
 }