Struct hstreamdb::client::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn new<Destination>(
    server_url: Destination,
    channel_provider_settings: ChannelProviderSettings
) -> Result<Self, Error>where
    Destination: Into<String>,

impl Client

pub async fn echo<T: Into<String>>(&self, msg: T) -> Result<String>

impl Client

pub async fn create_stream(&self, stream: Stream) -> Result<Stream>

pub async fn delete_stream(
    &self,
    stream_name: String,
    ignore_non_exist: bool,
    force: bool
) -> Result<()>

pub async fn list_streams(&self) -> Result<Vec<Stream>>

pub async fn get_stream<T: Into<String>>(&self, stream_name: T) -> Result<Stream>

impl Client

pub async fn create_subscription(
    &self,
    subscription: Subscription
) -> Result<Subscription>

pub async fn delete_subscription(
    &self,
    subscription_id: String,
    force: bool
) -> Result<()>

pub async fn list_subscriptions(&self) -> Result<Vec<Subscription>>

pub async fn get_subscription<T: Into<String>>(
    &self,
    subscription_id: T
) -> Result<Subscription>

impl Client

pub async fn new_producer(
    &self,
    stream_name: String,
    compression_type: CompressionType,
    flow_control_bytes_limit: Option<usize>,
    flush_settings: FlushSettings,
    channel_provider_settings: ChannelProviderSettings,
    on_flush: Option<FlushCallback>
) -> Result<(Appender, Producer)>

impl Client

pub async fn list_consumers<T: Into<String>>(
    &self,
    subscription_id: T
) -> Result<Vec<Consumer>>

impl Client

pub async fn streaming_fetch(
    &self,
    consumer_name: String,
    subscription_id: String
) -> Result<UnboundedReceiverStream<(Payload, Responder)>>

impl Client

pub async fn create_shard_reader(
    &self,
    reader_id: String,
    stream_name: String,
    shard_id: ShardId,
    shard_offset: StreamShardOffset,
    timeout_ms: u32,
    channel_provider_settings: ChannelProviderSettings
) -> Result<ShardReader>