pub struct ResolvedConfig {
pub download_dir_mc: PathBuf,
pub download_dir_pt: PathBuf,
pub parquet_dir_mc: PathBuf,
pub parquet_dir_pt: PathBuf,
pub batch_size: usize,
pub read_concurrency: usize,
pub concat_batches: bool,
pub max_retries: u32,
pub retry_initial_delay_ms: u64,
pub retry_max_delay_ms: u64,
pub concurrent_downloads: usize,
}Expand description
Resolved configuration with all values filled in (no Options).
This struct represents the pipeline defaults and can be deserialized by the TOML loader. All fields have concrete values, making it safe to access directly without unwrapping.
Fields§
§download_dir_mc: PathBuf§download_dir_pt: PathBuf§parquet_dir_mc: PathBuf§parquet_dir_pt: PathBuf§batch_size: usizeNumber of XML files processed per chunk during parsing. This also bounds the peak in-memory DataFrame size.
read_concurrency: usizeNumber of concurrent XML file reads during parsing.
concat_batches: boolWhether to concatenate per-batch parquet files into a single period file.
max_retries: u32§retry_initial_delay_ms: u64§retry_max_delay_ms: u64§concurrent_downloads: usizeTrait Implementations§
Source§impl Clone for ResolvedConfig
impl Clone for ResolvedConfig
Source§fn clone(&self) -> ResolvedConfig
fn clone(&self) -> ResolvedConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ResolvedConfig
impl Debug for ResolvedConfig
Source§impl Default for ResolvedConfig
impl Default for ResolvedConfig
Source§impl<'de> Deserialize<'de> for ResolvedConfigwhere
ResolvedConfig: Default,
impl<'de> Deserialize<'de> for ResolvedConfigwhere
ResolvedConfig: Default,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for ResolvedConfig
impl RefUnwindSafe for ResolvedConfig
impl Send for ResolvedConfig
impl Sync for ResolvedConfig
impl Unpin for ResolvedConfig
impl UnwindSafe for ResolvedConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more