Struct dataflow_types::client::LocalClient [−][src]
pub struct LocalClient {
client: Partitioned<ProcessLocal>,
}
Expand description
A convenience type for compatibility.
Fields
client: Partitioned<ProcessLocal>
Implementations
Trait Implementations
Sends a command to the dataflow server.
Auto Trait Implementations
impl !RefUnwindSafe for LocalClient
impl Send for LocalClient
impl Sync for LocalClient
impl Unpin for LocalClient
impl !UnwindSafe for LocalClient
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>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn drop_instance<'life0, 'async_trait>(
&'life0 mut self,
instance: usize
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn create_dataflows<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
dataflows: Vec<DataflowDescription<Plan>>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn drop_sinks<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
sink_identifiers: Vec<GlobalId>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn drop_indexes<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
index_identifiers: Vec<GlobalId>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn peek<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
id: GlobalId,
key: Option<Row>,
conn_id: u32,
timestamp: Timestamp,
finishing: RowSetFinishing,
map_filter_project: SafeMfpPlan
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn cancel_peek<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
conn_id: u32
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn allow_index_compaction<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
frontiers: Vec<(GlobalId, Antichain<Timestamp>)>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn enable_logging<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
logging_config: LoggingConfig
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn create_sources<'life0, 'async_trait>(
&'life0 mut self,
source_descriptions: Vec<(GlobalId, (SourceDesc, Antichain<Timestamp>))>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn drop_sources<'life0, 'async_trait>(
&'life0 mut self,
source_identifiers: Vec<GlobalId>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn table_insert<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
updates: Vec<Update>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn update_durability_frontiers<'life0, 'async_trait>(
&'life0 mut self,
updates: Vec<(GlobalId, Antichain<Timestamp>)>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn add_source_timestamping<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
connector: SourceConnector,
bindings: Vec<(PartitionId, Timestamp, MzOffset)>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
fn allow_source_compaction<'life0, 'async_trait>(
&'life0 mut self,
frontiers: Vec<(GlobalId, Antichain<Timestamp>)>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: Send + 'async_trait,
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