Struct FlowLiveUpdater 

pub struct FlowLiveUpdater {
    pub operation_in_process_stats: Arc<OperationInProcessStats>,
    /* private fields */
}

Fields

operation_in_process_stats: Arc<OperationInProcessStats>

Global tracking of in-process rows per operation

Implementations

impl FlowLiveUpdater

pub async fn start( flow_ctx: Arc<FlowContext>, pool: &PgPool, options: FlowLiveUpdaterOptions, ) -> Result<Self>

pub async fn wait(&self) -> Result<()>

pub fn abort(&self)

pub fn index_update_info(&self) -> IndexUpdateInfo

pub async fn next_status_updates(&self) -> Result<FlowLiveUpdaterUpdates>