Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
489 changes: 321 additions & 168 deletions Cargo.lock

Large diffs are not rendered by default.

30 changes: 14 additions & 16 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ resolver = "2"
version = "1.6.0-dev"
authors = ["restate.dev"]
edition = "2024"
rust-version = "1.88.0"
rust-version = "1.90.0"
license = "BUSL-1.1"
repository = "https://github.com/restatedev/restate"
homepage = "https://github.com/restatedev/restate"
Expand Down Expand Up @@ -133,11 +133,11 @@ datafusion = { version = "50.0.0", default-features = false, features = [
datafusion-expr = { version = "50.0.0" }
derive_builder = "0.20.0"
derive_more = { version = "2.0.1", features = ["full"] }
dialoguer = { version = "0.11.0" }
dialoguer = { version = "0.12.0" }
downcast-rs = { version = "2.0.1" }
enum-map = { version = "2.7.3" }
enumset = { version = "1.1.3" }
etcd-client = { version = "0.14" }
etcd-client = { version = "0.17" }
flexbuffers = { version = "25.2.10" }
futures = "0.3.25"
futures-sink = "0.3.25"
Expand Down Expand Up @@ -173,24 +173,23 @@ moka = "0.12.5"
mockall = { version = "0.13.1" }
num-traits = { version = "0.2.17" }
object_store = { version = "0.12.4", features = ["aws", "azure", "gcp"] }
opentelemetry = { version = "0.30" }
opentelemetry-contrib = { version = "0.22" }
opentelemetry-http = { version = "0.30" }
opentelemetry-otlp = { version = "0.30" }
opentelemetry-semantic-conventions = { version = "0.30" }
opentelemetry_sdk = { version = "0.30" }
opentelemetry = { version = "0.31" }
opentelemetry-contrib = { version = "0.23" }
opentelemetry-http = { version = "0.31" }
opentelemetry-otlp = { version = "0.31" }
opentelemetry-semantic-conventions = { version = "0.31" }
opentelemetry_sdk = { version = "0.31" }
parking_lot = { version = "0.12" }
paste = "1.0"
pin-project = "1.0"
pin-project-lite = { version = "0.2" }
prost = { version = "0.14.1" }
prost-build = { version = "0.14.1" }
priority-queue = "2.0.3"
prost-dto = { version = "0.0.3" }
priority-queue = { version = "2.7.0" }
prost-dto = { version = "0.0.4" }
prost-types = { version = "0.14.1" }
rand = "0.9.0"
rangemap = "1.5.1"
rayon = { version = "1.10" }
regex = { version = "1.11" }
reqwest = { version = "0.12", default-features = false, features = [
"json",
Expand All @@ -214,7 +213,6 @@ sha2 = "0.10.8"
smartstring = { version = "1.0.1" }
static_assertions = { version = "1.1.0" }
strum = { version = "0.27.1", features = ["derive"] }
sync_wrapper = "1.0.1"
smallvec = { version = "1.15.1", features = ["serde", "union"] }
tempfile = "3.6.0"
test-log = { version = "0.2.11", default-features = false, features = [
Expand All @@ -234,7 +232,7 @@ tokio = { version = "1.47.0", default-features = false, features = [
] }
tokio-stream = "0.1.17"
tokio-util = { version = "0.7.14" }
toml = { version = "0.8.23" }
toml = { version = "0.9" }
tonic = { version = "0.14.2", default-features = false }
tonic-reflection = { version = "0.14.2" }
tonic-health = { version = "0.14.2" }
Expand All @@ -243,14 +241,14 @@ tonic-prost-build = { version = "0.14.2" }
tower = "0.5.2"
tower-http = { version = "0.6.2", default-features = false }
tracing = { version = "0.1" }
tracing-opentelemetry = { version = "0.31.0" }
tracing-opentelemetry = { version = "0.32.0" }
tracing-subscriber = { version = "0.3", features = [
"env-filter",
"fmt",
"parking_lot",
] }
tracing-test = { version = "0.2.5" }
typed-builder = "0.21.0"
typed-builder = "0.23.0"
ulid = { version = "1.2.0" }
url = { version = "2.5" }
urlencoding = { version = "2.1" }
Expand Down
5 changes: 4 additions & 1 deletion crates/cli-util/src/ui/console.rs
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,10 @@ pub fn confirm_or_exit(prompt: &str) -> anyhow::Result<()> {
Ok(())
}

pub fn choose<T: ToString>(prompt: &str, choices: &[T]) -> anyhow::Result<usize> {
pub fn choose<T: ToString + std::fmt::Display>(
prompt: &str,
choices: &[T],
) -> anyhow::Result<usize> {
let theme = dialoguer::theme::ColorfulTheme::default();
Ok(dialoguer::Select::with_theme(&theme)
.with_prompt(prompt)
Expand Down
4 changes: 2 additions & 2 deletions crates/core/src/network/incoming.rs
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ impl<M> Incoming<M> {
/// incoming message, use [`Self::parent_context()`] instead
pub fn follow_from_sender(&mut self) {
if let Some(context) = self.parent_context.take() {
Span::current().set_parent(context)
let _ = Span::current().set_parent(context);
}
}

Expand All @@ -91,7 +91,7 @@ impl<M> Incoming<M> {
/// incoming message, use [`Self::parent_context()`] instead
pub fn follow_from_sender_for(&mut self, span: &Span) {
if let Some(context) = self.parent_context.take() {
span.set_parent(context)
let _ = span.set_parent(context);
}
}
}
Expand Down
4 changes: 2 additions & 2 deletions crates/timer/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ restate-workspace-hack = { workspace = true }

restate-types = { workspace = true }

ahash = "0.8.3"
ahash = { workspace = true }
pin-project = { workspace = true }
priority-queue = { workspace = true }
schemars = { workspace = true, optional = true }
Expand All @@ -29,4 +29,4 @@ restate-test-util = { workspace = true }

futures-util = { workspace = true }
tracing-subscriber = { workspace = true }
test-log = { workspace = true }
test-log = { workspace = true }
3 changes: 1 addition & 2 deletions crates/tracing-instrumentation/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,7 @@ reqwest = { workspace = true }
schemars = { workspace = true, optional = true }
thiserror = { workspace = true }
tokio = { workspace = true, optional = true }
# using version 0.13.1 which is required by opentelemetry-otlp
tonic = { version = "0.13.1", features = ["tls-native-roots"]}
tonic = { workspace = true, features = ["tls-native-roots"]}
tracing = { workspace = true }
tracing-appender = { version = "0.2.3", features = ["parking_lot"] }
tracing-core = { version = "0.1" }
Expand Down
3 changes: 1 addition & 2 deletions crates/types/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ listenfd = { version = "1" }
metrics = { workspace = true }
moka = { workspace = true, features = ["sync", "logging"] }
notify = { version = "8.0.0" }
notify-debouncer-full = { version = "0.5" }
notify-debouncer-full = { version = "0.6" }
num-traits = { workspace = true }
opentelemetry = { workspace = true , features = ["trace"]}
parking_lot = { workspace = true }
Expand All @@ -88,7 +88,6 @@ smallvec = { workspace = true }
smartstring = { workspace = true, features = ["serde"]}
static_assertions = { workspace = true }
strum = { workspace = true }
sync_wrapper = { workspace = true }
tempfile = { workspace = true, optional = true }
thiserror = { workspace = true }
tiny-gradient = { version = "0.1.0" }
Expand Down
9 changes: 0 additions & 9 deletions crates/types/src/errors.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
// the Business Source License, use of this software will be governed
// by the Apache License, Version 2.0.

use std::any::Any;
use std::borrow::Cow;
use std::convert::Into;
use std::fmt;
Expand Down Expand Up @@ -381,14 +380,6 @@ pub enum IdDecodeError {
UnrecognizedType(String),
}

#[derive(Debug, thiserror::Error)]
pub enum ThreadJoinError {
#[error("thread panicked: {0:?}")]
Panic(sync_wrapper::SyncWrapper<Box<dyn Any + Send + 'static>>),
#[error("thread terminated unexpectedly")]
UnexpectedTermination,
}

#[derive(Debug, thiserror::Error)]
pub enum ConversionError {
#[error("missing field '{0}'")]
Expand Down
10 changes: 0 additions & 10 deletions crates/worker/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -91,16 +91,6 @@ pub enum BuildError {
SnapshotRepository(#[from] anyhow::Error),
}

#[derive(Debug, thiserror::Error, CodedError)]
pub enum Error {
#[error("thread '{thread}' panicked: {cause}")]
#[code(unknown)]
ThreadPanic {
thread: &'static str,
cause: restate_types::errors::ThreadJoinError,
},
}

pub struct Worker {
storage_query_context: QueryContext,
datafusion_remote_scanner: RemoteQueryScannerServer,
Expand Down
20 changes: 10 additions & 10 deletions workspace-hack/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -87,12 +87,12 @@ num-bigint = { version = "0.4" }
num-integer = { version = "0.1", features = ["i128"] }
num-traits = { version = "0.2", features = ["i128", "libm"] }
object_store = { version = "0.12", features = ["aws", "azure", "gcp"] }
opentelemetry_sdk = { version = "0.30", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
opentelemetry = { version = "0.31" }
opentelemetry_sdk = { version = "0.31", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
phf_shared = { version = "0.11" }
pprof = { version = "0.15", features = ["criterion", "flamegraph", "frame-pointer"] }
proc-macro2 = { version = "1" }
prost-582f2526e08bb6a0 = { package = "prost", version = "0.14" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["prost-derive"] }
prost-types = { version = "0.14" }
protobuf = { version = "2", default-features = false, features = ["with-bytes"] }
quanta = { version = "0.12" }
Expand Down Expand Up @@ -124,7 +124,7 @@ tokio-stream = { version = "0.1", features = ["net", "sync"] }
tokio-util = { version = "0.7", features = ["codec", "io-util", "net", "rt"] }
toml_datetime = { version = "0.6", default-features = false, features = ["serde"] }
toml_edit = { version = "0.22", features = ["serde"] }
tonic = { version = "0.14", default-features = false, features = ["codegen", "gzip", "router", "transport", "zstd"] }
tonic = { version = "0.14", features = ["gzip", "tls-native-roots", "tls-ring", "zstd"] }
tower-9fbad63c4bcf4a8f = { package = "tower", version = "0.4", features = ["balance", "buffer", "limit", "util"] }
tower-d8f496e17d97b5cb = { package = "tower", version = "0.5", default-features = false, features = ["balance", "buffer", "limit", "load-shed", "log", "retry", "timeout"] }
tower-http = { version = "0.6", features = ["cors", "follow-redirect", "map-response-body", "normalize-path", "trace"] }
Expand Down Expand Up @@ -216,12 +216,12 @@ num-bigint = { version = "0.4" }
num-integer = { version = "0.1", features = ["i128"] }
num-traits = { version = "0.2", features = ["i128", "libm"] }
object_store = { version = "0.12", features = ["aws", "azure", "gcp"] }
opentelemetry_sdk = { version = "0.30", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
opentelemetry = { version = "0.31" }
opentelemetry_sdk = { version = "0.31", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
phf_shared = { version = "0.11" }
pprof = { version = "0.15", features = ["criterion", "flamegraph", "frame-pointer"] }
proc-macro2 = { version = "1" }
prost-582f2526e08bb6a0 = { package = "prost", version = "0.14" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["prost-derive"] }
prost-build = { version = "0.14", features = ["cleanup-markdown"] }
prost-types = { version = "0.14" }
protobuf = { version = "2", default-features = false, features = ["with-bytes"] }
Expand Down Expand Up @@ -255,7 +255,7 @@ tokio-stream = { version = "0.1", features = ["net", "sync"] }
tokio-util = { version = "0.7", features = ["codec", "io-util", "net", "rt"] }
toml_datetime = { version = "0.6", default-features = false, features = ["serde"] }
toml_edit = { version = "0.22", features = ["serde"] }
tonic = { version = "0.14", default-features = false, features = ["codegen", "gzip", "router", "transport", "zstd"] }
tonic = { version = "0.14", features = ["gzip", "tls-native-roots", "tls-ring", "zstd"] }
tower-9fbad63c4bcf4a8f = { package = "tower", version = "0.4", features = ["balance", "buffer", "limit", "util"] }
tower-d8f496e17d97b5cb = { package = "tower", version = "0.5", default-features = false, features = ["balance", "buffer", "limit", "load-shed", "log", "retry", "timeout"] }
tower-http = { version = "0.6", features = ["cors", "follow-redirect", "map-response-body", "normalize-path", "trace"] }
Expand All @@ -280,7 +280,7 @@ libc = { version = "0.2", default-features = false, features = ["use_std"] }
mio = { version = "1", features = ["net", "os-ext"] }
nix = { version = "0.29", features = ["fs", "signal"] }
num = { version = "0.4" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }

Expand All @@ -292,7 +292,7 @@ libc = { version = "0.2", default-features = false, features = ["use_std"] }
mio = { version = "1", features = ["net", "os-ext"] }
nix = { version = "0.29", features = ["fs", "signal"] }
num = { version = "0.4" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }

Expand All @@ -303,7 +303,7 @@ hyper-util = { version = "0.1", default-features = false, features = ["client-pr
libc = { version = "0.2", default-features = false, features = ["use_std"] }
nix = { version = "0.29", features = ["fs", "signal"] }
num = { version = "0.4" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }

Expand All @@ -314,7 +314,7 @@ hyper-util = { version = "0.1", default-features = false, features = ["client-pr
libc = { version = "0.2", default-features = false, features = ["use_std"] }
nix = { version = "0.29", features = ["fs", "signal"] }
num = { version = "0.4" }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }

Expand Down
Loading