Struct SinkBuildCtx 

pub struct SinkBuildCtx {
    pub work_root: PathBuf,
    pub replica_idx: usize,
    pub replica_cnt: usize,
    pub rate_limit_rps: usize,
}

Build context passed to sink factories during construction.

Contains runtime configuration such as work directories, replica info, and rate limiting hints that sinks may use during initialization.

Fields

work_root: PathBuf

Root directory for sink-specific working files (state, checkpoints, etc.)

replica_idx: usize

Replica index for parallel group builds (0-based). Defaults to 0.

replica_cnt: usize

Replica count for the group (>=1). Defaults to 1.

rate_limit_rps: usize

Upstream rate limit hint in requests per second. 0 means unlimited.

Implementations

impl SinkBuildCtx

pub fn new(work_root: PathBuf) -> Self

pub fn new_with_replica( work_root: PathBuf, replica_idx: usize, replica_cnt: usize, ) -> Self

pub fn with_limit(self, rate_limit_rps: usize) -> Self

Trait Implementations

impl Clone for SinkBuildCtx

fn clone(&self) -> SinkBuildCtx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SinkBuildCtx

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.