StreamClientPool

risingwave_rpc_client::stream_client

Type Alias StreamClientPool 

Source 
pub type StreamClientPool = RpcClientPool<StreamClient>;

Aliased Type§

pub struct StreamClientPool {
    pub(crate) connection_pool_size: u16,
    pub(crate) clients: Cache<HostAddr, Arc<Vec<StreamClient>>>,
    pub(crate) opts: RpcClientConfig,
}

Fields§

§connection_pool_size: u16§clients: Cache<HostAddr, Arc<Vec<StreamClient>>>§opts: RpcClientConfig