C++ Client: provide entry points for C API

cpp-client/deephaven/dhclient/CMakeLists.txt

@@ -44,6 +44,13 @@ set(ALL_FILES
     include/public/deephaven/client/flight.h
     include/public/deephaven/client/update_by.h
 
+    src/interop/client_interop.cc
+    src/interop/client_options_interop.cc
+    src/interop/update_by_interop.cc
+    include/public/deephaven/client/interop/client_interop.h
+    include/public/deephaven/client/interop/client_options_interop.h
+    include/public/deephaven/client/interop/update_by_interop.h
+
     src/subscription/subscribe_thread.cc
 
     include/private/deephaven/client/subscription/subscribe_thread.h

cpp-client/deephaven/dhclient/include/public/deephaven/client/interop/client_options_interop.h

@@ -0,0 +1,57 @@
+/*
+ * Copyright (c) 2016-2024 Deephaven Data Labs and Patent Pending
+ */
+#include <cstdint>
+#include "deephaven/client/client_options.h"
+#include "deephaven/dhcore/interop/interop_util.h"
+
+extern "C" {
+void deephaven_client_ClientOptions_ctor(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_dtor(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self);
+void deephaven_client_ClientOptions_SetDefaultAuthentication(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetBasicAuthentication(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *username, const char *password,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetCustomAuthentication(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *authentication_key, const char *authentication_value,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetSessionType(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *session_type,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetUseTls(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    deephaven::dhcore::interop::InteropBool use_tls,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetTlsRootCerts(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *tls_root_certs,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetClientCertChain(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *client_cert_chain,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_SetClientPrivateKey(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *client_private_key,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_AddIntOption(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *opt, int32_t val,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_AddStringOption(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *opt, const char *val,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_ClientOptions_AddExtraHeader(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::ClientOptions> self,
+    const char *header_name, const char *header_value,
+    deephaven::dhcore::interop::ErrorStatus *status);
+}  // extern "C"

cpp-client/deephaven/dhclient/include/public/deephaven/client/interop/update_by_interop.h

@@ -0,0 +1,195 @@
+/*
+ * Copyright (c) 2016-2024 Deephaven Data Labs and Patent Pending
+ */
+#include <cstdint>
+#include "deephaven/client/client.h"
+#include "deephaven/client/client_options.h"
+#include "deephaven/client/update_by.h"
+#include "deephaven/client/utility/table_maker.h"
+#include "deephaven/dhcore/interop/interop_util.h"
+
+
+extern "C" {
+void deephaven_client_UpdateByOperation_dtor(
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> self);
+void deephaven_client_update_by_cumSum(
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_cumProd(
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_cumMin(
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_cumMax(
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_forwardFill(
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_delta(
+    const char **cols, int32_t num_cols,
+    deephaven::client::update_by::DeltaControl delta_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emaTick(double decay_ticks,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emaTime(const char *timestamp_col,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> decay_time,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emsTick(double decay_ticks,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emsTime(const char *timestamp_col,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> decay_time,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emminTick(double decay_ticks,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emminTime(const char *timestamp_col,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> decay_time,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emmaxTick(double decay_ticks,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emmaxTime(const char *timestamp_col,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> decay_time,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emstdTick(double decay_ticks,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_emstdTime(const char *timestamp_col,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> decay_time,
+    const char **cols, int32_t num_cols,
+    const deephaven::client::update_by::OperationControl *op_control,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingSumTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingSumTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingGroupTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingGroupTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingAvgTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingAvgTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingMinTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingMinTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingMaxTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingMaxTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingProdTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingProdTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingCountTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingCountTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingStdTick(
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingStdTime(const char *timestamp_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingWavgTick(const char *weight_col,
+    const char **cols, int32_t num_cols,
+    int32_t rev_ticks, int32_t fwd_ticks,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+void deephaven_client_update_by_rollingWavgTime(const char *timestamp_col,
+    const char *weight_col,
+    const char **cols, int32_t num_cols,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> rev_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::utility::DurationSpecifier> fwd_time,
+    deephaven::dhcore::interop::NativePtr<deephaven::client::UpdateByOperation> *result,
+    deephaven::dhcore::interop::ErrorStatus *status);
+}  // extern "C"