Struct ratsio::stan_client::StanClient

pub struct StanClient {
    pub options: StanOptions,
    pub nats_client: Arc<NatsClient>,
    pub client_id: String,
    // some fields omitted
}

Fields

options: StanOptions

nats_client: Arc<NatsClient>

client_id: String

Implementations

impl StanClient

pub async fn from_options(
    options: StanOptions
) -> Result<Arc<Self>, RatsioError>

pub async fn subscribe<T>(
    &self,
    subject: T,
    queue_group: Option<T>,
    durable_name: Option<T>
) -> Result<(StanSid, impl Stream<Item = StanMessage> + Send + Sync), RatsioError> where
    T: ToString, 

pub async fn subscribe_with_manual_ack<T>(
    &self,
    subject: T,
    queue_group: Option<T>,
    durable_name: Option<T>
) -> Result<(StanSid, impl Stream<Item = StanMessage> + Send + Sync), RatsioError> where
    T: ToString, 

pub async fn subscribe_with_all<T>(
    &self,
    subject: T,
    queue_group: Option<T>,
    durable_name: Option<T>,
    max_in_flight: i32,
    ack_wait_in_secs: i32,
    start_position: StartPosition,
    start_sequence: u64,
    start_time_delta: Option<i32>,
    manual_acks: bool
) -> Result<(StanSid, impl Stream<Item = StanMessage> + Send + Sync), RatsioError> where
    T: ToString, 

pub async fn subscribe_with<T>(
    &self,
    stan_subscribe: T
) -> Result<(StanSid, impl Stream<Item = StanMessage> + Send + Sync), RatsioError> where
    T: Into<StanSubscribe>, 

pub async fn acknowledge(&self, message: StanMessage) -> Result<(), RatsioError>

pub async fn publish<T>(
    &self,
    subject: T,
    payload: &[u8]
) -> Result<(), RatsioError> where
    T: ToString, 

pub async fn send_with_reply<T>(
    &self,
    subject: T,
    reply_to: T,
    payload: &[u8]
) -> Result<(), RatsioError> where
    T: ToString, 

pub async fn send_with<T>(&self, message: T) -> Result<(), RatsioError> where
    T: Into<StanMessage>, 

pub async fn un_subscribe(&self, stan_sid: &StanSid) -> Result<(), RatsioError>

pub async fn close(&self) -> Result<(), RatsioError>