feat: update deps

Signed-off-by: kjuulh <contact@kjuulh.io>
This commit is contained in:
Kasper Juul Hermansen 2023-09-24 22:09:36 +02:00
parent 8a6e5c7ac0
commit 8beaeb53d7
Signed by: kjuulh
GPG Key ID: 9AA7BC13CE474394
7 changed files with 24 additions and 20 deletions

2
Cargo.lock generated
View File

@ -596,7 +596,7 @@ dependencies = [
"anyhow", "anyhow",
"async-trait", "async-trait",
"futures", "futures",
"prost 0.12.1", "prost",
"thiserror", "thiserror",
"tokio", "tokio",
"uuid", "uuid",

View File

@ -10,7 +10,7 @@ name = "envelope_benchmark"
harness = false harness = false
[features] [features]
default = ["proto", "capnp"] default = ["proto"]
json = ["dep:serde", "dep:serde_json", "dep:base64"] json = ["dep:serde", "dep:serde_json", "dep:base64"]
proto = ["dep:prost", "dep:prost-types", "dep:bytes"] proto = ["dep:prost", "dep:prost-types", "dep:bytes"]
capnp = ["dep:capnp"] capnp = ["dep:capnp"]

View File

@ -1,18 +1,20 @@
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct Envelope { pub struct Envelope {
#[prost(message, optional, tag="1")] #[prost(message, optional, tag = "1")]
pub metadata: ::std::option::Option<Metadata>, pub metadata: ::core::option::Option<Metadata>,
#[prost(bytes, tag="2")] #[prost(bytes = "vec", tag = "2")]
pub content: std::vec::Vec<u8>, pub content: ::prost::alloc::vec::Vec<u8>,
} }
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct Metadata { pub struct Metadata {
#[prost(string, tag="1")] #[prost(string, tag = "1")]
pub domain: std::string::String, pub domain: ::prost::alloc::string::String,
#[prost(string, tag="2")] #[prost(string, tag = "2")]
pub entity: std::string::String, pub entity: ::prost::alloc::string::String,
#[prost(uint64, tag="3")] #[prost(uint64, tag = "3")]
pub timestamp: u64, pub timestamp: u64,
#[prost(uint64, tag="4")] #[prost(uint64, tag = "4")]
pub sequence: u64, pub sequence: u64,
} }

View File

@ -39,7 +39,7 @@ async fn main() -> anyhow::Result<()> {
tracing_subscriber::fmt::init(); tracing_subscriber::fmt::init();
// Remember to start nats via. docker first, or set equivalent settings as in `NatsConnectOptions` // Remember to start nats via. docker first, or set equivalent settings as in `NatsConnectOptions`
let crunch = crunch::builder::Builder::default() let crunch = crunch::Builder::default()
.with_nats_transport(NatsConnectOptions { .with_nats_transport(NatsConnectOptions {
host: "127.0.0.1:4222", host: "127.0.0.1:4222",
credentials: NatsConnectCredentials::UserPass { credentials: NatsConnectCredentials::UserPass {

View File

@ -6,7 +6,7 @@ edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies] [dependencies]
crunch = { workspace = true,default-features = false, features = ["in-memory"] } crunch = { workspace = true, features = ["in-memory"] }
tracing.workspace = true tracing.workspace = true
tokio.workspace = true tokio.workspace = true

View File

@ -1,5 +1,6 @@
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct MyInclude { pub struct MyInclude {
#[prost(string, tag="1")] #[prost(string, tag = "1")]
pub name: std::string::String, pub name: ::prost::alloc::string::String,
} }

View File

@ -1,7 +1,8 @@
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct MyEvent { pub struct MyEvent {
#[prost(string, tag="1")] #[prost(string, tag = "1")]
pub name: std::string::String, pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag="2")] #[prost(message, optional, tag = "2")]
pub include: ::std::option::Option<super::includes::my_include::MyInclude>, pub include: ::core::option::Option<super::includes::my_include::MyInclude>,
} }