Added C, C++ and Rust 'from_conf' examples and wired up manifest

Author: amunra

CMakeLists.txt

@@ -108,6 +108,9 @@ if (QUESTDB_TESTS_AND_EXAMPLES)
         line_sender_c_example_http
         examples/concat.c
         examples/line_sender_c_example_http.c)
+    compile_example(
+        line_sender_c_example_from_conf
+        examples/line_sender_c_example_from_conf.c)
     compile_example(
         line_sender_c_example_from_env
         examples/line_sender_c_example_from_env.c)
@@ -126,6 +129,9 @@ if (QUESTDB_TESTS_AND_EXAMPLES)
     compile_example(
         line_sender_cpp_example_http
         examples/line_sender_cpp_example_http.cpp)
+    compile_example(
+        line_sender_cpp_example_from_conf
+        examples/line_sender_cpp_example_from_conf.cpp)
     compile_example(
         line_sender_cpp_example_from_env
         examples/line_sender_cpp_example_from_env.cpp)

examples.manifest.yaml

@@ -102,3 +102,24 @@
   addr:
     host: localhost
     port: 9009
+
+ - name: ilp-from-conf
+   lang: c
+   path: examples/line_sender_c_example_from_conf.c
+   header: |-
+     [C client library docs](https://github.com/questdb/c-questdb-client/blob/main/doc/C.md)
+   conf: tcp::addr=localhost:9009;
+
+ - name: ilp-from-conf
+   lang: cpp
+   path: examples/line_sender_cpp_example_from_conf.cpp
+   header: |-
+     [C client library docs](https://github.com/questdb/c-questdb-client/blob/main/doc/CPP.md)
+   conf: tcp::addr=localhost:9009;
+
+  - name: ilp-from-conf
+    lang: rust
+    path: questdb-rs/examples/from_conf.rs
+    header: |-
+      [Rust client library docs](https://docs.rs/crate/questdb-rs/latest)
+    conf: tcp::addr=localhost:9009;

examples/line_sender_c_example_from_conf.c

@@ -0,0 +1,83 @@
+#include <questdb/ingress/line_sender.h>
+#include <stdio.h>
+#include <stdbool.h>
+#include <string.h>
+
+int main(int argc, const char* argv[])
+{
+    line_sender_error* err = NULL;
+    line_sender_buffer* buffer = NULL;
+
+    line_sender_utf8 conf = QDB_UTF8_LITERAL(
+        "tcp::addr=localhost:9009;");
+    line_sender* sender = line_sender_from_conf(conf, &err);
+    if (!sender)
+        goto on_error;    
+
+    buffer = line_sender_buffer_new();
+    line_sender_buffer_reserve(buffer, 64 * 1024);  // 64KB buffer initial size.
+
+    // We prepare all our table names and column names in advance.
+    // If we're inserting multiple rows, this allows us to avoid
+    // re-validating the same strings over and over again.
+    line_sender_table_name table_name = QDB_TABLE_NAME_LITERAL("c_cars_from_conf");
+    line_sender_column_name id_name = QDB_COLUMN_NAME_LITERAL("id");
+    line_sender_column_name x_name = QDB_COLUMN_NAME_LITERAL("x");
+    line_sender_column_name y_name = QDB_COLUMN_NAME_LITERAL("y");
+    line_sender_column_name booked_name = QDB_COLUMN_NAME_LITERAL("booked");
+    line_sender_column_name passengers_name = QDB_COLUMN_NAME_LITERAL(
+        "passengers");
+    line_sender_column_name driver_name = QDB_COLUMN_NAME_LITERAL("driver");
+
+    if (!line_sender_buffer_table(buffer, table_name, &err))
+        goto on_error;
+
+    line_sender_utf8 id_value = QDB_UTF8_LITERAL(
+        "d6e5fe92-d19f-482a-a97a-c105f547f721");
+    if (!line_sender_buffer_symbol(buffer, id_name, id_value, &err))
+        goto on_error;
+
+    if (!line_sender_buffer_column_f64(buffer, x_name, 30.5, &err))
+        goto on_error;
+
+    if (!line_sender_buffer_column_f64(buffer, y_name, -150.25, &err))
+        goto on_error;
+
+    if (!line_sender_buffer_column_bool(buffer, booked_name, true, &err))
+        goto on_error;
+
+    if (!line_sender_buffer_column_i64(buffer, passengers_name, 3, &err))
+        goto on_error;
+
+    line_sender_utf8 driver_value = QDB_UTF8_LITERAL("John Doe");
+    if (!line_sender_buffer_column_str(buffer, driver_name, driver_value, &err))
+        goto on_error;
+
+    // 1997-07-04 04:56:55 UTC
+    int64_t designated_timestamp = 867992215000000000;
+    if (!line_sender_buffer_at_nanos(buffer, designated_timestamp, &err))
+        goto on_error;
+
+    //// If you want to get the current system timestamp as nanos, call:
+    // if (!line_sender_buffer_at_nanos(buffer, line_sender_now_nanos(), &err))
+    //     goto on_error;
+
+    // To insert more records, call `line_sender_buffer_table(..)...` again.
+    // It's recommended to keep a timer and/or maximum buffer size to flush
+    // the buffer periodically with any accumulated records.
+    if (!line_sender_flush(sender, buffer, &err))
+        goto on_error;
+
+    line_sender_close(sender);
+
+    return 0;
+
+on_error: ;
+    size_t err_len = 0;
+    const char* err_msg = line_sender_error_msg(err, &err_len);
+    fprintf(stderr, "Error running example: %.*s\n", (int)err_len, err_msg);
+    line_sender_error_free(err);
+    line_sender_buffer_free(buffer);
+    line_sender_close(sender);
+    return 1;
+}

examples/line_sender_cpp_example_from_conf.cpp

@@ -0,0 +1,54 @@
+#include <questdb/ingress/line_sender.hpp>
+#include <iostream>
+
+using namespace std::literals::string_view_literals;
+using namespace questdb::ingress::literals;
+
+int main(int argc, const char* argv[])
+{
+    try
+    {
+        auto sender = questdb::ingress::line_sender::from_conf(
+            "tcp::addr=localhost:9009;");
+
+        // We prepare all our table names and column names in advance.
+        // If we're inserting multiple rows, this allows us to avoid
+        // re-validating the same strings over and over again.
+        const auto table_name = "cpp_cars_from_conf"_tn;
+        const auto id_name = "id"_cn;
+        const auto x_name = "x"_cn;
+        const auto y_name = "y"_cn;
+        const auto booked_name = "booked"_cn;
+        const auto passengers_name = "passengers"_cn;
+        const auto driver_name = "driver"_cn;
+
+        questdb::ingress::line_sender_buffer buffer;
+        buffer
+            .table(table_name)
+            .symbol(id_name, "d6e5fe92-d19f-482a-a97a-c105f547f721"_utf8)
+            .column(x_name, 30.5)
+            .column(y_name, -150.25)
+            .column(booked_name, true)
+            .column(passengers_name, int64_t{3})
+            .column(driver_name, "John Doe"_utf8)
+            .at(questdb::ingress::timestamp_nanos::now());
+
+        // To insert more records, call `buffer.table(..)...` again.
+
+        sender.flush(buffer);
+
+        // It's recommended to keep a timer and/or maximum buffer size to flush
+        // the buffer periodically with any accumulated records.
+
+        return 0;
+    }
+    catch (const questdb::ingress::line_sender_error& err)
+    {
+        std::cerr
+            << "Error running example: "
+            << err.what()
+            << std::endl;
+
+        return 1;
+    }
+}

questdb-rs/examples/from_conf.rs

@@ -0,0 +1,17 @@
+use questdb::{
+    ingress::{Buffer, Sender, TimestampNanos},
+    Result,
+};
+
+fn main() -> Result<()> {
+    let mut sender = Sender::from_conf("tcp::addr=localhost:9009;")?;
+    let mut buffer = Buffer::new();
+    buffer
+        .table("sensors")?
+        .symbol("id", "toronto1")?
+        .column_f64("temperature", 20.0)?
+        .column_i64("humidity", 50)?
+        .at(TimestampNanos::now())?;
+    sender.flush(&mut buffer)?;
+    Ok(())
+}