Struct dataflowd::tcp::TcpClient [−][src]
pub struct TcpClient { /* fields omitted */ }
Expand description
A client to a remote dataflow server.
Implementations
Trait Implementations
Sends a command to the dataflow server.
Auto Trait Implementations
impl RefUnwindSafe for TcpClient
impl UnwindSafe for TcpClient
Blanket Implementations
Mutably borrows from an owned value. Read more
fn create_instance<'life0, 'async_trait>(
&'life0 mut self,
instance: usize
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn drop_instance<'life0, 'async_trait>(
&'life0 mut self,
instance: usize
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn create_dataflows<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
dataflows: Vec<DataflowDescription<Plan>, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn drop_sinks<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
sink_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn drop_indexes<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
index_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn peek<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
id: GlobalId,
key: Option<Row>,
conn_id: u32,
timestamp: u64,
finishing: RowSetFinishing,
map_filter_project: SafeMfpPlan
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn cancel_peek<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
conn_id: u32
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn create_sources<'life0, 'async_trait>(
&'life0 mut self,
source_descriptions: Vec<(GlobalId, (SourceDesc, Antichain<u64>)), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn drop_sources<'life0, 'async_trait>(
&'life0 mut self,
source_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn table_insert<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
updates: Vec<Update, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn update_durability_frontiers<'life0, 'async_trait>(
&'life0 mut self,
updates: Vec<(GlobalId, Antichain<u64>), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn add_source_timestamping<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
connector: SourceConnector,
bindings: Vec<(PartitionId, u64, MzOffset), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
fn allow_source_compaction<'life0, 'async_trait>(
&'life0 mut self,
frontiers: Vec<(GlobalId, Antichain<u64>), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more