chore(flagd): refactoring codebase into multiple classes (#378)

Signed-off-by: Giovanni Liva <[email protected]>
Signed-off-by: Giovanni Liva <[email protected]>

Author: thisthat

pom.xml

@@ -47,7 +47,6 @@
         <junit.jupiter.version>5.10.0</junit.jupiter.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-
     </properties>
 
     <dependencies>

providers/flagd/README.md

@@ -45,6 +45,8 @@ variables.
 | cache                 | FLAGD_CACHE                    | string  | lru       | lru,disabled |
 | maxCacheSize          | FLAGD_MAX_CACHE_SIZE           | int     | 1000      |              |
 | maxEventStreamRetries | FLAGD_MAX_EVENT_STREAM_RETRIES | int     | 5         |              |
+| retryBackoffMs        | FLAGD_RETRY_BACKOFF_MS         | int     | 1000      |              |
+| deadline              | FLAGD_DEADLINE_MS              | int     | 500       |              |
 
 ### OpenTelemetry support
 

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/Config.java

@@ -1,6 +1,9 @@
 package dev.openfeature.contrib.providers.flagd;
 
-final class Config {
+/**
+ * Helper class to hold configuration default values.
+ */
+public final class Config {
     static final String DEFAULT_PORT = "8013";
     static final String DEFAULT_TLS = "false";
     static final String DEFAULT_HOST = "localhost";
@@ -16,17 +19,19 @@ final class Config {
     static final String CACHE_ENV_VAR_NAME = "FLAGD_CACHE";
     static final String MAX_CACHE_SIZE_ENV_VAR_NAME = "FLAGD_MAX_CACHE_SIZE";
     static final String MAX_EVENT_STREAM_RETRIES_ENV_VAR_NAME = "FLAGD_MAX_EVENT_STREAM_RETRIES";
+    static final String BASE_EVENT_STREAM_RETRY_BACKOFF_MS_ENV_VAR_NAME = "FLAGD_RETRY_BACKOFF_MS";
+    static final String DEADLINE_MS_ENV_VAR_NAME = "FLAGD_DEADLINE_MS";
 
-    static final String STATIC_REASON = "STATIC";
-    static final String CACHED_REASON = "CACHED";
+    public static final String STATIC_REASON = "STATIC";
+    public static final String CACHED_REASON = "CACHED";
 
-    static final String FLAG_KEY_FIELD = "flag_key";
-    static final String CONTEXT_FIELD = "context";
-    static final String VARIANT_FIELD = "variant";
-    static final String VALUE_FIELD = "value";
-    static final String REASON_FIELD = "reason";
+    public static final String FLAG_KEY_FIELD = "flag_key";
+    public static final String CONTEXT_FIELD = "context";
+    public static final String VARIANT_FIELD = "variant";
+    public static final String VALUE_FIELD = "value";
+    public static final String REASON_FIELD = "reason";
 
-    static final String LRU_CACHE = "lru";
+    public static final String LRU_CACHE = "lru";
     static final String DEFAULT_CACHE = LRU_CACHE;
 
     static final int DEFAULT_MAX_EVENT_STREAM_RETRIES = 5;

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/EventStreamCallback.java

@@ -4,8 +4,12 @@
 import lombok.Builder;
 import lombok.Getter;
 
+import static dev.openfeature.contrib.providers.flagd.Config.BASE_EVENT_STREAM_RETRY_BACKOFF_MS;
+import static dev.openfeature.contrib.providers.flagd.Config.BASE_EVENT_STREAM_RETRY_BACKOFF_MS_ENV_VAR_NAME;
 import static dev.openfeature.contrib.providers.flagd.Config.CACHE_ENV_VAR_NAME;
+import static dev.openfeature.contrib.providers.flagd.Config.DEADLINE_MS_ENV_VAR_NAME;
 import static dev.openfeature.contrib.providers.flagd.Config.DEFAULT_CACHE;
+import static dev.openfeature.contrib.providers.flagd.Config.DEFAULT_DEADLINE;
 import static dev.openfeature.contrib.providers.flagd.Config.DEFAULT_HOST;
 import static dev.openfeature.contrib.providers.flagd.Config.DEFAULT_MAX_CACHE_SIZE;
 import static dev.openfeature.contrib.providers.flagd.Config.DEFAULT_MAX_EVENT_STREAM_RETRIES;
@@ -78,6 +82,21 @@ public class FlagdOptions {
     private int maxEventStreamRetries =
             fallBackToEnvOrDefault(MAX_EVENT_STREAM_RETRIES_ENV_VAR_NAME, DEFAULT_MAX_EVENT_STREAM_RETRIES);
 
+    /**
+     * Backoff interval in milliseconds.
+     * */
+    @Builder.Default
+    private int retryBackoffMs =
+            fallBackToEnvOrDefault(BASE_EVENT_STREAM_RETRY_BACKOFF_MS_ENV_VAR_NAME, BASE_EVENT_STREAM_RETRY_BACKOFF_MS);
+
+
+    /**
+     * Deadline to connect to flagD in milliseconds.
+     * */
+    @Builder.Default
+    private int deadline =
+            fallBackToEnvOrDefault(DEADLINE_MS_ENV_VAR_NAME, DEFAULT_DEADLINE);
+
     /**
      * Inject OpenTelemetry for the library runtime. Providing sdk will initiate distributed tracing for flagd grpc
      * connectivity.