Skip to content

Commit

Permalink
Rename some constants
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
  • Loading branch information
Jarema committed Jun 19, 2023
1 parent 455a5a5 commit cb3edc5
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 4 deletions.
2 changes: 1 addition & 1 deletion async-nats/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ once_cell = "1.17.1"
regex = "1.7.1"
serde = { version = "1.0.152", features = ["derive"] }
serde_json = "1.0.93"
serde_repr = "0.1.11"
serde_repr = "0.1.10"
http = "0.2.9"
tokio = { version = "1.25.0", features = ["macros", "rt", "fs", "net", "sync", "time", "io-util"] }
itoa = "1"
Expand Down
4 changes: 2 additions & 2 deletions async-nats/src/jetstream/errors.rs
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ impl ErrorCode {
pub const MAXIMUM_STREAMS_LIMIT: ErrorCode = ErrorCode(10027);

/// Stream mirrors can not have both start seq and start time configured
pub const MIRROR_WITH_START_SEQ_AND_TIME: ErrorCode = ErrorCode(10032);
pub const MIRROR_WITH_START_SEQUENCE_AND_TIME: ErrorCode = ErrorCode(10032);

/// Stream snapshot failed
pub const STREAM_SNAPSHOT: ErrorCode = ErrorCode(10064);
Expand Down Expand Up @@ -281,7 +281,7 @@ impl ErrorCode {
pub const CONSUMER_HEARTBEAT_REQUIRES_PUSH: ErrorCode = ErrorCode(10088);

/// Consumer flow control requires a push based consumer
pub const CONSUMER_FC_REQUIRES_PUSH: ErrorCode = ErrorCode(10089);
pub const CONSUMER_FLOW_CONTROL_REQUIRES_PUSH: ErrorCode = ErrorCode(10089);

/// Consumer direct requires a push based consumer
pub const CONSUMER_DIRECT_REQUIRES_PUSH: ErrorCode = ErrorCode(10090);
Expand Down
4 changes: 3 additions & 1 deletion async-nats/src/jetstream/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ use crate::Client;
pub mod account;
pub mod consumer;
pub mod context;
pub mod errors;
mod errors;
pub mod kv;
pub mod message;
pub mod object_store;
Expand All @@ -141,6 +141,8 @@ pub mod response;
pub mod stream;

pub use context::Context;
pub use errors::Error;
pub use errors::ErrorCode;
pub use message::{AckKind, Message};

/// Creates a new JetStream [Context] that provides JetStream API for managing and using [Streams][crate::jetstream::stream::Stream],
Expand Down

0 comments on commit cb3edc5

Please sign in to comment.