Skip to content

Commit

Permalink
Use i64 instead of isize for representing Go's time.Duration type
Browse files Browse the repository at this point in the history
  • Loading branch information
spacejam committed Sep 1, 2021
1 parent c358859 commit d671f06
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/jetstream_types.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit d671f06

Please sign in to comment.