mz_catalog::durable::persist

Trait ApplyUpdate

Source 
pub(crate) trait ApplyUpdate<T: IntoStateUpdateKindJson> {
    // Required method
    fn apply_update(
        &mut self,
        update: StateUpdate<T>,
        current_fence_token: &mut FenceableToken,
        metrics: &Arc<Metrics>,
    ) -> Result<Option<StateUpdate<T>>, FenceError>;
}

Required Methods§

Source

fn apply_update( &mut self, update: StateUpdate<T>, current_fence_token: &mut FenceableToken, metrics: &Arc<Metrics>, ) -> Result<Option<StateUpdate<T>>, FenceError>

Process and apply update.

Returns Some if update should be cached in memory and None otherwise.

Implementors§