Struct DefaultWriter

pub struct DefaultWriter;

Implementations

impl DefaultWriter

pub fn new() -> Self

Trait Implementations

impl Default for DefaultWriter

fn default() -> Self

Returns the “default value” for a type.

impl MessageWriter for DefaultWriter

type Channel = DefaultChannel

fn open(&self, params: Map<String, Value>) -> Self::Channel

Initialize a channel for writing messages back to Dagster.

fn get_opened_payload(&self, _: Token) -> HashMap<&str, Option<Value>>

Return a payload containing information about the external process to be passed back to the orchestration process. This should contain information that cannot be known before the external process is launched.

fn get_opened_extras(&self) -> Map<String, Value>

Return arbitary reader-specific information to be passed back to the orchestration process. The information will be returned under the extras key of the initialization payload.