Struct Client 

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn new(addrs: Vec<&str>) -> Result<Client>

pub async fn create_stream(&self, subject: &str, name: &str) -> Result<()>

pub async fn delete_stream(&self, name: &str) -> Result<()>

pub async fn pause_stream( &self, name: &str, options: PauseOptions, ) -> Result<()>

pub async fn subscribe<'a>( &'a self, stream: &'a str, options: SubscriptionOptions, ) -> Result<Subscription<'a>>

pub async fn fetch_metadata(&self)

pub async fn publish(&self, stream: &str, value: Vec<u8>) -> Result<()>