Struct FileSink 

pub struct FileSink {
    pub path: Option<String>,
}

Writes each record value as a single JSON line to stdout or a file.

Fields

path: Option<String>

Implementations

impl FileSink

pub fn stdout() -> Self

Trait Implementations

impl Sink for FileSink

fn on_element<'life0, 'async_trait>( &'life0 mut self, record: Record, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn on_watermark<'life0, 'async_trait>( &'life0 mut self, _wm: Watermark, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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