Trait dataflow_types::client::ComputeClient[−][src]

pub trait ComputeClient: Client {
    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,
    { ... }
}
Expand description

Methods that reflect actions that can be performed against a compute instance.

Provided methods

Implementors