Struct fluvio::spu::SpuPool

pub struct SpuPool { /* private fields */ }

connection pool to spu

Implementations

impl SpuPool

pub fn start( config: Arc<ClientConfig>, metadata: MetadataStores ) -> Result<Self, SocketError>

start synchronize based on pool

pub async fn create_serial_socket_from_leader( &self, leader_id: SpuId ) -> Result<VersionedSerialSocket, FluvioError>

pub async fn topic_exists<S: Into<String>>( &self, topic: S ) -> Result<bool, FluvioError>

pub fn shutdown(&mut self)

Trait Implementations

impl Drop for SpuPool

fn drop(&mut self)

Executes the destructor for this type.

impl SpuDirectory for SpuPool

fn create_serial_socket<'life0, 'life1, 'async_trait>( &'life0 self, replica: &'life1 ReplicaKey ) -> Pin<Box<dyn Future<Output = Result<VersionedSerialSocket, FluvioError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create request/response socket to SPU for a replica

All sockets to same SPU use a single TCP connection. First this looks up SPU address in SPU metadata and try to see if there is an existing TCP connection. If not, it will create a new connection and creates socket to it

fn create_stream_with_version<'life0, 'life1, 'async_trait, R>( &'life0 self, replica: &'life1 ReplicaKey, request: R, version: i16 ) -> Pin<Box<dyn Future<Output = Result<AsyncResponse<R>, FluvioError>> + Send + 'async_trait>>where R: Sync + Send + 'async_trait + Request, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

create stream to leader replica