feat: expose partitions update interval configuration to C client (#437)

* feat: expose partitions update interval configuration to C client * code format
apache · Jul 22, 2024 · 2a69168 · 2a69168
1 parent 35bf161
commit 2a69168
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 0 deletions.
diff --git a/include/pulsar/c/client_configuration.h b/include/pulsar/c/client_configuration.h
@@ -192,6 +192,12 @@ PULSAR_PUBLIC void pulsar_client_configuration_set_listener_name(pulsar_client_c
 
 PULSAR_PUBLIC const char *pulsar_client_configuration_get_listener_name(pulsar_client_configuration_t *conf);
 
+PULSAR_PUBLIC void pulsar_client_configuration_set_partitions_update_interval(
+    pulsar_client_configuration_t *conf, const unsigned int intervalInSeconds);
+
+PULSAR_PUBLIC const unsigned int pulsar_client_configuration_get_partitions_update_interval(
+    pulsar_client_configuration_t *conf);
+
 /*
  * Get the stats interval set in the client.
  */

diff --git a/lib/c/c_ClientConfiguration.cc b/lib/c/c_ClientConfiguration.cc
@@ -198,3 +198,13 @@ void pulsar_client_configuration_set_listener_name(pulsar_client_configuration_t
 const char *pulsar_client_configuration_get_listener_name(pulsar_client_configuration_t *conf) {
     return conf->conf.getListenerName().c_str();
 }
+
+void pulsar_client_configuration_set_partitions_update_interval(pulsar_client_configuration_t *conf,
+                                                                const unsigned int intervalInSeconds) {
+    conf->conf.setPartititionsUpdateInterval(intervalInSeconds);
+}
+
+const unsigned int pulsar_client_configuration_get_partitions_update_interval(
+    pulsar_client_configuration_t *conf) {
+    return conf->conf.getPartitionsUpdateInterval();
+}
diff --git a/tests/c/c_ClientConfigurationTest.cc b/tests/c/c_ClientConfigurationTest.cc
@@ -31,4 +31,7 @@ TEST(C_ClientConfigurationTest, testCApiConfig) {
 
     pulsar_client_configuration_set_listener_name(conf, "listenerName");
     ASSERT_STREQ(pulsar_client_configuration_get_listener_name(conf), "listenerName");
+
+    pulsar_client_configuration_set_partitions_update_interval(conf, 10);
+    ASSERT_EQ(pulsar_client_configuration_get_partitions_update_interval(conf), 10);
 }