Struct pravega_client::client_factory::ClientFactoryAsync

pub struct ClientFactoryAsync { /* private fields */ }

Implementations

impl ClientFactoryAsync

pub fn new(config: ClientConfig, handle: Handle) -> Self

pub fn config(&self) -> &ClientConfig

pub fn create_event_writer(&self, stream: ScopedStream) -> EventWriter

pub async fn create_stream_meta_client( &self, stream: ScopedStream ) -> MetaClient

pub async fn create_reader_group( &self, reader_group_name: String, stream: ScopedStream ) -> ReaderGroup

Create a ReaderGroup with the specified name to read from the specified Stream. The readers will read from the HEAD/beginning of the Stream.

pub async fn create_reader_group_with_config( &self, scope: Scope, reader_group_name: String, rg_config: ReaderGroupConfig ) -> ReaderGroup

Create a ReaderGroup with the streams configured in the ReaderGroupConfig.

pub async fn delete_reader_group( &self, scope: Scope, reader_group_name: String ) -> Result<(), TableError>

Delete a ReaderGroup given for a given scope.

pub async fn create_transactional_event_writer( &self, stream: ScopedStream, writer_id: WriterId ) -> TransactionalEventWriter

pub async fn create_byte_writer(&self, stream: ScopedStream) -> ByteWriter

pub async fn create_byte_reader(&self, stream: ScopedStream) -> ByteReader

pub async fn create_index_writer<T: Fields + PartialOrd + PartialEq + Debug>( &self, stream: ScopedStream ) -> IndexWriter<T>

pub async fn create_index_reader(&self, stream: ScopedStream) -> IndexReader

pub async fn create_table(&self, scope: Scope, name: String) -> Table

pub async fn create_synchronizer( &self, scope: Scope, name: String ) -> Synchronizer

pub fn controller_client(&self) -> &dyn ControllerClient

pub fn runtime_handle(&self) -> Handle

Trait Implementations

impl Clone for ClientFactoryAsync

fn clone(&self) -> ClientFactoryAsync

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ClientFactoryAsync

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

Formats the value using the given formatter.