Add flush_interval to the LaunchDarklyConfig, default to the

default flush interval to allow configuring how often events are sent

GitOrigin-RevId: 5e36390bc9fe80da834a7b8baf036591e85536fa

Author: meghans-cash

misk-launchdarkly/api/misk-launchdarkly.api

@@ -3,17 +3,20 @@ public final class misk/feature/launchdarkly/LaunchDarklyConfig : wisp/config/Co
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;Z)V
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;)V
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;I)V
-	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;IILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;ILjava/time/Duration;)V
+	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;ILjava/time/Duration;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public final fun component1 ()Ljava/lang/String;
 	public final fun component2 ()Ljava/lang/String;
 	public final fun component3 ()Z
 	public final fun component4 ()Lmisk/client/HttpClientSSLConfig;
 	public final fun component5 ()I
-	public final fun copy (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;I)Lmisk/feature/launchdarkly/LaunchDarklyConfig;
-	public static synthetic fun copy$default (Lmisk/feature/launchdarkly/LaunchDarklyConfig;Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;IILjava/lang/Object;)Lmisk/feature/launchdarkly/LaunchDarklyConfig;
+	public final fun component6 ()Ljava/time/Duration;
+	public final fun copy (Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;ILjava/time/Duration;)Lmisk/feature/launchdarkly/LaunchDarklyConfig;
+	public static synthetic fun copy$default (Lmisk/feature/launchdarkly/LaunchDarklyConfig;Ljava/lang/String;Ljava/lang/String;ZLmisk/client/HttpClientSSLConfig;ILjava/time/Duration;ILjava/lang/Object;)Lmisk/feature/launchdarkly/LaunchDarklyConfig;
 	public fun equals (Ljava/lang/Object;)Z
 	public final fun getBase_uri ()Ljava/lang/String;
 	public final fun getEvent_capacity ()I
+	public final fun getFlush_interval ()Ljava/time/Duration;
 	public final fun getSdk_key ()Ljava/lang/String;
 	public final fun getSsl ()Lmisk/client/HttpClientSSLConfig;
 	public final fun getUse_relay_proxy ()Z

misk-launchdarkly/src/main/kotlin/misk/feature/launchdarkly/LaunchDarklyFeatureFlagsModule.kt

@@ -6,6 +6,7 @@ import com.launchdarkly.sdk.server.Components
 import com.launchdarkly.sdk.server.LDClient
 import com.launchdarkly.sdk.server.LDConfig
 import com.launchdarkly.sdk.server.integrations.EventProcessorBuilder.DEFAULT_CAPACITY
+import com.launchdarkly.sdk.server.integrations.EventProcessorBuilder.DEFAULT_FLUSH_INTERVAL
 import com.launchdarkly.sdk.server.interfaces.LDClientInterface
 import com.squareup.moshi.Moshi
 import io.micrometer.core.instrument.MeterRegistry
@@ -66,7 +67,11 @@ class LaunchDarklyModule @JvmOverloads constructor(
       // Set wait to 0 to not block here. Block in service initialization instead.
       .startWait(Duration.ofMillis(0))
       .dataSource(Components.streamingDataSource())
-      .events(Components.sendEvents().capacity(config.event_capacity))
+      .events(
+        Components.sendEvents()
+          .capacity(config.event_capacity)
+          .flushInterval(config.flush_interval)
+      )
 
     if (config.use_relay_proxy) {
       ldConfig.serviceEndpoints(
@@ -97,4 +102,5 @@ data class LaunchDarklyConfig @JvmOverloads constructor(
   val use_relay_proxy: Boolean = true,
   val ssl: HttpClientSSLConfig? = null,
   val event_capacity: Int = DEFAULT_CAPACITY,
+  val flush_interval: Duration = DEFAULT_FLUSH_INTERVAL,
 ) : Config

wisp/wisp-launchdarkly/api/wisp-launchdarkly.api

@@ -21,17 +21,20 @@ public final class wisp/launchdarkly/LaunchDarklyConfig : wisp/config/Config {
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;)V
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;Z)V
 	public fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZI)V
-	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZIILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZILjava/time/Duration;)V
+	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZILjava/time/Duration;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public final fun component1 ()Ljava/lang/String;
 	public final fun component2 ()Ljava/lang/String;
 	public final fun component3 ()Lwisp/client/HttpClientSSLConfig;
 	public final fun component4 ()Z
 	public final fun component5 ()I
-	public final fun copy (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZI)Lwisp/launchdarkly/LaunchDarklyConfig;
-	public static synthetic fun copy$default (Lwisp/launchdarkly/LaunchDarklyConfig;Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZIILjava/lang/Object;)Lwisp/launchdarkly/LaunchDarklyConfig;
+	public final fun component6 ()Ljava/time/Duration;
+	public final fun copy (Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZILjava/time/Duration;)Lwisp/launchdarkly/LaunchDarklyConfig;
+	public static synthetic fun copy$default (Lwisp/launchdarkly/LaunchDarklyConfig;Ljava/lang/String;Ljava/lang/String;Lwisp/client/HttpClientSSLConfig;ZILjava/time/Duration;ILjava/lang/Object;)Lwisp/launchdarkly/LaunchDarklyConfig;
 	public fun equals (Ljava/lang/Object;)Z
 	public final fun getBase_uri ()Ljava/lang/String;
 	public final fun getEvent_capacity ()I
+	public final fun getFlush_interval ()Ljava/time/Duration;
 	public final fun getOffline ()Z
 	public final fun getSdk_key ()Ljava/lang/String;
 	public final fun getSsl ()Lwisp/client/HttpClientSSLConfig;

wisp/wisp-launchdarkly/src/main/kotlin/wisp/launchdarkly/LaunchDarklyClient.kt

@@ -33,7 +33,11 @@ object LaunchDarklyClient {
                     .streaming(baseUri)
                     .events(baseUri)
             )
-            .events(Components.sendEvents().capacity(config.event_capacity))
+            .events(
+              Components.sendEvents()
+                .capacity(config.event_capacity)
+                .flushInterval(config.flush_interval)
+            )
 
         config.ssl?.let {
             val trustStore = sslLoader.loadTrustStore(config.ssl.trust_store)!!

wisp/wisp-launchdarkly/src/main/kotlin/wisp/launchdarkly/LaunchDarklyConfig.kt

@@ -1,13 +1,16 @@
 package wisp.launchdarkly
 
 import com.launchdarkly.sdk.server.integrations.EventProcessorBuilder.DEFAULT_CAPACITY
+import com.launchdarkly.sdk.server.integrations.EventProcessorBuilder.DEFAULT_FLUSH_INTERVAL
 import wisp.client.HttpClientSSLConfig
 import wisp.config.Config
+import java.time.Duration
 
 data class LaunchDarklyConfig @JvmOverloads constructor(
     val sdk_key: String,
     val base_uri: String,
     val ssl: HttpClientSSLConfig? = null,
     val offline: Boolean = false,
-    val event_capacity: Int = DEFAULT_CAPACITY
+    val event_capacity: Int = DEFAULT_CAPACITY,
+    val flush_interval: Duration = DEFAULT_FLUSH_INTERVAL
 ) : Config