Struct EtlExecutor 

pub struct EtlExecutor { /* private fields */ }

ETL executor — periodically moves data from source tier to destination tier.

Implementations

impl EtlExecutor

pub fn new( source: Arc<PlainPbStoragePlugin>, dest: Arc<PlainPbStoragePlugin>, period_secs: u64, hold: u32, gather: u32, ) -> Self

pub fn with_pv_registry(self, registry: Arc<PvRegistry>) -> Self

Wire a PV registry so the executor can skip paused PVs in run_once. Java parity (92db337): without this, PB files for a paused PV continue to migrate out of the STS, which surprises operators who expect the data to stay accessible there until the PV resumes.

pub async fn run(&self, shutdown: Receiver<bool>)

Run the ETL loop. Call this as a spawned task.

pub fn source_name(&self) -> &str

pub fn dest_name(&self) -> &str

pub async fn consolidate_pv(&self, pv: &str) -> Result<u64>

Force-move every PB file the source tier currently holds for pv to the destination tier, ignoring hold / gather constraints. Drives the consolidateDataForPV BPL endpoint.

The same crash-safe move_file is reused, so partial failures leave the source either fully migrated or untouched.