Struct SourceDrivenConfig 

pub struct SourceDrivenConfig {
    pub primary: Arc<Mutex<Box<dyn SourceReader>>>,
    pub primary_name: String,
    pub dimensions: HashMap<String, DimensionSource>,
    pub resolved_paths: HashMap<String, PathBuf>,
    pub load_stats: DimLoadStats,
    pub runtime_stats: SourceRuntimeStats,
    pub fallback_policy: RuntimeFallbackPolicy,
    pub loaded_at: Instant,
    pub current_row: AtomicU64,
    /* private fields */
}

Fields

primary: Arc<Mutex<Box<dyn SourceReader>>>

primary_name: String

dimensions: HashMap<String, DimensionSource>

resolved_paths: HashMap<String, PathBuf>

load_stats: DimLoadStats

runtime_stats: SourceRuntimeStats

fallback_policy: RuntimeFallbackPolicy

loaded_at: Instant

current_row: AtomicU64

Implementations

impl SourceDrivenConfig

pub fn prepare( definitions: &[SourceDefinition], document_path: &Path, ) -> Result<Option<Self>>

pub fn next_row_variables(&self) -> Result<Option<HashMap<String, Value>>>

pub fn dimension_lookup( &self, source_name: &str, key: &str, ) -> Option<SourceRow>

pub fn dimension_lookup_all( &self, source_name: &str, key: &str, ) -> Option<Vec<SourceRow>>

pub fn build_dimension_variables( &self, row: &SourceRow, joins: &[(String, String, String)], ) -> HashMap<String, Value>

pub fn primary_headers(&self) -> Vec<String>