chore(sync): influxdb_pro 2026-05-01

.circleci/config.yml

@@ -271,10 +271,8 @@ jobs:
           command: cargo install cargo-deny --locked
       - run:
           name: cargo-deny Checks
-          # `--warn unsound` downgrades RustSec `informational = "unsound"`
-          # advisories to warnings, they flag API soundness concerns, not
-          # exploitable vulnerabilities, so we don't want them to fail CI.
           command: cargo deny check -s --warn unsound
+
   doc:
     docker:
       - image: quay.io/influxdb/rust:ci

.circleci/packages/influxdb3/fs/usr/share/influxdb3/influxdb3-core.conf

@@ -228,6 +228,10 @@
 # URL of plugin repository (env: INFLUXDB3_PLUGIN_REPO)
 #plugin-repo="<URL>"
 
+# Restrict plugin triggers to the provided trigger type(s). Comma-separated
+# list of: wal, schedule, request (env: INFLUXDB3_RESTRICT_PLUGIN_TRIGGERS_TO)
+#restrict-plugin-triggers-to="<TYPES>"
+
 # =============================================================================
 # Data Lifecycle & Retention
 # =============================================================================

Cargo.toml

@@ -212,7 +212,7 @@ regex = "1.11.1"
 reqwest = { version = "0.12", default-features = false, features = ["rustls-tls", "stream", "json"] }
 rstest = "0.26"
 rustls = { version = "0.23", default-features = false, features = ["logging", "ring", "std", "tls12"] }
-rustls-webpki = { version = "0.103.12", default-features = false, features = ["ring", "std"] }
+rustls-webpki = { version = "0.103.13", default-features = false, features = ["ring", "std"] }
 secrecy = "0.8.0"
 serde = { version = "1.0", features = ["derive"] }
 # serde_json is set to 1.0.127 to prevent a conflict with core, if that gets updated upstream, this

core/README.md

@@ -0,0 +1,21 @@
+# `oss/core`
+
+`oss/core` contains the lower-level shared crates shared across:
+
+- InfluxDB 3 Core
+- InfluxDB 3 Enterprise
+- InfluxDB 3 IOx
+
+These crates provide common building blocks such as query execution, schema and data
+types, HTTP and gRPC utilities, observability helpers, and supporting Arrow and Parquet
+infrastructure.
+
+
+Examples of crates in this directory include:
+
+- query and planner crates such as `iox_query`, `iox_query_influxql`, and `query_functions`
+- shared data model crates such as `data_types`, `schema`, and `mutable_batch`
+- service and protocol crates such as `generated_types`, `service_grpc_flight`, and `iox_http`
+- common runtime and observability crates such as `executor`, `metric`, `trace`, and `trogging`
+
+As a rule of thumb, code belongs in `core` when it is product-agnostic infrastructure.

core/data_types/src/columns.rs

@@ -411,6 +411,25 @@ impl std::fmt::Display for ColumnType {
     }
 }
 
+impl std::str::FromStr for ColumnType {
+    type Err = String;
+
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        match s {
+            "i64" => Ok(Self::I64),
+            "u64" => Ok(Self::U64),
+            "f64" => Ok(Self::F64),
+            "bool" => Ok(Self::Bool),
+            "string" => Ok(Self::String),
+            "time" => Ok(Self::Time),
+            "tag" => Ok(Self::Tag),
+            _ => Err(format!(
+                "invalid column type '{s}': valid types are i64, u64, f64, bool, string, time, tag"
+            )),
+        }
+    }
+}
+
 impl TryFrom<&ArrowDataType> for ColumnType {
     type Error = &'static str;