NATS Client

A simple, developer-friendly NATS client designed with an ergonomic API designed to allow you to use this client anywhere, whether you're using tokio or single-threaded apps or traditional multi-threaded.

Usage

The following sample illustrates basic publish and subscribe features:

let jwt = "...";
let seed = "...";
    
let opts = ClientOptions::builder()
    .cluster_uris(vec!["nats://localhost:4222".into()])
    .authentication(AuthenticationStyle::UserCredentials(
        jwt.to_string(),
        seed.to_string(),
    ))
    .build()?;

let client = Client::from_options(opts)?;
client.connect()?;

client.subscribe("ticker", move |msg| {
    let symbol: SymbolReply = serde_json::from_slice(&msg.payload).unwrap();
    info!("Received stock ticker: {:?}", symbol);
    Ok(())
})?;

To publish a message:

c.publish(&r, payload_bytes, None)?;

And to utilize the request/response pattern:

 let reply = client.request(
    "symbolquery",
    r#"{"symbol": "NATS"}"#.as_bytes(),
    Duration::from_millis(100),
)?;

let symbol: SymbolReply = serde_json::from_slice(&reply.payload).unwrap();
info!("Stock symbol response: {:?}", symbol);

Features

The following is a list of features currently supported and planned by this client:

• - Request/Reply
• - Subscribe
• - Publish
• - All authentication models, including NATS 2.0 JWT and seed keys
• - Adherance to protocol v1, accepts new server information whenever it's sent from NATS
• - Automatic reconnect upon connection failure
• - TLS support
• - NATS Streaming (STAN)