Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat(cppclient): provide entry points for C API #5695

Merged
merged 1 commit into from
Jun 27, 2024
Merged

feat(cppclient): provide entry points for C API #5695

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions cpp-client/deephaven/dhclient/CMakeLists.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
678 changes: 678 additions & 0 deletions cpp-client/deephaven/dhclient/include/public/deephaven/client/interop/client_interop.h
View file
Open in desktop

Large diffs are not rendered by default.

57 changes: 57 additions & 0 deletions ...lient/deephaven/dhclient/include/public/deephaven/client/interop/client_options_interop.h
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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"
195 changes: 195 additions & 0 deletions cpp-client/deephaven/dhclient/include/public/deephaven/client/interop/update_by_interop.h
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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"
Loading
Loading