Struct NatsConnection 

pub struct NatsConnection { /* private fields */ }

NATS JetStream KV connection.

Implementations

impl NatsConnection

pub fn new(config: NatsConnectionConfig) -> Self

pub fn from_client(client: Client) -> Self

Create a NatsConnection from an existing NATS client.

This is useful when the caller already has a NATS connection and wants to reuse it for KV stores instead of creating a new connection.

Trait Implementations

impl Connection for NatsConnection

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), KvError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the store.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), KvError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Graceful shutdown.

fn is_healthy(&self) -> bool

Health check - fast, non-blocking.

fn store<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn KvStore>, KvError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get or create a named store with default configuration.

fn store_with_config<'life0, 'async_trait>( &'life0 self, config: StoreConfig, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn KvStore>, KvError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get or create a named store with custom configuration.

fn capabilities(&self) -> ConnectionCapabilities

Store capabilities for runtime feature detection.

impl Debug for NatsConnection

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

Formats the value using the given formatter.