From d671f06f64e8b487587fb83e726ceea413604ead Mon Sep 17 00:00:00 2001 From: Tyler Neely Date: Wed, 1 Sep 2021 14:02:05 +0200 Subject: [PATCH] Use i64 instead of isize for representing Go's time.Duration type --- src/jetstream_types.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/jetstream_types.rs b/src/jetstream_types.rs index 291c37546..2a41bdbe8 100644 --- a/src/jetstream_types.rs +++ b/src/jetstream_types.rs @@ -99,7 +99,7 @@ pub struct ConsumerConfig { pub ack_policy: AckPolicy, /// How long to allow messages to remain un-acknowledged before attempting redelivery #[serde(default, skip_serializing_if = "is_default")] - pub ack_wait: isize, + pub ack_wait: i64, /// Maximum number of times a specific message will be delivered. Use this to avoid poison pill messages that repeatedly crash your consumer processes forever. #[serde(default, skip_serializing_if = "is_default")] pub max_deliver: i64, @@ -551,7 +551,7 @@ pub(crate) struct SubOpts { /// Options for publishing #[derive(Debug, Default, Serialize, Deserialize, Clone)] pub(crate) struct PubOpts { - pub ttl: isize, + pub ttl: i64, pub id: String, // Expected last msgId pub lid: String,