Struct FileConfig 

pub struct FileConfig {

    pub directory: String,
    pub delay: Duration,
    pub initial_delay: Duration,
    pub noop: bool,
    pub delete: bool,
    pub file_name: Option<String>,
    pub include: Option<String>,
    pub exclude: Option<String>,
    pub recursive: bool,
    pub file_exist: FileExistStrategy,
    pub temp_prefix: Option<String>,
    pub auto_create: bool,
    pub read_timeout: Duration,
    pub write_timeout: Duration,
    /* private fields */
}

Configuration for file component endpoints.

Streaming

Both the file consumer and producer use native streaming with no RAM materialization:

• The consumer creates a Body::Stream backed by tokio::fs::File via ReaderStream. Files of any size are handled without loading them into memory.

• The producer writes via tokio::io::copy directly to a tokio::fs::File using Body::into_async_read(). Writes for the Override strategy are atomic: data is written to a temporary file first and renamed only on success, preventing partial files on failure.

Write strategies (fileExist URI parameter)

Value	Behavior
Override (default)	Atomic write via temp file + rename
Append	Appends to existing file; non-atomic by nature
Fail	Returns error if file already exists

Fields

directory: String

Directory path to read from or write to.

delay: Duration

Polling delay as Duration.

initial_delay: Duration

Initial delay as Duration.

noop: bool

If true, don’t delete or move files after processing.

delete: bool

If true, delete files after processing.

file_name: Option<String>

Fixed filename for producer (optional).

include: Option<String>

Regex pattern for including files (consumer).

exclude: Option<String>

Regex pattern for excluding files (consumer).

recursive: bool

Whether to scan directories recursively.

file_exist: FileExistStrategy

Strategy for handling existing files when writing.

temp_prefix: Option<String>

Prefix for temporary files during atomic writes.

auto_create: bool

Whether to automatically create directories.

read_timeout: Duration

Read timeout as Duration.

write_timeout: Duration

Write timeout as Duration.

Implementations

impl FileConfig

pub fn parse_uri_components(parts: UriComponents) -> Result<Self, CamelError>

Parse URI components into this config. Call this from your custom UriConfig::from_components implementation.

impl FileConfig

pub fn apply_global_defaults(&mut self, global: &FileGlobalConfig)

Apply global config defaults. Since FileConfig uses a proc macro that bakes in defaults, we compare Duration values against the known macro defaults to detect “not explicitly set by user”. Only overrides when current value == macro default.

Note: If a user explicitly sets a URI param to its default value (e.g., ?delay=500), it is indistinguishable from “not set” and will be overridden by global config. This is a known limitation of the Duration comparison approach.

Trait Implementations

impl Clone for FileConfig

fn clone(&self) -> FileConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileConfig

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

Formats the value using the given formatter.

impl UriConfig for FileConfig

fn scheme() -> &'static str

Returns the URI scheme this config handles (e.g., “timer”, “http”).

fn from_uri(uri: &str) -> Result<Self, CamelError>

Parse a URI string into this configuration.

fn from_components(parts: UriComponents) -> Result<Self, CamelError>

Parse already-extracted URI components into this configuration.

fn validate(self) -> Result<Self, CamelError>

Override to add validation logic after parsing.