From 2a6916819b2a80a532f827dc96026b8fdc0b15ed Mon Sep 17 00:00:00 2001 From: Baodi Shi Date: Mon, 22 Jul 2024 19:01:39 +0800 Subject: [PATCH] feat: expose partitions update interval configuration to C client (#437) * feat: expose partitions update interval configuration to C client * code format --- include/pulsar/c/client_configuration.h | 6 ++++++ lib/c/c_ClientConfiguration.cc | 10 ++++++++++ tests/c/c_ClientConfigurationTest.cc | 3 +++ 3 files changed, 19 insertions(+) diff --git a/include/pulsar/c/client_configuration.h b/include/pulsar/c/client_configuration.h index 7ff5dcb7..75c24b32 100644 --- 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 index 96a1bf7b..630cabc6 100644 --- 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 index 3fec51a5..a7dd0226 100644 --- 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); }