Trait AudienceBlobMoveStaging 

pub trait AudienceBlobMoveStaging: Send + Sync {
    // Required method
    fn stage_audience_move_blobs_on(
        &self,
        transaction: &mut HostWriteBlobTransaction<'_, '_>,
        facts: &mut StoreWriteBlobFacts,
        moves: &[AudienceMove],
        partitions: &[AudiencePartition],
    ) -> Result<StagedAudienceBlobRollback, DbError>;
}

Staging audience-move blobs into the spool needs the connected staging owner replication composes. The capture transaction names only this port; the returned rollback closure is consumed on failure.

Required Methods

fn stage_audience_move_blobs_on( &self, transaction: &mut HostWriteBlobTransaction<'_, '_>, facts: &mut StoreWriteBlobFacts, moves: &[AudienceMove], partitions: &[AudiencePartition], ) -> Result<StagedAudienceBlobRollback, DbError>

Implementors