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

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

    fn drop_source_timestamping<'life0, 'async_trait>(
        &'life0 mut self, 
        id: GlobalId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: Send + 'async_trait,
    { ... }

    fn advance_all_table_timestamps<'life0, 'async_trait>(
        &'life0 mut self, 
        advance_to: Timestamp
    ) -> 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 the storage layer.

Provided methods

Implementors