feat(event-processor): add C binding for context keys cache capacity

libs/common/include/launchdarkly/config/shared/builders/events_builder.hpp

@@ -107,6 +107,20 @@ class EventsBuilder {
      */
     EventsBuilder& PrivateAttribute(AttributeReference attribute);
 
+    /**
+     * @brief Specifies the number of unique context keys that can be remembered
+     * by the index event generation logic before needing to evict keys from
+     * memory in LRU order.
+     *
+     * After reaching capacity, it's possible
+     * that a previously-indexed context may cause generation of a redundant
+     * index event.
+     *
+     * @param capacity Maximum unique context keys to remember.
+     * @return  Reference to this builder.
+     */
+    EventsBuilder& ContextKeysCapacity(std::size_t capacity);
+
     /**
      * Builds Events configuration, if the configuration is valid.
      * @return Events config, or error.

libs/common/include/launchdarkly/config/shared/built/events.hpp

@@ -93,8 +93,8 @@ class Events final {
     [[nodiscard]] std::size_t FlushWorkers() const;
 
     /**
-     * Max number of unique context keys to hold in LRU cache used for context
-     * deduplication when generating index events.
+     * Number of unique contexts to remember when deduplicating index
+     * events.
      * @return Max, or std::nullopt if not applicable.
      */
     [[nodiscard]] std::optional<std::size_t> ContextKeysCacheCapacity() const;

libs/common/src/config/events_builder.cpp

@@ -25,6 +25,13 @@ EventsBuilder<SDK>& EventsBuilder<SDK>::Capacity(std::size_t capacity) {
     return *this;
 }
 
+template <typename SDK>
+EventsBuilder<SDK>& EventsBuilder<SDK>::ContextKeysCapacity(
+    std::size_t capacity) {
+    config_.context_keys_cache_capacity_ = capacity;
+    return *this;
+}
+
 template <typename SDK>
 EventsBuilder<SDK>& EventsBuilder<SDK>::FlushInterval(
     std::chrono::milliseconds interval) {

libs/server-sdk/include/launchdarkly/server_side/bindings/c/config/builder.h

@@ -1,4 +1,4 @@
 /** @file */
 // NOLINTBEGIN modernize-use-using
 
 #pragma once
@@ -107,6 +107,22 @@
 LD_EXPORT(void)
 LDServerConfigBuilder_Events_Enabled(LDServerConfigBuilder b, bool enabled);
 
+/**
+ * Specifies the number of unique context keys that can be remembered
+ * by the index event generation logic before needing to evict keys from
+ * memory in LRU order.
+ *
+ * After reaching capacity, it's possible
+ * that a previously-indexed context may cause generation of a redundant
+ * index event.
+ * @param b Server config builder. Must not be NULL.
+ * @param context_keys_capacity Maximum unique context keys to remember. The default
+ * is 1000.
+ */
+LD_EXPORT(void)
+LDServerConfigBuilder_Events_ContextKeysCapacity(LDServerConfigBuilder b,
+                                                 size_t context_keys_capacity);
+
 /**
  * Sets the capacity of the event processor. When more events are generated
  * within the processor's flush interval than this value, events will be

libs/server-sdk/src/bindings/c/builder.cpp

@@ -140,6 +140,14 @@ LDServerConfigBuilder_Events_Capacity(LDServerConfigBuilder b,
     TO_BUILDER(b)->Events().Capacity(capacity);
 }
 
+LD_EXPORT(void)
+LDServerConfigBuilder_Events_ContextKeysCapacity(LDServerConfigBuilder b,
+                                                 size_t context_keys_capacity) {
+    LD_ASSERT_NOT_NULL(b);
+
+    TO_BUILDER(b)->Events().ContextKeysCapacity(context_keys_capacity);
+}
+
 LD_EXPORT(void)
 LDServerConfigBuilder_Events_FlushIntervalMs(LDServerConfigBuilder b,
                                              unsigned int milliseconds) {
@@ -225,7 +233,7 @@ LD_EXPORT(LDServerDataSourcePollBuilder) LDServerDataSourcePollBuilder_New() {
 
 LD_EXPORT(void)
 LDServerDataSourcePollBuilder_IntervalS(LDServerDataSourcePollBuilder b,
-                                     unsigned int seconds) {
+                                        unsigned int seconds) {
     LD_ASSERT_NOT_NULL(b);
 
     TO_POLL_BUILDER(b)->PollInterval(std::chrono::seconds{seconds});

libs/server-sdk/tests/server_c_bindings_test.cpp

@@ -9,11 +9,12 @@
 #include <boost/json/parse.hpp>
 
 #include <chrono>
+#include <launchdarkly/server_side/config/config.hpp>
 
 TEST(ClientBindings, MinimalInstantiation) {
     LDServerConfigBuilder cfg_builder = LDServerConfigBuilder_New("sdk-123");
 
     LDServerConfig config;
     LDStatus status = LDServerConfigBuilder_Build(cfg_builder, &config);
     ASSERT_TRUE(LDStatus_Ok(status));
 
@@ -37,7 +38,7 @@
     LDServerConfigBuilder cfg_builder = LDServerConfigBuilder_New("sdk-123");
     LDServerConfigBuilder_Offline(cfg_builder, true);
 
     LDServerConfig config;
     LDStatus status = LDServerConfigBuilder_Build(cfg_builder, &config);
     ASSERT_TRUE(LDStatus_Ok(status));
 
@@ -46,14 +47,14 @@
     struct LDServerDataSourceStatusListener listener {};
     LDServerDataSourceStatusListener_Init(&listener);
 
     listener.UserData = const_cast<char*>("Potato");
     listener.StatusChanged = StatusListenerFunction;
 
     LDListenerConnection connection =
         LDServerSDK_DataSourceStatus_OnStatusChange(sdk, listener);
 
     bool success = false;
     LDServerSDK_Start(sdk, 3000, &success);
     EXPECT_TRUE(success);
 
     LDListenerConnection_Disconnect(connection);
@@ -66,7 +67,7 @@
     LDServerConfigBuilder cfg_builder = LDServerConfigBuilder_New("sdk-123");
     LDServerConfigBuilder_Offline(cfg_builder, true);
 
     LDServerConfig config;
     LDStatus status = LDServerConfigBuilder_Build(cfg_builder, &config);
     ASSERT_TRUE(LDStatus_Ok(status));
 
@@ -78,7 +79,7 @@
               LDServerDataSourceStatus_GetState(status_1));
 
     bool success = false;
     LDServerSDK_Start(sdk, 3000, &success);
 
     LDServerDataSourceStatus status_2 =
         LDServerSDK_DataSourceStatus_Status(sdk);
@@ -100,9 +101,9 @@
     DataSourceStatus status(
         DataSourceStatus::DataSourceState::kValid,
         std::chrono::time_point<std::chrono::system_clock>{
             std::chrono::seconds{200}},
         DataSourceStatus::ErrorInfo(
             DataSourceStatus::ErrorInfo::ErrorKind::kErrorResponse, 404,
             "Not found",
             std::chrono::time_point<std::chrono::system_clock>{
                 std::chrono::seconds{100}}));
@@ -186,3 +187,29 @@
     LDServerSDK_Free(sdk);
     LDContext_Free(context);
 }
+
+TEST(ClientBindings, CanSetEventConfigurationSuccessfully) {
+    LDServerConfigBuilder cfg_builder = LDServerConfigBuilder_New("sdk-123");
+
+    LDServerConfigBuilder_Events_Enabled(cfg_builder, false);
+    LDServerConfigBuilder_Events_Capacity(cfg_builder, 100);
+    LDServerConfigBuilder_Events_ContextKeysCapacity(cfg_builder, 100);
+    LDServerConfigBuilder_Events_PrivateAttribute(cfg_builder, "email");
+    LDServerConfigBuilder_Events_AllAttributesPrivate(cfg_builder, true);
+
+    LDServerConfig config;
+    LDStatus status = LDServerConfigBuilder_Build(cfg_builder, &config);
+    ASSERT_TRUE(LDStatus_Ok(status));
+
+    launchdarkly::server_side::Config const* c =
+        reinterpret_cast<launchdarkly::server_side::Config*>(config);
+
+    ASSERT_EQ(c->Events().Capacity(), 100);
+    ASSERT_EQ(c->Events().ContextKeysCacheCapacity(), 100);
+    ASSERT_EQ(c->Events().PrivateAttributes(),
+              launchdarkly::AttributeReference::SetType{"email"});
+    ASSERT_TRUE(c->Events().AllAttributesPrivate());
+    ASSERT_FALSE(c->Events().Enabled());
+
+    LDServerConfig_Free(config);
+}