Skip to main content

ApplyUpdate

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§