Merge pull request #7839 from influxdata/dom/cleanup-deps
build: remove unused dependencies from loads of cratespull/24376/head
kodiakhq[bot]
GitHub
commit
43078576b8
|
|
@ -383,7 +383,6 @@ version = "0.1.0"
|
|||
dependencies = [
|
||||
"ahash 0.8.3",
|
||||
"arrow",
|
||||
"arrow-flight",
|
||||
"chrono",
|
||||
"comfy-table",
|
||||
"datafusion",
|
||||
|
|
@ -898,21 +897,16 @@ name = "clap_blocks"
|
|||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"clap 4.3.0",
|
||||
"data_types",
|
||||
"futures",
|
||||
"http",
|
||||
"humantime",
|
||||
"iox_catalog",
|
||||
"iox_time",
|
||||
"metric",
|
||||
"object_store",
|
||||
"observability_deps",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"snafu",
|
||||
"tempfile",
|
||||
"test_helpers",
|
||||
"trace",
|
||||
"trace_exporters",
|
||||
"trogging",
|
||||
"uuid 1.3.3",
|
||||
|
|
@ -1409,12 +1403,9 @@ dependencies = [
|
|||
"observability_deps",
|
||||
"once_cell",
|
||||
"ordered-float 3.7.0",
|
||||
"percent-encoding",
|
||||
"proptest",
|
||||
"schema",
|
||||
"serde",
|
||||
"sqlx",
|
||||
"test_helpers",
|
||||
"thiserror",
|
||||
"uuid 1.3.3",
|
||||
"workspace-hack",
|
||||
|
|
@ -1845,14 +1836,11 @@ dependencies = [
|
|||
"arrow_util",
|
||||
"bytes",
|
||||
"datafusion",
|
||||
"futures",
|
||||
"iox_query",
|
||||
"observability_deps",
|
||||
"once_cell",
|
||||
"prost",
|
||||
"snafu",
|
||||
"tokio",
|
||||
"tonic",
|
||||
"workspace-hack",
|
||||
]
|
||||
|
||||
|
|
@ -2040,7 +2028,6 @@ dependencies = [
|
|||
name = "generated_types"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"base64 0.21.1",
|
||||
"bytes",
|
||||
"observability_deps",
|
||||
"pbjson",
|
||||
|
|
@ -2049,7 +2036,6 @@ dependencies = [
|
|||
"prost",
|
||||
"prost-build",
|
||||
"serde",
|
||||
"snafu",
|
||||
"tonic",
|
||||
"tonic-build",
|
||||
"workspace-hack",
|
||||
|
|
@ -2142,7 +2128,6 @@ version = "0.1.0"
|
|||
dependencies = [
|
||||
"prost",
|
||||
"prost-build",
|
||||
"prost-types",
|
||||
"tonic",
|
||||
"tonic-build",
|
||||
"workspace-hack",
|
||||
|
|
@ -2447,24 +2432,12 @@ dependencies = [
|
|||
name = "import_export"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"assert_matches",
|
||||
"chrono",
|
||||
"client_util",
|
||||
"data_types",
|
||||
"futures",
|
||||
"futures-util",
|
||||
"influxdb_iox_client",
|
||||
"iox_catalog",
|
||||
"metric",
|
||||
"object_store",
|
||||
"observability_deps",
|
||||
"parking_lot 0.12.1",
|
||||
"schema",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"tokio-stream",
|
||||
"tokio-util",
|
||||
"workspace-hack",
|
||||
]
|
||||
|
|
@ -2759,7 +2732,6 @@ dependencies = [
|
|||
"datafusion-proto",
|
||||
"pbjson",
|
||||
"pbjson-build",
|
||||
"pbjson-types",
|
||||
"predicate",
|
||||
"prost",
|
||||
"prost-build",
|
||||
|
|
@ -2800,7 +2772,6 @@ dependencies = [
|
|||
"tokio",
|
||||
"tokio-util",
|
||||
"tonic",
|
||||
"wal",
|
||||
"workspace-hack",
|
||||
]
|
||||
|
||||
|
|
@ -2877,7 +2848,6 @@ dependencies = [
|
|||
"sqlx",
|
||||
"sqlx-hotswap-pool",
|
||||
"tempfile",
|
||||
"test_helpers",
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"uuid 1.3.3",
|
||||
|
|
@ -2958,7 +2928,6 @@ dependencies = [
|
|||
"assert_matches",
|
||||
"chrono",
|
||||
"chrono-tz",
|
||||
"data_types",
|
||||
"datafusion",
|
||||
"datafusion_util",
|
||||
"generated_types",
|
||||
|
|
@ -2967,11 +2936,9 @@ dependencies = [
|
|||
"iox_query",
|
||||
"itertools",
|
||||
"observability_deps",
|
||||
"once_cell",
|
||||
"query_functions",
|
||||
"regex",
|
||||
"schema",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"test_helpers",
|
||||
"thiserror",
|
||||
|
|
@ -3005,11 +2972,9 @@ name = "iox_tests"
|
|||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"arrow",
|
||||
"bytes",
|
||||
"data_types",
|
||||
"datafusion",
|
||||
"datafusion_util",
|
||||
"futures",
|
||||
"iox_catalog",
|
||||
"iox_query",
|
||||
"iox_time",
|
||||
|
|
@ -3018,7 +2983,6 @@ dependencies = [
|
|||
"object_store",
|
||||
"observability_deps",
|
||||
"parquet_file",
|
||||
"predicate",
|
||||
"schema",
|
||||
"uuid 1.3.3",
|
||||
"workspace-hack",
|
||||
|
|
@ -3107,7 +3071,6 @@ dependencies = [
|
|||
"hyper",
|
||||
"ioxd_common",
|
||||
"metric",
|
||||
"observability_deps",
|
||||
"snafu",
|
||||
"tokio",
|
||||
"tokio-util",
|
||||
|
|
@ -3184,7 +3147,6 @@ dependencies = [
|
|||
"mutable_batch",
|
||||
"object_store",
|
||||
"router",
|
||||
"sharder",
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"tokio-util",
|
||||
|
|
@ -3900,7 +3862,6 @@ version = "0.1.0"
|
|||
dependencies = [
|
||||
"async-trait",
|
||||
"bytes",
|
||||
"dotenvy",
|
||||
"futures",
|
||||
"iox_time",
|
||||
"metric",
|
||||
|
|
@ -4080,10 +4041,8 @@ dependencies = [
|
|||
"iox_time",
|
||||
"object_store",
|
||||
"observability_deps",
|
||||
"parking_lot 0.12.1",
|
||||
"parquet",
|
||||
"pbjson-types",
|
||||
"predicate",
|
||||
"prost",
|
||||
"schema",
|
||||
"snafu",
|
||||
|
|
@ -4103,7 +4062,6 @@ dependencies = [
|
|||
"datafusion_util",
|
||||
"futures",
|
||||
"influxdb-line-protocol",
|
||||
"mutable_batch",
|
||||
"mutable_batch_lp",
|
||||
"num_cpus",
|
||||
"object_store",
|
||||
|
|
@ -4601,7 +4559,6 @@ dependencies = [
|
|||
"datafusion",
|
||||
"datafusion_util",
|
||||
"itertools",
|
||||
"observability_deps",
|
||||
"once_cell",
|
||||
"regex",
|
||||
"regex-syntax 0.7.2",
|
||||
|
|
@ -4915,7 +4872,6 @@ dependencies = [
|
|||
"rand 0.8.5",
|
||||
"schema",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"serde_urlencoded",
|
||||
"service_grpc_catalog",
|
||||
"service_grpc_namespace",
|
||||
|
|
@ -5191,7 +5147,6 @@ version = "0.1.0"
|
|||
dependencies = [
|
||||
"arrow",
|
||||
"arrow-flight",
|
||||
"arrow_util",
|
||||
"assert_matches",
|
||||
"async-trait",
|
||||
"authz",
|
||||
|
|
@ -5222,7 +5177,6 @@ name = "service_grpc_influxrpc"
|
|||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"arrow",
|
||||
"async-trait",
|
||||
"data_types",
|
||||
"datafusion",
|
||||
"datafusion_util",
|
||||
|
|
@ -5243,7 +5197,6 @@ dependencies = [
|
|||
"schema",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"serde_urlencoded",
|
||||
"service_common",
|
||||
"service_grpc_testing",
|
||||
"snafu",
|
||||
|
|
@ -5265,7 +5218,6 @@ dependencies = [
|
|||
"data_types",
|
||||
"generated_types",
|
||||
"iox_catalog",
|
||||
"iox_tests",
|
||||
"metric",
|
||||
"observability_deps",
|
||||
"paste",
|
||||
|
|
@ -5360,7 +5312,6 @@ dependencies = [
|
|||
"parking_lot 0.12.1",
|
||||
"rand 0.8.5",
|
||||
"siphasher",
|
||||
"test_helpers",
|
||||
"workspace-hack",
|
||||
]
|
||||
|
||||
|
|
|
|||
|
|
@ -22,6 +22,5 @@ uuid = "1"
|
|||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
arrow-flight = { workspace = true }
|
||||
datafusion = { workspace = true }
|
||||
rand = "0.8.3"
|
||||
|
|
|
|||
|
|
@ -8,9 +8,13 @@
|
|||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod bitset;
|
||||
pub mod dictionary;
|
||||
pub mod display;
|
||||
|
|
|
|||
|
|
@ -13,10 +13,14 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(rustdoc::private_intra_doc_links)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use base64::{prelude::BASE64_STANDARD, Engine};
|
||||
use generated_types::influxdata::iox::authz::v1::{self as proto};
|
||||
use observability_deps::tracing::warn;
|
||||
|
|
|
|||
|
|
@ -10,8 +10,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use observability_deps::tracing::warn;
|
||||
use rand::prelude::*;
|
||||
use snafu::Snafu;
|
||||
|
|
|
|||
|
|
@ -9,9 +9,15 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod addressable_heap;
|
||||
pub mod backend;
|
||||
pub mod cache;
|
||||
|
|
|
|||
|
|
@ -7,19 +7,14 @@ license.workspace = true
|
|||
|
||||
[dependencies]
|
||||
clap = { version = "4", features = ["derive", "env"] }
|
||||
data_types = { path = "../data_types" }
|
||||
futures = "0.3"
|
||||
http = "0.2.9"
|
||||
humantime = "2.1.0"
|
||||
iox_catalog = { path = "../iox_catalog" }
|
||||
iox_time = { path = "../iox_time" }
|
||||
metric = { path = "../metric" }
|
||||
object_store = "0.5.6"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = "1.0.96"
|
||||
snafu = "0.7"
|
||||
trace = { path = "../trace" }
|
||||
trace_exporters = { path = "../trace_exporters" }
|
||||
trogging = { path = "../trogging", default-features = false, features = ["clap"] }
|
||||
uuid = { version = "1", features = ["v4"] }
|
||||
|
|
|
|||
|
|
@ -11,8 +11,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod catalog_dsn;
|
||||
pub mod compactor;
|
||||
pub mod garbage_collector;
|
||||
|
|
|
|||
|
|
@ -14,10 +14,14 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
/// Builder for constructing connections for use with the various gRPC clients
|
||||
pub mod connection;
|
||||
|
||||
|
|
|
|||
|
|
@ -200,10 +200,14 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(rustdoc::private_intra_doc_links)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod compactor;
|
||||
mod components;
|
||||
pub mod config;
|
||||
|
|
|
|||
|
|
@ -10,12 +10,13 @@ license.workspace = true
|
|||
async-trait = "0.1.68"
|
||||
backoff = { path = "../backoff" }
|
||||
compactor = { path = "../compactor" }
|
||||
data_types = { path = "../data_types" }
|
||||
datafusion = { workspace = true }
|
||||
datafusion_util = { path = "../datafusion_util" }
|
||||
data_types = { path = "../data_types" }
|
||||
futures = "0.3"
|
||||
iox_catalog = { path = "../iox_catalog" }
|
||||
iox_query = { path = "../iox_query" }
|
||||
iox_tests = { path = "../iox_tests" }
|
||||
iox_time = { path = "../iox_time" }
|
||||
object_store = "0.5.6"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
|
|
@ -26,5 +27,5 @@ tracker = { path = "../tracker" }
|
|||
uuid = { version = "1", features = ["v4"] }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
iox_tests = { path = "../iox_tests" }
|
||||
[dev-dependencies]
|
||||
insta = { version = "1.29.0", features = ["yaml"] }
|
||||
|
|
|
|||
|
|
@ -10,9 +10,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod commit_wrapper;
|
||||
mod display;
|
||||
mod simulator;
|
||||
|
|
|
|||
|
|
@ -14,9 +14,7 @@ generated_types = { path = "../generated_types" }
|
|||
observability_deps = { path = "../observability_deps" }
|
||||
once_cell = "1"
|
||||
ordered-float = "3"
|
||||
percent-encoding = "2.2.0"
|
||||
schema = { path = "../schema" }
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
sqlx = { version = "0.6", features = ["runtime-tokio-rustls", "postgres", "uuid"] }
|
||||
thiserror = "1.0.40"
|
||||
uuid = { version = "1", features = ["v4"] }
|
||||
|
|
@ -24,4 +22,3 @@ workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
|||
|
||||
[dev-dependencies] # In alphabetical order
|
||||
proptest = "1.1.0"
|
||||
test_helpers = { path = "../test_helpers" }
|
||||
|
|
|
|||
|
|
@ -11,9 +11,13 @@
|
|||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod sequence_number_set;
|
||||
|
||||
mod columns;
|
||||
|
|
|
|||
|
|
@ -1,4 +1,13 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![deny(
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
clippy::clone_on_ref_ptr,
|
||||
rustdoc::broken_intra_doc_links,
|
||||
rustdoc::bare_urls,
|
||||
rust_2018_idioms,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
|
||||
//! This module contains various DataFusion utility functions.
|
||||
|
|
@ -10,6 +19,9 @@
|
|||
//! [datafusion_optimizer::utils](https://docs.rs/datafusion-optimizer/13.0.0/datafusion_optimizer/utils/index.html)
|
||||
//! for expression manipulation functions.
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod config;
|
||||
pub mod sender;
|
||||
pub mod watch;
|
||||
|
|
|
|||
|
|
@ -11,9 +11,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::time::Duration;
|
||||
|
||||
use data_types::{
|
||||
|
|
|
|||
|
|
@ -11,9 +11,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use once_cell::sync::Lazy;
|
||||
use parking_lot::Mutex;
|
||||
use pin_project::{pin_project, pinned_drop};
|
||||
|
|
|
|||
|
|
@ -17,10 +17,7 @@ iox_query = { path = "../iox_query" }
|
|||
|
||||
# Crates.io dependencies, in alphabetical order
|
||||
bytes = "1.4"
|
||||
futures = "0.3"
|
||||
snafu = "0.7"
|
||||
once_cell = { version = "1", default-features = false }
|
||||
prost = "0.11"
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
|
|
|||
|
|
@ -55,7 +55,7 @@ impl Display for PreparedStatementHandle {
|
|||
/// Encode a PreparedStatementHandle as Bytes
|
||||
impl From<PreparedStatementHandle> for Bytes {
|
||||
fn from(value: PreparedStatementHandle) -> Self {
|
||||
Bytes::from(value.query.into_bytes())
|
||||
Self::from(value.query.into_bytes())
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -303,26 +303,26 @@ impl FlightSQLCommand {
|
|||
// Encode the command as a flightsql message (bytes)
|
||||
pub fn try_encode(self) -> Result<Bytes> {
|
||||
let msg = match self {
|
||||
FlightSQLCommand::CommandStatementQuery(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandPreparedStatementQuery(handle) => {
|
||||
Self::CommandStatementQuery(cmd) => Any::pack(&cmd),
|
||||
Self::CommandPreparedStatementQuery(handle) => {
|
||||
let prepared_statement_handle = handle.encode();
|
||||
let cmd = CommandPreparedStatementQuery {
|
||||
prepared_statement_handle,
|
||||
};
|
||||
Any::pack(&cmd)
|
||||
}
|
||||
FlightSQLCommand::CommandGetSqlInfo(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetCatalogs(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetCrossReference(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetDbSchemas(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetExportedKeys(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetImportedKeys(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetPrimaryKeys(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetTables(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetTableTypes(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::CommandGetXdbcTypeInfo(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::ActionCreatePreparedStatementRequest(cmd) => Any::pack(&cmd),
|
||||
FlightSQLCommand::ActionClosePreparedStatementRequest(handle) => {
|
||||
Self::CommandGetSqlInfo(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetCatalogs(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetCrossReference(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetDbSchemas(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetExportedKeys(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetImportedKeys(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetPrimaryKeys(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetTables(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetTableTypes(cmd) => Any::pack(&cmd),
|
||||
Self::CommandGetXdbcTypeInfo(cmd) => Any::pack(&cmd),
|
||||
Self::ActionCreatePreparedStatementRequest(cmd) => Any::pack(&cmd),
|
||||
Self::ActionClosePreparedStatementRequest(handle) => {
|
||||
let prepared_statement_handle = handle.encode();
|
||||
Any::pack(&ActionClosePreparedStatementRequest {
|
||||
prepared_statement_handle,
|
||||
|
|
|
|||
|
|
@ -44,8 +44,8 @@ impl From<Error> for DataFusionError {
|
|||
fn from(value: Error) -> Self {
|
||||
match value {
|
||||
Error::DataFusion { source } => source,
|
||||
Error::Arrow { source } => DataFusionError::ArrowError(source),
|
||||
value => DataFusionError::External(Box::new(value)),
|
||||
Error::Arrow { source } => Self::ArrowError(source),
|
||||
value => Self::External(Box::new(value)),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,4 +1,22 @@
|
|||
//! InfluxDB IOx implementation of FlightSQL
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
// Allow missing docs - there's lots missing!
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod cmd;
|
||||
mod error;
|
||||
mod get_catalogs;
|
||||
|
|
|
|||
|
|
@ -46,7 +46,7 @@ impl FlightSQLPlanner {
|
|||
|
||||
/// Returns the schema, in Arrow IPC encoded form, for the request in msg.
|
||||
pub async fn get_flight_info(
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
cmd: FlightSQLCommand,
|
||||
ctx: &IOxSessionContext,
|
||||
) -> Result<Bytes> {
|
||||
|
|
@ -101,7 +101,7 @@ impl FlightSQLPlanner {
|
|||
|
||||
/// Returns a plan that computes results requested in msg
|
||||
pub async fn do_get(
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
_database: Arc<dyn QueryNamespace>,
|
||||
cmd: FlightSQLCommand,
|
||||
ctx: &IOxSessionContext,
|
||||
|
|
@ -261,7 +261,7 @@ impl FlightSQLPlanner {
|
|||
/// the [`arrow_flight::Result`] (not the same as a rust
|
||||
/// [`Result`]!)
|
||||
pub async fn do_action(
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
_database: Arc<dyn QueryNamespace>,
|
||||
cmd: FlightSQLCommand,
|
||||
ctx: &IOxSessionContext,
|
||||
|
|
|
|||
|
|
@ -86,7 +86,7 @@ impl SqlInfoList {
|
|||
let mut name_builder = UInt32Builder::new();
|
||||
let mut value_builder = SqlInfoUnionBuilder::new();
|
||||
|
||||
for (&name, value) in self.infos.iter() {
|
||||
for (&name, value) in &self.infos {
|
||||
name_builder.append_value(name);
|
||||
value_builder.append_value(value)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -14,10 +14,15 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use clap as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
use crate::{
|
||||
objectstore::{checker as os_checker, deleter as os_deleter, lister as os_lister},
|
||||
parquetfile::deleter as pf_deleter,
|
||||
|
|
|
|||
|
|
@ -6,17 +6,17 @@ edition.workspace = true
|
|||
license.workspace = true
|
||||
|
||||
[dependencies] # In alphabetical order
|
||||
base64 = "0.21"
|
||||
bytes = "1.4"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
pbjson = "0.5"
|
||||
pbjson-types = "0.5"
|
||||
prost = "0.11"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
snafu = "0.7"
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
bytes = "1.4"
|
||||
|
||||
[build-dependencies] # In alphabetical order
|
||||
tonic-build = { workspace = true }
|
||||
prost-build = "0.11"
|
||||
|
|
|
|||
|
|
@ -3,6 +3,10 @@
|
|||
// control over.
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls)]
|
||||
#![allow(clippy::derive_partial_eq_without_eq, clippy::needless_borrow)]
|
||||
#![warn(unused_crate_dependencies)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
/// This module imports the generated protobuf code into a Rust module
|
||||
/// hierarchy that matches the namespace hierarchy of the protobuf
|
||||
|
|
|
|||
|
|
@ -1,4 +1,9 @@
|
|||
#![warn(unused_crate_dependencies)]
|
||||
#![allow(clippy::derive_partial_eq_without_eq)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod proto {
|
||||
tonic::include_proto!("grpc.binarylog.v1");
|
||||
}
|
||||
|
|
|
|||
|
|
@ -7,7 +7,6 @@ license.workspace = true
|
|||
|
||||
[dependencies]
|
||||
prost = "0.11"
|
||||
prost-types = { version = "0.11.9", features = ["std"] }
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,9 @@
|
|||
#![warn(unused_crate_dependencies)]
|
||||
#![allow(clippy::derive_partial_eq_without_eq)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod proto {
|
||||
tonic::include_proto!("test");
|
||||
}
|
||||
|
|
|
|||
|
|
@ -11,9 +11,19 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use assert_matches as _;
|
||||
#[cfg(test)]
|
||||
use grpc_binary_logger_test_proto as _;
|
||||
#[cfg(test)]
|
||||
use tokio_stream as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
mod predicate;
|
||||
pub use self::predicate::{NoReflection, Predicate};
|
||||
pub mod sink;
|
||||
|
|
|
|||
|
|
@ -6,31 +6,11 @@ edition.workspace = true
|
|||
license.workspace = true
|
||||
|
||||
[dependencies]
|
||||
chrono = { version = "0.4", default-features = false }
|
||||
data_types = { path = "../data_types" }
|
||||
futures = "0.3"
|
||||
futures-util = { version = "0.3" }
|
||||
influxdb_iox_client = { path = "../influxdb_iox_client", features = ["flight", "format"] }
|
||||
iox_catalog = { path = "../iox_catalog" }
|
||||
object_store = { version = "0.5.6", features = ["aws"] }
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
schema = { path = "../schema" }
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = "1.0.96"
|
||||
thiserror = "1.0.40"
|
||||
tokio = { version = "1.28" }
|
||||
tokio-util = { version = "0.7.8" }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
|
||||
[dev-dependencies]
|
||||
assert_matches = "1.5"
|
||||
client_util = { path = "../client_util" }
|
||||
metric = { path = "../metric" }
|
||||
parking_lot = "0.12"
|
||||
tokio-stream = { version = "0.1", features = ["net"] }
|
||||
|
||||
[features]
|
||||
azure = ["object_store/azure"] # Optional Azure Object store support
|
||||
gcp = ["object_store/gcp"] # Optional GCP object store support
|
||||
aws = ["object_store/aws"] # Optional AWS / S3 object store support
|
||||
|
|
|
|||
|
|
@ -6,8 +6,12 @@
|
|||
clippy::explicit_iter_loop,
|
||||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::future_not_send
|
||||
clippy::future_not_send,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
/// Import/Export data to files
|
||||
pub mod file;
|
||||
|
|
|
|||
|
|
@ -10,7 +10,8 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
//! # influxdb2_client
|
||||
|
|
@ -67,6 +68,14 @@
|
|||
//! }
|
||||
//! ```
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use once_cell as _;
|
||||
#[cfg(test)]
|
||||
use parking_lot as _;
|
||||
#[cfg(test)]
|
||||
use test_helpers as _;
|
||||
|
||||
use reqwest::Method;
|
||||
use snafu::Snafu;
|
||||
|
||||
|
|
|
|||
|
|
@ -12,9 +12,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use crate::common::{statement_terminator, ws0};
|
||||
use crate::internal::Error as InternalError;
|
||||
use crate::statement::{statement, Statement};
|
||||
|
|
|
|||
|
|
@ -96,9 +96,9 @@ insta = { version = "1", features = ["yaml"] }
|
|||
[features]
|
||||
default = ["jemalloc_replacing_malloc"]
|
||||
|
||||
azure = ["clap_blocks/azure", "import_export/azure"] # Optional Azure Object store support
|
||||
gcp = ["clap_blocks/gcp", "import_export/gcp"] # Optional GCP object store support
|
||||
aws = ["clap_blocks/aws", "import_export/aws"] # Optional AWS / S3 object store support
|
||||
azure = ["clap_blocks/azure"] # Optional Azure Object store support
|
||||
gcp = ["clap_blocks/gcp"] # Optional GCP object store support
|
||||
aws = ["clap_blocks/aws"] # Optional AWS / S3 object store support
|
||||
pprof = ["ioxd_common/pprof"] # Optional http://localhost:8080/debug/pprof/profile support
|
||||
heappy = ["ioxd_common/heappy"] # Optional http://localhost:8080/debug/pproc/alloc support
|
||||
|
||||
|
|
|
|||
|
|
@ -37,6 +37,6 @@ async fn assert_panic_logging(connection: Connection, log_path: Box<Path>) {
|
|||
|
||||
// check logs
|
||||
let logs = std::fs::read_to_string(log_path).unwrap();
|
||||
let expected_error = "'This is a test panic', service_grpc_testing/src/lib.rs:18:9";
|
||||
let expected_error = "'This is a test panic', service_grpc_testing/src/lib.rs:";
|
||||
assert_contains!(logs, expected_error);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -14,7 +14,8 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
|
|
|
|||
|
|
@ -63,7 +63,8 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
pub mod builder;
|
||||
|
|
|
|||
|
|
@ -14,10 +14,14 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use client_util::connection::GrpcConnection;
|
||||
use futures_util::TryStreamExt;
|
||||
use prost::Message;
|
||||
|
|
|
|||
|
|
@ -6,9 +6,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod encoders;
|
||||
pub mod key;
|
||||
pub mod mapper;
|
||||
|
|
|
|||
|
|
@ -10,7 +10,11 @@
|
|||
clippy::str_to_string,
|
||||
clippy::string_to_string,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod predicate;
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ iox_time = { path = "../iox_time" }
|
|||
metric = { version = "0.1.0", path = "../metric" }
|
||||
mutable_batch = { version = "0.1.0", path = "../mutable_batch" }
|
||||
mutable_batch_pb = { version = "0.1.0", path = "../mutable_batch_pb" }
|
||||
object_store = "0.5.6"
|
||||
observability_deps = { version = "0.1.0", path = "../observability_deps" }
|
||||
once_cell = "1.17"
|
||||
parking_lot = "0.12.1"
|
||||
|
|
@ -59,6 +58,7 @@ influxdb_iox_client = { path = "../influxdb_iox_client" }
|
|||
ingester_test_ctx = { path = "../ingester_test_ctx" }
|
||||
lazy_static = "1.4.0"
|
||||
mutable_batch_lp = { path = "../mutable_batch_lp" }
|
||||
object_store = "0.5.6"
|
||||
paste = "1.0.12"
|
||||
tempfile = "3.5.0"
|
||||
test_helpers = { path = "../test_helpers", features = ["future_timeout"] }
|
||||
|
|
|
|||
|
|
@ -197,9 +197,19 @@
|
|||
clippy::use_self,
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies,
|
||||
missing_docs
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
#[cfg(test)]
|
||||
use influxdb_iox_client as _;
|
||||
#[cfg(test)]
|
||||
use ingester_test_ctx as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
/// Ingester initialisation methods & types.
|
||||
///
|
||||
/// This module defines the public API boundary of the Ingester crate.
|
||||
|
|
|
|||
|
|
@ -11,7 +11,6 @@ data_types = { path = "../data_types" }
|
|||
datafusion = { workspace = true }
|
||||
datafusion-proto = { workspace = true }
|
||||
pbjson = "0.5"
|
||||
pbjson-types = "0.5"
|
||||
predicate = { path = "../predicate" }
|
||||
prost = "0.11"
|
||||
query_functions = { path = "../query_functions" }
|
||||
|
|
|
|||
|
|
@ -1,9 +1,23 @@
|
|||
// This crate deliberately does not use the same linting rules as the other
|
||||
// crates because of all the generated code it contains that we don't have much
|
||||
// control over.
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls)]
|
||||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::derive_partial_eq_without_eq, clippy::needless_borrow)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use crate::influxdata::iox::ingester::v1 as proto;
|
||||
use base64::{prelude::BASE64_STANDARD, Engine};
|
||||
use data_types::{NamespaceId, TableId, TimestampRange};
|
||||
|
|
@ -16,6 +30,7 @@ use snafu::{ResultExt, Snafu};
|
|||
/// This module imports the generated protobuf code into a Rust module
|
||||
/// hierarchy that matches the namespace hierarchy of the protobuf
|
||||
/// definitions
|
||||
#[allow(clippy::use_self)]
|
||||
pub mod influxdata {
|
||||
pub mod iox {
|
||||
pub mod ingester {
|
||||
|
|
|
|||
|
|
@ -32,5 +32,4 @@ test_helpers = { path = "../test_helpers", features = ["future_timeout"] }
|
|||
tokio = { version = "1.28", features = ["macros", "parking_lot", "rt-multi-thread", "sync", "time"] }
|
||||
tokio-util = "0.7.8"
|
||||
tonic = { workspace = true }
|
||||
wal = { version = "0.1.0", path = "../wal" }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
|
|
|||
|
|
@ -10,9 +10,13 @@
|
|||
clippy::use_self,
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
missing_docs
|
||||
missing_docs,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::{collections::HashMap, sync::Arc, time::Duration};
|
||||
|
||||
use arrow::record_batch::RecordBatch;
|
||||
|
|
|
|||
|
|
@ -32,4 +32,3 @@ paste = "1.0.12"
|
|||
pretty_assertions = "1.3.0"
|
||||
rand = "0.8"
|
||||
tempfile = "3"
|
||||
test_helpers = { path = "../test_helpers" }
|
||||
|
|
|
|||
|
|
@ -11,9 +11,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use crate::interface::{ColumnTypeMismatchSnafu, Error, RepoCollection, Result};
|
||||
use data_types::{ColumnType, NamespaceSchema, TableSchema};
|
||||
use mutable_batch::MutableBatch;
|
||||
|
|
|
|||
|
|
@ -27,9 +27,16 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use clap as _;
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
use tracing_subscriber as _;
|
||||
|
||||
use crate::{
|
||||
agent::{Agent, AgentGenerateStats},
|
||||
tag_set::GeneratedTagSets,
|
||||
|
|
|
|||
|
|
@ -8,9 +8,13 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use arrow::{
|
||||
datatypes::{DataType, Field},
|
||||
record_batch::RecordBatch,
|
||||
|
|
|
|||
|
|
@ -9,7 +9,6 @@ license.workspace = true
|
|||
arrow = { workspace = true, features = ["prettyprint"] }
|
||||
chrono = { version = "0.4", default-features = false }
|
||||
chrono-tz = { version = "0.8" }
|
||||
data_types = { path = "../data_types" }
|
||||
datafusion = { workspace = true }
|
||||
datafusion_util = { path = "../datafusion_util" }
|
||||
generated_types = { path = "../generated_types" }
|
||||
|
|
@ -17,8 +16,7 @@ influxdb_influxql_parser = { path = "../influxdb_influxql_parser" }
|
|||
iox_query = { path = "../iox_query" }
|
||||
itertools = "0.10.5"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
once_cell = "1"
|
||||
query_functions = { path = "../query_functions"}
|
||||
query_functions = { path = "../query_functions" }
|
||||
regex = "1"
|
||||
schema = { path = "../schema" }
|
||||
serde_json = "1.0.96"
|
||||
|
|
@ -29,4 +27,3 @@ workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
|||
test_helpers = { path = "../test_helpers" }
|
||||
assert_matches = "1"
|
||||
insta = { version = "1", features = ["yaml"] }
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
|
|
|
|||
|
|
@ -8,8 +8,12 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod frontend;
|
||||
pub mod plan;
|
||||
|
|
|
|||
|
|
@ -1,5 +1,22 @@
|
|||
//! Query frontend for InfluxDB Storage gRPC requests
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use arrow::datatypes::DataType;
|
||||
use data_types::ChunkId;
|
||||
use datafusion::{
|
||||
|
|
|
|||
|
|
@ -8,20 +8,17 @@ license.workspace = true
|
|||
|
||||
[dependencies]
|
||||
arrow = { workspace = true }
|
||||
bytes = "1.4"
|
||||
data_types = { path = "../data_types" }
|
||||
datafusion = { workspace = true }
|
||||
datafusion_util = { path = "../datafusion_util" }
|
||||
iox_catalog = { path = "../iox_catalog" }
|
||||
iox_query = { path = "../iox_query" }
|
||||
iox_time = { path = "../iox_time" }
|
||||
metric = { path = "../metric" }
|
||||
mutable_batch_lp = { path = "../mutable_batch_lp" }
|
||||
object_store = "0.5.6"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
parquet_file = { path = "../parquet_file" }
|
||||
predicate = { path = "../predicate" }
|
||||
iox_query = { path = "../iox_query" }
|
||||
schema = { path = "../schema" }
|
||||
uuid = { version = "1", features = ["v4"] }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
futures = "0.3.28"
|
||||
|
|
|
|||
|
|
@ -10,9 +10,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod catalog;
|
||||
pub use catalog::{
|
||||
TestCatalog, TestNamespace, TestParquetFile, TestParquetFileBuilder, TestPartition, TestTable,
|
||||
|
|
|
|||
|
|
@ -7,9 +7,13 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use chrono::{DateTime, TimeZone, Timelike, Utc};
|
||||
use parking_lot::{lock_api::RwLockUpgradableReadGuard, RwLock};
|
||||
use std::{
|
||||
|
|
|
|||
|
|
@ -83,6 +83,7 @@ pub fn get_content_type(response: &Result<reqwest::Response, reqwest::Error>) ->
|
|||
}
|
||||
}
|
||||
|
||||
#[derive(Debug)]
|
||||
pub struct TestServer<M>
|
||||
where
|
||||
M: ServerType,
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod http;
|
||||
pub mod rpc;
|
||||
pub mod server_type;
|
||||
|
|
|
|||
|
|
@ -5,6 +5,7 @@ use clap_blocks::{run_config::RunConfig, socket_addr::SocketAddr};
|
|||
use crate::server_type::ServerType;
|
||||
|
||||
/// A service that will start on the specified addresses
|
||||
#[derive(Debug)]
|
||||
pub struct Service {
|
||||
pub http_bind_address: Option<SocketAddr>,
|
||||
pub grpc_bind_address: SocketAddr,
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use async_trait::async_trait;
|
||||
use backoff::BackoffConfig;
|
||||
use clap_blocks::compactor::{CompactionType, CompactorConfig};
|
||||
|
|
@ -110,7 +126,7 @@ pub enum IoxHttpError {
|
|||
impl IoxHttpError {
|
||||
fn status_code(&self) -> HttpApiErrorCode {
|
||||
match self {
|
||||
IoxHttpError::NotFound => HttpApiErrorCode::NotFound,
|
||||
Self::NotFound => HttpApiErrorCode::NotFound,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -12,7 +12,6 @@ hyper = "0.14"
|
|||
garbage_collector = { path = "../garbage_collector" }
|
||||
ioxd_common = { path = "../ioxd_common" }
|
||||
metric = { path = "../metric" }
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
snafu = "0.7"
|
||||
tokio = { version = "1", features = ["sync"] }
|
||||
trace = { path = "../trace" }
|
||||
|
|
|
|||
|
|
@ -14,10 +14,14 @@
|
|||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use async_trait::async_trait;
|
||||
use futures::{
|
||||
future::{BoxFuture, Shared},
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use arrow_flight::flight_service_server::FlightServiceServer;
|
||||
use async_trait::async_trait;
|
||||
use clap_blocks::ingester::IngesterConfig;
|
||||
|
|
@ -162,7 +178,7 @@ pub enum IoxHttpError {
|
|||
impl IoxHttpError {
|
||||
fn status_code(&self) -> HttpApiErrorCode {
|
||||
match self {
|
||||
IoxHttpError::NotFound => HttpApiErrorCode::NotFound,
|
||||
Self::NotFound => HttpApiErrorCode::NotFound,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use async_trait::async_trait;
|
||||
use authz::{Authorizer, IoxAuthorizer};
|
||||
use clap_blocks::querier::QuerierConfig;
|
||||
|
|
@ -131,7 +147,7 @@ pub enum IoxHttpError {
|
|||
impl IoxHttpError {
|
||||
fn status_code(&self) -> HttpApiErrorCode {
|
||||
match self {
|
||||
IoxHttpError::NotFound => HttpApiErrorCode::NotFound,
|
||||
Self::NotFound => HttpApiErrorCode::NotFound,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -18,9 +18,10 @@ metric = { path = "../metric" }
|
|||
mutable_batch = { path = "../mutable_batch" }
|
||||
object_store = "0.5.6"
|
||||
router = { path = "../router" }
|
||||
sharder = { path = "../sharder" }
|
||||
thiserror = "1.0.40"
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
tokio-util = { version = "0.7.8" }
|
||||
trace = { path = "../trace" }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::{
|
||||
fmt::{Debug, Display},
|
||||
sync::Arc,
|
||||
|
|
|
|||
|
|
@ -1,3 +1,19 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rust_2018_idioms)]
|
||||
#![warn(
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::dbg_macro,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::todo,
|
||||
clippy::use_self,
|
||||
missing_debug_implementations,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::sync::Arc;
|
||||
|
||||
use async_trait::async_trait;
|
||||
|
|
|
|||
|
|
@ -1,4 +1,24 @@
|
|||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use once_cell as _;
|
||||
#[cfg(test)]
|
||||
use parking_lot as _;
|
||||
#[cfg(test)]
|
||||
use regex as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
use observability_deps::tracing::{
|
||||
self,
|
||||
|
|
@ -19,6 +39,7 @@ use tracing_subscriber::{fmt::MakeWriter, layer::Context, registry::LookupSpan,
|
|||
/// looked very small and did not (obviously) work with the tracing subscriber
|
||||
///
|
||||
/// [logfmt]: https://brandur.org/logfmt
|
||||
#[derive(Debug)]
|
||||
pub struct LogFmtLayer<W>
|
||||
where
|
||||
W: for<'writer> MakeWriter<'writer>,
|
||||
|
|
|
|||
|
|
@ -109,9 +109,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use parking_lot::Mutex;
|
||||
use std::any::Any;
|
||||
use std::borrow::Cow;
|
||||
|
|
|
|||
|
|
@ -5,9 +5,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use metric::{Attributes, MetricKind, Observation};
|
||||
use std::io::Write;
|
||||
|
||||
|
|
|
|||
|
|
@ -9,7 +9,8 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
//! A mutable data structure for a collection of writes.
|
||||
|
|
@ -18,6 +19,9 @@
|
|||
//! owner of its buffers, permitting mutability. The in-memory layout is similar, however,
|
||||
//! permitting fast conversion to [`RecordBatch`].
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use crate::column::{Column, ColumnData};
|
||||
use arrow::record_batch::RecordBatch;
|
||||
use data_types::StatValues;
|
||||
|
|
|
|||
|
|
@ -10,7 +10,6 @@ license.workspace = true
|
|||
hashbrown = { workspace = true }
|
||||
influxdb-line-protocol = { path = "../influxdb_line_protocol" }
|
||||
mutable_batch = { path = "../mutable_batch" }
|
||||
schema = { path = "../schema" }
|
||||
snafu = "0.7"
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
|
|
@ -18,6 +17,7 @@ workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
|||
arrow_util = { path = "../arrow_util" }
|
||||
assert_matches = "1.5.0"
|
||||
criterion = { version = "0.4", default-features = false, features = ["rayon"]}
|
||||
schema = { path = "../schema" }
|
||||
|
||||
[[bench]]
|
||||
name = "parse_lp"
|
||||
|
|
|
|||
|
|
@ -11,9 +11,15 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
use hashbrown::{hash_map::Entry, HashMap, HashSet};
|
||||
use influxdb_line_protocol::{parse_lines, FieldValue, ParsedLine};
|
||||
use mutable_batch::writer::Writer;
|
||||
|
|
|
|||
|
|
@ -11,8 +11,16 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use data_types as _;
|
||||
#[cfg(test)]
|
||||
use mutable_batch_lp as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod decode;
|
||||
pub mod encode;
|
||||
|
|
|
|||
|
|
@ -7,18 +7,18 @@ edition.workspace = true
|
|||
license.workspace = true
|
||||
|
||||
[dependencies]
|
||||
dml = { path = "../dml" }
|
||||
flate2 = "1.0"
|
||||
generated_types = { path = "../generated_types" }
|
||||
mutable_batch = { path = "../mutable_batch" }
|
||||
mutable_batch_lp = { path = "../mutable_batch_lp" }
|
||||
mutable_batch_pb = { path = "../mutable_batch_pb" }
|
||||
prost = "0.11"
|
||||
|
||||
[dev-dependencies]
|
||||
bytes = "1.4"
|
||||
criterion = { version = "0.4", default-features = false, features = ["rayon"]}
|
||||
data_types = { path = "../data_types", default-features = false }
|
||||
dml = { path = "../dml" }
|
||||
generated_types = { path = "../generated_types" }
|
||||
mutable_batch = { path = "../mutable_batch" }
|
||||
mutable_batch_lp = { path = "../mutable_batch_lp" }
|
||||
mutable_batch_pb = { path = "../mutable_batch_pb" }
|
||||
prost = "0.11"
|
||||
|
||||
[[bench]]
|
||||
name = "write_lp"
|
||||
|
|
|
|||
|
|
@ -1,5 +1,27 @@
|
|||
//! This crate only exists for its tests and benchmarks
|
||||
|
||||
#![warn(unused_crate_dependencies)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use bytes as _;
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
#[cfg(test)]
|
||||
use data_types as _;
|
||||
#[cfg(test)]
|
||||
use dml as _;
|
||||
#[cfg(test)]
|
||||
use generated_types as _;
|
||||
#[cfg(test)]
|
||||
use mutable_batch as _;
|
||||
#[cfg(test)]
|
||||
use mutable_batch_lp as _;
|
||||
#[cfg(test)]
|
||||
use mutable_batch_pb as _;
|
||||
#[cfg(test)]
|
||||
use prost as _;
|
||||
|
||||
use flate2::read::GzDecoder;
|
||||
use std::io::Read;
|
||||
use std::path::Path;
|
||||
|
|
|
|||
|
|
@ -17,6 +17,5 @@ tokio = { version = "1.28", features = ["io-util"] }
|
|||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies] # In alphabetical order
|
||||
dotenvy = "0.15.7"
|
||||
snafu = "0.7"
|
||||
tokio = { version = "1.28", features = ["macros", "io-util"] }
|
||||
|
|
|
|||
|
|
@ -1,5 +1,22 @@
|
|||
//! A metric instrumentation wrapper over [`ObjectStore`] implementations.
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::ops::Range;
|
||||
use std::sync::Arc;
|
||||
use std::{
|
||||
|
|
|
|||
|
|
@ -8,9 +8,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::{collections::HashMap, fmt, panic, sync::Arc};
|
||||
|
||||
use metric::U64Counter;
|
||||
|
|
@ -256,9 +260,9 @@ mod tests {
|
|||
|
||||
assert_eq!(
|
||||
capture.to_string(),
|
||||
"level = ERROR; message = Thread panic; panic_type = \"unknown\"; panic_info = panicked at 'it's bananas', panic_logging/src/lib.rs:223:13; \
|
||||
\nlevel = ERROR; message = Thread panic; panic_type = \"offset_overflow\"; panic_info = panicked at 'offset', panic_logging/src/lib.rs:231:13; \
|
||||
\nlevel = ERROR; message = Thread panic; panic_type = \"offset_overflow\"; panic_info = panicked at 'offset overflow', panic_logging/src/lib.rs:240:13; ",
|
||||
"level = ERROR; message = Thread panic; panic_type = \"unknown\"; panic_info = panicked at 'it's bananas', panic_logging/src/lib.rs:227:13; \n\
|
||||
level = ERROR; message = Thread panic; panic_type = \"offset_overflow\"; panic_info = panicked at 'offset', panic_logging/src/lib.rs:235:13; \n\
|
||||
level = ERROR; message = Thread panic; panic_type = \"offset_overflow\"; panic_info = panicked at 'offset overflow', panic_logging/src/lib.rs:244:13; "
|
||||
);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -17,10 +17,8 @@ generated_types = { path = "../generated_types" }
|
|||
iox_time = { path = "../iox_time" }
|
||||
object_store = "0.5.6"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
parking_lot = "0.12"
|
||||
parquet = { workspace = true, features = ["experimental"]}
|
||||
pbjson-types = "0.5"
|
||||
predicate = { path = "../predicate" }
|
||||
prost = "0.11"
|
||||
schema = { path = "../schema" }
|
||||
snafu = "0.7"
|
||||
|
|
|
|||
|
|
@ -12,10 +12,14 @@
|
|||
unreachable_pub,
|
||||
missing_docs,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod chunk;
|
||||
pub mod metadata;
|
||||
pub mod serialize;
|
||||
|
|
|
|||
|
|
@ -20,5 +20,4 @@ workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
|||
|
||||
|
||||
[dev-dependencies]
|
||||
mutable_batch = { path = "../mutable_batch" }
|
||||
mutable_batch_lp = { path = "../mutable_batch_lp" }
|
||||
|
|
|
|||
|
|
@ -1,5 +1,22 @@
|
|||
//! Code that can convert between parquet files and line protocol
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use datafusion::{
|
||||
arrow::datatypes::SchemaRef as ArrowSchemaRef,
|
||||
datasource::{
|
||||
|
|
@ -94,7 +111,7 @@ pub enum Error {
|
|||
/// protocol (aka lines are not split across the buffers)
|
||||
pub async fn convert_file<P>(path: P) -> Result<BoxStream<'static, Result<Vec<u8>>>>
|
||||
where
|
||||
P: AsRef<Path>,
|
||||
P: AsRef<Path> + Send,
|
||||
{
|
||||
let path = path.as_ref();
|
||||
let object_store_path =
|
||||
|
|
@ -172,6 +189,18 @@ pub struct ParquetFileReader {
|
|||
session_ctx: SessionContext,
|
||||
}
|
||||
|
||||
impl std::fmt::Debug for ParquetFileReader {
|
||||
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
||||
f.debug_struct("ParquetFileReader")
|
||||
.field("object_store", &self.object_store)
|
||||
.field("object_store_url", &self.object_store_url)
|
||||
.field("object_meta", &self.object_meta)
|
||||
.field("schema", &self.schema)
|
||||
.field("session_ctx", &"<CONTEXT>")
|
||||
.finish()
|
||||
}
|
||||
}
|
||||
|
||||
impl ParquetFileReader {
|
||||
/// Find and open the specified parquet file, and read its metadata / schema
|
||||
pub async fn try_new(
|
||||
|
|
|
|||
|
|
@ -8,9 +8,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod delete_expr;
|
||||
pub mod delete_predicate;
|
||||
pub mod rpc_predicate;
|
||||
|
|
|
|||
|
|
@ -9,9 +9,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod cache;
|
||||
mod database;
|
||||
mod handler;
|
||||
|
|
|
|||
|
|
@ -9,8 +9,6 @@ license.workspace = true
|
|||
arrow = { workspace = true, features = ["prettyprint"] }
|
||||
chrono = { version = "0.4", default-features = false }
|
||||
datafusion = { workspace = true }
|
||||
itertools = "0.10.5"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
once_cell = "1"
|
||||
regex = "1"
|
||||
regex-syntax = "0.7.1"
|
||||
|
|
@ -19,5 +17,6 @@ snafu = "0.7"
|
|||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
itertools = "0.10.5"
|
||||
tokio = { version = "1.28", features = ["macros", "parking_lot"] }
|
||||
datafusion_util = { path = "../datafusion_util" }
|
||||
|
|
|
|||
|
|
@ -9,9 +9,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use datafusion::{
|
||||
execution::FunctionRegistry,
|
||||
prelude::{lit, Expr, SessionContext},
|
||||
|
|
|
|||
|
|
@ -8,7 +8,6 @@ license.workspace = true
|
|||
[dependencies]
|
||||
async-trait = "0.1"
|
||||
authz = { path = "../authz", features = ["http"] }
|
||||
base64 = "0.21.1"
|
||||
bytes = "1.4"
|
||||
crossbeam-utils = "0.8.15"
|
||||
data_types = { path = "../data_types" }
|
||||
|
|
@ -27,9 +26,7 @@ mutable_batch_pb = { version = "0.1.0", path = "../mutable_batch_pb" }
|
|||
object_store = "0.5.6"
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
parking_lot = "0.12"
|
||||
schema = { version = "0.1.0", path = "../schema" }
|
||||
serde = "1.0"
|
||||
serde_json = "1.0.96"
|
||||
serde_urlencoded = "0.7"
|
||||
service_grpc_catalog = { path = "../service_grpc_catalog"}
|
||||
service_grpc_namespace = { path = "../service_grpc_namespace"}
|
||||
|
|
@ -45,6 +42,7 @@ workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
|||
|
||||
[dev-dependencies]
|
||||
assert_matches = "1.5"
|
||||
base64 = "0.21.0"
|
||||
criterion = { version = "0.4", default-features = false, features = ["async_tokio", "rayon"]}
|
||||
influxdb-line-protocol = { path = "../influxdb_line_protocol" }
|
||||
iox_tests = { path = "../iox_tests" }
|
||||
|
|
@ -53,6 +51,7 @@ paste = "1.0.12"
|
|||
pretty_assertions = "1.3.0"
|
||||
proptest = "1.1.0"
|
||||
rand = "0.8.3"
|
||||
schema = { version = "0.1.0", path = "../schema" }
|
||||
test_helpers = { version = "0.1.0", path = "../test_helpers", features = ["future_timeout"] }
|
||||
tokio = { version = "1", features = ["test-util"] }
|
||||
tokio-stream = { version = "0.1.13", default_features = false, features = [] }
|
||||
|
|
|
|||
|
|
@ -126,10 +126,16 @@
|
|||
clippy::explicit_iter_loop,
|
||||
clippy::clone_on_ref_ptr,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send
|
||||
clippy::future_not_send,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
#![allow(clippy::missing_docs_in_private_items)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
#[cfg(test)]
|
||||
use criterion as _;
|
||||
use workspace_hack as _;
|
||||
|
||||
pub mod dml_handlers;
|
||||
pub mod namespace_cache;
|
||||
pub mod namespace_resolver;
|
||||
|
|
|
|||
|
|
@ -1,4 +1,22 @@
|
|||
//! This module contains the schema definition for IOx
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use std::{
|
||||
cmp::Ordering,
|
||||
collections::HashMap,
|
||||
|
|
|
|||
|
|
@ -1,5 +1,22 @@
|
|||
//! Common methods for RPC service implementations
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod error;
|
||||
pub mod planner;
|
||||
pub mod test_util;
|
||||
|
|
|
|||
|
|
@ -18,10 +18,10 @@ use predicate::rpc_predicate::InfluxRpcPredicate;
|
|||
|
||||
/// Query planner that plans queries on a separate threadpool.
|
||||
///
|
||||
/// Query planning was, at time of writing, a single threaded
|
||||
/// affair. In order to avoid tying up the tokio executor that is
|
||||
/// handling API requests, IOx plan queries using a separate thread
|
||||
/// pool.
|
||||
/// Query planning was, at time of writing, a single threaded affair. In order
|
||||
/// to avoid tying up the tokio executor that is handling API requests, IOx plan
|
||||
/// queries using a separate thread pool.
|
||||
#[derive(Debug)]
|
||||
pub struct Planner {
|
||||
/// Executors (whose threadpool to use)
|
||||
ctx: IOxSessionContext,
|
||||
|
|
@ -62,12 +62,11 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan for a `DoGet` FlightSQL message,
|
||||
/// as described on [`FlightSQLPlanner::do_get`], on a
|
||||
/// separate threadpool
|
||||
/// Creates a plan for a `DoGet` FlightSQL message, as described on
|
||||
/// [`FlightSQLPlanner::do_get`], on a separate threadpool
|
||||
pub async fn flight_sql_do_get<N>(
|
||||
&self,
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
namespace: Arc<N>,
|
||||
cmd: FlightSQLCommand,
|
||||
) -> Result<Arc<dyn ExecutionPlan>>
|
||||
|
|
@ -86,12 +85,11 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan for a `DoAction` FlightSQL message,
|
||||
/// as described on [`FlightSQLPlanner::do_action`], on a
|
||||
/// separate threadpool
|
||||
/// Creates a plan for a `DoAction` FlightSQL message, as described on
|
||||
/// [`FlightSQLPlanner::do_action`], on a separate threadpool
|
||||
pub async fn flight_sql_do_action<N>(
|
||||
&self,
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
namespace: Arc<N>,
|
||||
cmd: FlightSQLCommand,
|
||||
) -> Result<Bytes>
|
||||
|
|
@ -110,12 +108,12 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates the response for a `GetFlightInfo` FlightSQL message
|
||||
/// as described on [`FlightSQLPlanner::get_flight_info`], on a
|
||||
/// separate threadpool.
|
||||
/// Creates the response for a `GetFlightInfo` FlightSQL message as
|
||||
/// described on [`FlightSQLPlanner::get_flight_info`], on a separate
|
||||
/// threadpool.
|
||||
pub async fn flight_sql_get_flight_info(
|
||||
&self,
|
||||
namespace_name: impl Into<String>,
|
||||
namespace_name: impl Into<String> + Send,
|
||||
cmd: FlightSQLCommand,
|
||||
) -> Result<Bytes> {
|
||||
let namespace_name = namespace_name.into();
|
||||
|
|
@ -130,8 +128,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::table_names`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::table_names`], on a
|
||||
/// separate threadpool
|
||||
pub async fn table_names<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
@ -152,8 +150,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::tag_keys`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::tag_keys`], on a
|
||||
/// separate threadpool
|
||||
pub async fn tag_keys<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
@ -174,8 +172,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::tag_values`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::tag_values`], on a
|
||||
/// separate threadpool
|
||||
pub async fn tag_values<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
@ -198,8 +196,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::field_columns`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::field_columns`], on a
|
||||
/// separate threadpool
|
||||
pub async fn field_columns<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
@ -220,8 +218,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::read_filter`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::read_filter`], on a
|
||||
/// separate threadpool
|
||||
pub async fn read_filter<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
@ -242,8 +240,8 @@ impl Planner {
|
|||
.await
|
||||
}
|
||||
|
||||
/// Creates a plan as described on
|
||||
/// [`InfluxRpcPlanner::read_group`], on a separate threadpool
|
||||
/// Creates a plan as described on [`InfluxRpcPlanner::read_group`], on a
|
||||
/// separate threadpool
|
||||
pub async fn read_group<N>(
|
||||
&self,
|
||||
namespace: Arc<N>,
|
||||
|
|
|
|||
|
|
@ -10,10 +10,10 @@ data_types = { path = "../data_types" }
|
|||
generated_types = { path = "../generated_types" }
|
||||
iox_catalog = { path = "../iox_catalog" }
|
||||
observability_deps = { path = "../observability_deps" }
|
||||
tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
metric = { path = "../metric" }
|
||||
uuid = { version = "1", features = ["v4"] }
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
|
|
|
|||
|
|
@ -11,9 +11,13 @@
|
|||
clippy::use_self,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
use data_types::{PartitionId, TableId};
|
||||
use generated_types::influxdata::iox::catalog::v1::*;
|
||||
use iox_catalog::interface::{Catalog, SoftDeletedRows};
|
||||
|
|
|
|||
|
|
@ -8,7 +8,6 @@ license.workspace = true
|
|||
[dependencies]
|
||||
# Workspace dependencies, in alphabetical order
|
||||
authz = { path = "../authz" }
|
||||
arrow_util = { path = "../arrow_util" }
|
||||
data_types = { path = "../data_types" }
|
||||
datafusion = { workspace = true }
|
||||
flightsql = { path = "../flightsql" }
|
||||
|
|
@ -23,17 +22,17 @@ tracker = { path = "../tracker" }
|
|||
# Crates.io dependencies, in alphabetical order
|
||||
arrow = { workspace = true, features = ["prettyprint"] }
|
||||
arrow-flight = { workspace = true, features=["flight-sql-experimental"] }
|
||||
async-trait = "0.1"
|
||||
bytes = "1.4"
|
||||
futures = "0.3"
|
||||
prost = "0.11"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = "1.0.96"
|
||||
snafu = "0.7"
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
||||
[dev-dependencies]
|
||||
metric = { path = "../metric" }
|
||||
assert_matches = "1"
|
||||
async-trait = "0.1"
|
||||
metric = { path = "../metric" }
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
|
|
|
|||
|
|
@ -1,6 +1,23 @@
|
|||
//! Implements the InfluxDB IOx Flight API and Arrow FlightSQL, based
|
||||
//! on Arrow Flight and gRPC. See [`FlightService`] for full detail.
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
mod request;
|
||||
|
||||
use arrow::error::ArrowError;
|
||||
|
|
@ -1115,7 +1132,7 @@ mod tests {
|
|||
#[tokio::test]
|
||||
async fn do_get_authz() {
|
||||
let test_storage = Arc::new(TestDatabaseStore::default());
|
||||
test_storage.clone().db_or_create("bananas").await;
|
||||
test_storage.db_or_create("bananas").await;
|
||||
|
||||
let svc = FlightService {
|
||||
server: Arc::clone(&test_storage),
|
||||
|
|
@ -1217,7 +1234,7 @@ mod tests {
|
|||
#[tokio::test]
|
||||
async fn get_flight_info_authz() {
|
||||
let test_storage = Arc::new(TestDatabaseStore::default());
|
||||
test_storage.clone().db_or_create("bananas").await;
|
||||
test_storage.db_or_create("bananas").await;
|
||||
|
||||
let svc = FlightService {
|
||||
server: Arc::clone(&test_storage),
|
||||
|
|
|
|||
|
|
@ -15,7 +15,6 @@ observability_deps = { path = "../observability_deps" }
|
|||
predicate = { path = "../predicate" }
|
||||
iox_query = { path = "../iox_query" }
|
||||
query_functions = { path = "../query_functions"}
|
||||
schema = { path = "../schema" }
|
||||
service_common = { path = "../service_common" }
|
||||
trace = { path = "../trace"}
|
||||
trace_http = { path = "../trace_http"}
|
||||
|
|
@ -23,7 +22,6 @@ tracker = { path = "../tracker" }
|
|||
|
||||
# Crates.io dependencies, in alphabetical order
|
||||
arrow = { workspace = true, features = ["prettyprint"] }
|
||||
async-trait = "0.1"
|
||||
futures = "0.3"
|
||||
pin-project = "1.1"
|
||||
prost = "0.11"
|
||||
|
|
@ -31,7 +29,6 @@ regex = "1.8.2"
|
|||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = "1.0.96"
|
||||
snafu = "0.7"
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
tokio-stream = { version = "0.1", features = ["net"] }
|
||||
tonic = { workspace = true }
|
||||
workspace-hack = { version = "0.1", path = "../workspace-hack" }
|
||||
|
|
@ -43,10 +40,11 @@ influxdb_storage_client = { path = "../influxdb_storage_client" }
|
|||
metric = { path = "../metric" }
|
||||
panic_logging = { path = "../panic_logging" }
|
||||
procspawn = { version = "0.10", default-features = false, features = ["test-support", "safe-shared-libraries"] }
|
||||
schema = { path = "../schema" }
|
||||
service_grpc_testing = { path = "../service_grpc_testing" }
|
||||
test_helpers = { path = "../test_helpers" }
|
||||
trace_http = { path = "../trace_http" }
|
||||
service_grpc_testing = { path = "../service_grpc_testing" }
|
||||
|
||||
# Crates.io dependencies, in alphabetical order
|
||||
parking_lot = "0.12"
|
||||
serde_urlencoded = "0.7.0"
|
||||
tokio = { version = "1.28", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
|
||||
|
|
|
|||
|
|
@ -456,6 +456,7 @@ impl InListBuilder {
|
|||
/// Decoded special tag key.
|
||||
///
|
||||
/// The storage gRPC layer uses magic special bytes to encode measurement name and field name as tag
|
||||
#[derive(Debug)]
|
||||
pub enum DecodedTagKey {
|
||||
Measurement,
|
||||
Field,
|
||||
|
|
|
|||
|
|
@ -1,4 +1,22 @@
|
|||
//! This module contains gRPC service implementation for "InfluxRPC" (aka the storage RPC API used for Flux and InfluxQL)
|
||||
//! This module contains gRPC service implementation for "InfluxRPC" (aka the
|
||||
//! storage RPC API used for Flux and InfluxQL)
|
||||
|
||||
#![deny(rustdoc::broken_intra_doc_links, rustdoc::bare_urls, rust_2018_idioms)]
|
||||
#![allow(clippy::clone_on_ref_ptr)]
|
||||
#![warn(
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
clippy::explicit_iter_loop,
|
||||
// See https://github.com/influxdata/influxdb_iox/pull/1671
|
||||
clippy::future_not_send,
|
||||
clippy::clone_on_ref_ptr,
|
||||
clippy::todo,
|
||||
clippy::dbg_macro,
|
||||
unused_crate_dependencies
|
||||
)]
|
||||
|
||||
// Workaround for "unused crate" lint false positives.
|
||||
use workspace_hack as _;
|
||||
|
||||
/// `[0x00]` is the magic value that that the storage gRPC layer uses to
|
||||
/// encode a tag_key that means "measurement name"
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue