Struct FileSource 

pub struct FileSource {
    pub path: String,
    pub format: FileFormat,
    pub event_time_field: String,
    pub text_field: Option<String>,
}

Reads a file (JSONL or CSV) and emits records.

• event_time_field: name of the timestamp field (RFC3339 string or epoch ms)

Fields

path: String

format: FileFormat

event_time_field: String

text_field: Option<String>

Implementations

impl FileSource

pub fn jsonl( path: impl Into<String>, event_time_field: impl Into<String>, ) -> Self

Trait Implementations

impl Source for FileSource

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut dyn Context, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,