Struct NatsClient

pub struct NatsClient {
    pub nats_client: Client,
    pub jetstream: JetStreamContext,
    pub namespace: NatsNamespace,
    pub opts: NatsClientOpts,
}

NatsClient is a wrapper around the NATS client that provides additional functionality geared towards fuel-streaming use-cases

Examples

Creating a new NatsClient:

use fuel_streams_core::prelude::*;

async fn example() -> BoxedResult<()> {
    let opts = NatsClientOpts::new("nats://localhost:4222");
    let client = NatsClient::connect(&opts).await?;
    Ok(())
}

Creating a key-value store:

use fuel_streams_core::prelude::*;
use async_nats::jetstream::kv;

async fn example() -> BoxedResult<()> {
    let opts = NatsClientOpts::new("nats://localhost:4222");
    let client = NatsClient::connect(&opts).await?;
    let kv_config = kv::Config {
        bucket: "my-bucket".into(),
        ..Default::default()
    };

    let store = client.get_or_create_kv_store(kv_config).await?;
    Ok(())
}

Fields

nats_client: Client

The underlying NATS client

jetstream: JetStreamContext

The JetStream context for this client

namespace: NatsNamespace

The namespace used for this client

opts: NatsClientOpts

The options used to create this client

Implementations

impl NatsClient

pub async fn connect(opts: &NatsClientOpts) -> Result<Self, NatsError>

pub async fn get_or_create_kv_store( &self, options: Config, ) -> Result<Store, Error<CreateKeyValueErrorKind>>

pub fn is_connected(&self) -> bool

Trait Implementations

impl Clone for NatsClient

fn clone(&self) -> NatsClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NatsClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.