diff --git a/Cargo.toml b/Cargo.toml index 61ad7e9..da61fa7 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -8,7 +8,7 @@ repository = "https://github.com/restatedev/sdk-shared-core" [dependencies] thiserror = "1.0.61" -prost = "0.13" +prost = "0.13.2" bytes = "1.6" bytes-utils = "0.1.4" ambassador = "0.4.0" @@ -27,4 +27,4 @@ http = { version = "1.1.0", optional = true } googletest = "0.11.0" test-log = { version = "0.2.16", default-features = false, features = ["trace", "color"] } assert2 = "0.3.14" -prost-build = "0.13" +prost-build = "0.13.2" diff --git a/src/service_protocol/generated/dev.restate.service.protocol.rs b/src/service_protocol/generated/dev.restate.service.protocol.rs index 86a8f6b..b6f9c69 100644 --- a/src/service_protocol/generated/dev.restate.service.protocol.rs +++ b/src/service_protocol/generated/dev.restate.service.protocol.rs @@ -1,6 +1,5 @@ // This file is @generated by prost-build. /// Type: 0x0000 + 0 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct StartMessage { /// Unique id of the invocation. This id is unique across invocations and won't change when replaying the journal. @@ -35,7 +34,6 @@ pub struct StartMessage { } /// Nested message and enum types in `StartMessage`. pub mod start_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct StateEntry { #[prost(bytes = "bytes", tag = "1")] @@ -47,7 +45,6 @@ pub mod start_message { } } /// Type: 0x0000 + 1 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CompletionMessage { #[prost(uint32, tag = "1")] @@ -57,7 +54,6 @@ pub struct CompletionMessage { } /// Nested message and enum types in `CompletionMessage`. pub mod completion_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(message, tag = "13")] @@ -70,7 +66,6 @@ pub mod completion_message { } /// Type: 0x0000 + 2 /// Implementations MUST send this message when suspending an invocation. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SuspensionMessage { /// This list represents any of the entry_index the invocation is waiting on to progress. @@ -84,7 +79,6 @@ pub struct SuspensionMessage { pub entry_indexes: ::prost::alloc::vec::Vec, } /// Type: 0x0000 + 3 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ErrorMessage { /// The code can be any HTTP status code, as described @@ -115,7 +109,6 @@ pub struct ErrorMessage { pub next_retry_delay: ::core::option::Option, } /// Type: 0x0000 + 4 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct EntryAckMessage { #[prost(uint32, tag = "1")] @@ -123,13 +116,11 @@ pub struct EntryAckMessage { } /// Type: 0x0000 + 5 /// Implementations MUST send this message when the invocation lifecycle ends. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct EndMessage {} /// Completable: No /// Fallible: No /// Type: 0x0400 + 0 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct InputEntryMessage { #[prost(message, repeated, tag = "1")] @@ -143,7 +134,6 @@ pub struct InputEntryMessage { /// Completable: No /// Fallible: No /// Type: 0x0400 + 1 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OutputEntryMessage { /// Entry name @@ -154,7 +144,6 @@ pub struct OutputEntryMessage { } /// Nested message and enum types in `OutputEntryMessage`. pub mod output_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -166,7 +155,6 @@ pub mod output_entry_message { /// Completable: Yes /// Fallible: No /// Type: 0x0800 + 0 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetStateEntryMessage { #[prost(bytes = "bytes", tag = "1")] @@ -179,7 +167,6 @@ pub struct GetStateEntryMessage { } /// Nested message and enum types in `GetStateEntryMessage`. pub mod get_state_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(message, tag = "13")] @@ -193,7 +180,6 @@ pub mod get_state_entry_message { /// Completable: No /// Fallible: No /// Type: 0x0800 + 1 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SetStateEntryMessage { #[prost(bytes = "bytes", tag = "1")] @@ -207,7 +193,6 @@ pub struct SetStateEntryMessage { /// Completable: No /// Fallible: No /// Type: 0x0800 + 2 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ClearStateEntryMessage { #[prost(bytes = "bytes", tag = "1")] @@ -219,7 +204,6 @@ pub struct ClearStateEntryMessage { /// Completable: No /// Fallible: No /// Type: 0x0800 + 3 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ClearAllStateEntryMessage { /// Entry name @@ -229,7 +213,6 @@ pub struct ClearAllStateEntryMessage { /// Completable: Yes /// Fallible: No /// Type: 0x0800 + 4 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetStateKeysEntryMessage { /// Entry name @@ -240,13 +223,11 @@ pub struct GetStateKeysEntryMessage { } /// Nested message and enum types in `GetStateKeysEntryMessage`. pub mod get_state_keys_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct StateKeys { #[prost(bytes = "bytes", repeated, tag = "1")] pub keys: ::prost::alloc::vec::Vec<::prost::bytes::Bytes>, } - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(message, tag = "14")] @@ -258,7 +239,6 @@ pub mod get_state_keys_entry_message { /// Completable: Yes /// Fallible: No /// Type: 0x0800 + 8 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetPromiseEntryMessage { #[prost(string, tag = "1")] @@ -271,7 +251,6 @@ pub struct GetPromiseEntryMessage { } /// Nested message and enum types in `GetPromiseEntryMessage`. pub mod get_promise_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -283,7 +262,6 @@ pub mod get_promise_entry_message { /// Completable: Yes /// Fallible: No /// Type: 0x0800 + 9 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct PeekPromiseEntryMessage { #[prost(string, tag = "1")] @@ -296,7 +274,6 @@ pub struct PeekPromiseEntryMessage { } /// Nested message and enum types in `PeekPromiseEntryMessage`. pub mod peek_promise_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(message, tag = "13")] @@ -310,7 +287,6 @@ pub mod peek_promise_entry_message { /// Completable: Yes /// Fallible: No /// Type: 0x0800 + A -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CompletePromiseEntryMessage { #[prost(string, tag = "1")] @@ -327,7 +303,6 @@ pub struct CompletePromiseEntryMessage { /// Nested message and enum types in `CompletePromiseEntryMessage`. pub mod complete_promise_entry_message { /// The value to use to complete the promise - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Completion { #[prost(bytes, tag = "2")] @@ -335,7 +310,6 @@ pub mod complete_promise_entry_message { #[prost(message, tag = "3")] CompletionFailure(super::Failure), } - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { /// Returns empty if value was set successfully @@ -349,7 +323,6 @@ pub mod complete_promise_entry_message { /// Completable: Yes /// Fallible: No /// Type: 0x0C00 + 0 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SleepEntryMessage { /// Wake up time. @@ -364,7 +337,6 @@ pub struct SleepEntryMessage { } /// Nested message and enum types in `SleepEntryMessage`. pub mod sleep_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(message, tag = "13")] @@ -376,7 +348,6 @@ pub mod sleep_entry_message { /// Completable: Yes /// Fallible: Yes /// Type: 0x0C00 + 1 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CallEntryMessage { #[prost(string, tag = "1")] @@ -398,7 +369,6 @@ pub struct CallEntryMessage { } /// Nested message and enum types in `CallEntryMessage`. pub mod call_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -410,7 +380,6 @@ pub mod call_entry_message { /// Completable: No /// Fallible: Yes /// Type: 0x0C00 + 2 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OneWayCallEntryMessage { #[prost(string, tag = "1")] @@ -438,7 +407,6 @@ pub struct OneWayCallEntryMessage { /// Fallible: No /// Type: 0x0C00 + 3 /// Awakeables are addressed by an identifier exposed to the user. See the spec for more details. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct AwakeableEntryMessage { /// Entry name @@ -449,7 +417,6 @@ pub struct AwakeableEntryMessage { } /// Nested message and enum types in `AwakeableEntryMessage`. pub mod awakeable_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -461,7 +428,6 @@ pub mod awakeable_entry_message { /// Completable: No /// Fallible: Yes /// Type: 0x0C00 + 4 -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CompleteAwakeableEntryMessage { /// Identifier of the awakeable. See the spec for more details. @@ -475,7 +441,6 @@ pub struct CompleteAwakeableEntryMessage { } /// Nested message and enum types in `CompleteAwakeableEntryMessage`. pub mod complete_awakeable_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -488,7 +453,6 @@ pub mod complete_awakeable_entry_message { /// Fallible: No /// Type: 0x0C00 + 5 /// Flag: RequiresRuntimeAck -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct RunEntryMessage { /// Entry name @@ -499,7 +463,6 @@ pub struct RunEntryMessage { } /// Nested message and enum types in `RunEntryMessage`. pub mod run_entry_message { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { #[prost(bytes, tag = "14")] @@ -510,7 +473,6 @@ pub mod run_entry_message { } /// This failure object carries user visible errors, /// e.g. invocation failure return value or failure result of an InvokeEntryMessage. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Failure { /// The code can be any HTTP status code, as described @@ -520,7 +482,6 @@ pub struct Failure { #[prost(string, tag = "2")] pub message: ::prost::alloc::string::String, } -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Header { #[prost(string, tag = "1")] @@ -528,7 +489,6 @@ pub struct Header { #[prost(string, tag = "2")] pub value: ::prost::alloc::string::String, } -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct Empty {} /// Service protocol version.