Skip to content

Commit 9d7d56d

Browse files
refactor!: rename JetstreamError to JetstreamApiError
1 parent 05649d5 commit 9d7d56d

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

watermelon/src/client/jetstream/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ pub struct JetstreamClient {
3838
/// A Jetstream API error
3939
#[derive(Debug, Deserialize, thiserror::Error)]
4040
#[error("jetstream error status={status} code={code} description={description}")]
41-
pub struct JetstreamError {
41+
pub struct JetstreamApiError {
4242
#[serde(rename = "code")]
4343
status: StatusCode,
4444
#[serde(rename = "err_code")]
@@ -63,7 +63,7 @@ pub enum JetstreamError2 {
6363
#[error("JSON deserialization")]
6464
Json(#[source] serde_json::Error),
6565
#[error("bad response code")]
66-
Status(#[source] JetstreamError),
66+
Status(#[source] JetstreamApiError),
6767
}
6868

6969
impl JetstreamClient {

watermelon/src/client/jetstream/resources/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ pub use self::stream::{
88
Compression, DiscardPolicy, RetentionPolicy, Storage, Stream, StreamConfig, StreamState,
99
};
1010

11-
use super::JetstreamError;
11+
use super::JetstreamApiError;
1212

1313
mod consumer;
1414
mod stream;
@@ -17,7 +17,7 @@ mod stream;
1717
#[serde(untagged)]
1818
pub(crate) enum Response<T> {
1919
Response(T),
20-
Error { error: JetstreamError },
20+
Error { error: JetstreamApiError },
2121
}
2222

2323
mod nullable_number {

watermelon/src/client/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ pub use self::commands::{
2828
pub use self::jetstream::{
2929
AckPolicy, Compression, Consumer, ConsumerBatch, ConsumerConfig, ConsumerDurability,
3030
ConsumerSpecificConfig, ConsumerStorage, ConsumerStream, ConsumerStreamError, Consumers,
31-
DeliverPolicy, DiscardPolicy, JetstreamClient, JetstreamError, JetstreamError2,
31+
DeliverPolicy, DiscardPolicy, JetstreamApiError, JetstreamClient, JetstreamError2,
3232
JetstreamErrorCode, ReplayPolicy, RetentionPolicy, Storage, Stream, StreamConfig, StreamState,
3333
Streams,
3434
};

watermelon/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ pub mod jetstream {
6363
//! NATS Jetstream specific errors
6464
6565
pub use crate::client::{
66-
ConsumerStreamError, JetstreamError, JetstreamError2, JetstreamErrorCode,
66+
ConsumerStreamError, JetstreamApiError, JetstreamError2, JetstreamErrorCode,
6767
};
6868
}
6969
}

0 commit comments

Comments
 (0)