watermelon 0.4.4

High level actor based implementation NATS Core and NATS Jetstream client implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

#![forbid(unsafe_code)]

pub use watermelon_proto as proto;

mod client;
mod handler;
mod multiplexed_subscription;
mod subscription;
#[cfg(test)]
pub(crate) mod tests;
mod util;

pub mod core {
    //! NATS Core functionality implementation

    pub use crate::client::{Client, ClientBuilder, Echo, QuickInfo};
    pub(crate) use crate::multiplexed_subscription::MultiplexedSubscription;
    pub use crate::subscription::Subscription;
    pub use watermelon_mini::AuthenticationMethod;

    pub mod publish {
        //! Utilities for publishing messages

        pub use crate::client::{
            ClientPublish, DoClientPublish, DoOwnedClientPublish, OwnedClientPublish, Publish,
            PublishBuilder,
        };
    }

    pub mod request {
        //! Utilities for publishing messages and awaiting for a response

        pub use crate::client::{
            ClientRequest, DoClientRequest, DoOwnedClientRequest, OwnedClientRequest, Request,
            RequestBuilder, ResponseFut,
        };
    }

    pub mod error {
        //! NATS Core specific errors

        pub use crate::{
            client::{ClientClosedError, ResponseError, TryCommandError},
            handler::ConnectHandlerError,
        };
        pub use watermelon_mini::ConnectError;
    }
}

pub mod jetstream {
    //! NATS Jetstream functionality implementation
    //!
    //! Relies on NATS Core to communicate with the NATS server

    pub use crate::client::{
        AckPolicy, Compression, Consumer, ConsumerBatch, ConsumerConfig, ConsumerDurability,
        ConsumerSpecificConfig, ConsumerStorage, ConsumerStream, Consumers, DeliverPolicy,
        DiscardPolicy, JetstreamClient, ReplayPolicy, RetentionPolicy, Storage, Stream,
        StreamConfig, StreamState, Streams,
    };

    pub mod error {
        //! NATS Jetstream specific errors

        pub use crate::client::{
            ConsumerStreamError, JetstreamApiError, JetstreamError, JetstreamErrorCode,
        };
    }
}