all done including tests, just need more tests

Author: AhmedAbdelRaheem1

fallback/etc/fallback.urm.puml

@@ -1,57 +1,112 @@
 @startuml
 package com.iluwatar {
   class App {
-    - MAX_ATTEMPTS : int {static}
-    - RETRY_DELAY : int {static}
     - TIMEOUT : int {static}
     - circuitBreaker : CircuitBreaker
     - executor : ExecutorService
     - fallbackService : Service
     - primaryService : Service
+    - LOGGER : Logger {static}
     + App()
     + App(primaryService : Service, fallbackService : Service)
     + executeWithFallback() : String
     - getFallbackData() : String
     + main(args : String[]) {static}
     + shutdown()
   }
+
+  interface Service {
+    + getData() : String {abstract}
+  }
+
   interface CircuitBreaker {
     + isOpen() : boolean {abstract}
     + recordFailure() {abstract}
     + recordSuccess() {abstract}
     + reset() {abstract}
   }
+
   class DefaultCircuitBreaker {
     - RESET_TIMEOUT : long {static}
     - failureCount : int
     - failureThreshold : int
     - lastFailureTime : long
+    - state : State
     + DefaultCircuitBreaker(failureThreshold : int)
     + isOpen() : boolean
     + recordFailure()
     + recordSuccess()
     + reset()
+    - enum State
+  }
+
+  class FallbackService {
+    - MAX_RETRIES : int {static}
+    - RETRY_DELAY_MS : int {static}
+    - TIMEOUT_MS : int {static}
+    - MAX_REQUESTS_PER_MINUTE : int {static}
+    - LOGGER : Logger {static}
+    - primaryService : Service
+    - fallbackService : Service
+    - circuitBreaker : CircuitBreaker
+    - executor : ExecutorService
+    - healthChecker : ScheduledExecutorService
+    - monitor : ServiceMonitor
+    - rateLimiter : RateLimiter
+    - closed : boolean
+    + FallbackService(primaryService : Service, fallbackService : Service, circuitBreaker : CircuitBreaker)
+    + getData() : String
+    - executeWithTimeout(task : Callable<String>) : String
+    - executeFallback() : String
+    - updateFallbackCache(result : String)
+    - startHealthChecker()
+    + close()
   }
+
   class LocalCacheService {
-    - cache : ConcurrentHashMap<String, String>
+    - cache : Cache
     + LocalCacheService()
     + getData() : String
     + updateCache(key : String, value : String)
+    - class Cache
+    - class CacheEntry
   }
+
   class RemoteService {
     - HTTP_OK : int {static}
     - client : HttpClient
     - serviceUrl : String
     + RemoteService(serviceUrl : String)
     + getData() : String
   }
-  interface Service {
-    + getData() : String {abstract}
+
+  class ServiceMonitor {
+    - metrics : Queue<ServiceMetric>
+    + recordSuccess(responseTime : Duration)
+    + recordError()
+    + recordFallback()
+    + getMetrics() : List<ServiceMetric>
+    - class ServiceMetric
+    - enum MetricType
+  }
+
+  class ServiceException {
+    + ServiceException(message : String)
   }
+
+  ' Relationships
+  App -->  "-circuitBreaker" CircuitBreaker
+  App -->  "-primaryService" Service
+  App -->  "-fallbackService" Service
+  DefaultCircuitBreaker ..|> CircuitBreaker 
+  LocalCacheService ..|> Service 
+  RemoteService ..|> Service 
+  FallbackService ..|> Service
+  FallbackService ..|> AutoCloseable
+  FallbackService --> "-primaryService" Service
+  FallbackService --> "-fallbackService" Service
+  FallbackService --> "-circuitBreaker" CircuitBreaker
+  FallbackService --> "-monitor" ServiceMonitor
+  ServiceException --|> Exception
 }
-App -->  "-circuitBreaker" CircuitBreaker
-App -->  "-primaryService" Service
-DefaultCircuitBreaker ..|> CircuitBreaker 
-LocalCacheService ..|> Service 
-RemoteService ..|> Service 
 @enduml

fallback/pom.xml

@@ -67,5 +67,6 @@
                 <version>4.5.1</version>
                 <scope>test</scope>
             </dependency>
+        
         </dependencies>
 </project>