Struct dataflow_types::client::process_local::ProcessLocal [−][src]
pub struct ProcessLocal {
feedback_rx: UnboundedReceiver<Response>,
worker_tx: Sender<Command>,
worker_thread: Thread,
}
Expand description
A client to a dataflow server running in the current process.
Fields
feedback_rx: UnboundedReceiver<Response>
worker_tx: Sender<Command>
worker_thread: Thread
Implementations
Create a new instance of ProcessLocal from its parts.
Trait Implementations
Sends a command to the dataflow server.
Auto Trait Implementations
impl !RefUnwindSafe for ProcessLocal
impl Send for ProcessLocal
impl Sync for ProcessLocal
impl Unpin for ProcessLocal
impl !UnwindSafe for ProcessLocal
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