Struct fetcher_core::source::Exec

pub struct Exec {
    pub cmd: String,
}

Exec source. It can execute a shell command and source its stdout

Fields

cmd: String

The command to execute

Trait Implementations

impl Debug for Exec

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

Formats the value using the given formatter.

impl Fetch for Exec

fn fetch<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Vec<Entry>, SourceError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Fetch all available entries from the source

impl Sink for Exec

fn send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: Message, _reply_to: Option<&'life1 MessageId>, _tag: Option<&'life2 str> ) -> Pin<Box<dyn Future<Output = Result<Option<MessageId>, SinkError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Passes message’s body to the stdin of the process. The tag parameter is ignored

Errors

• if the process couldn’t be started
• if the data couldn’t be passed to the stdin pipe of the process