Struct FlowBuilder 

pub struct FlowBuilder { /* private fields */ }

Implementations

impl FlowBuilder

pub async fn new(name: &str) -> Result<Self>

pub fn root_scope(&self) -> OpScopeRef

pub async fn add_source( &mut self, kind: String, op_spec: Map<String, Value>, target_scope: Option<OpScopeRef>, name: String, refresh_options: Option<SourceRefreshOptions>, execution_options: Option<ExecutionOptions>, ) -> Result<DataSlice>

pub fn constant( &self, value_type: EnrichedValueType, value: Value, ) -> Result<DataSlice>

pub fn add_direct_input( &mut self, name: String, value_type: EnrichedValueType, ) -> Result<DataSlice>

pub fn set_direct_output(&mut self, data_slice: DataSlice) -> Result<()>

pub fn for_each( &mut self, data_slice: DataSlice, execution_options: Option<ExecutionOptions>, ) -> Result<OpScopeRef>

pub async fn transform( &mut self, kind: String, op_spec: Map<String, Value>, args: Vec<(DataSlice, Option<String>)>, target_scope: Option<OpScopeRef>, name: String, ) -> Result<DataSlice>

pub async fn collect( &mut self, collector: &DataCollector, fields: Vec<(FieldName, DataSlice)>, auto_uuid_field: Option<FieldName>, ) -> Result<()>

pub fn export( &mut self, name: String, kind: String, op_spec: Map<String, Value>, attachments: Vec<OpSpec>, index_options: IndexOptions, input: &DataCollector, setup_by_user: bool, ) -> Result<()>

pub fn declare(&mut self, op_spec: OpSpec) -> Result<()>

pub fn scope_field( &self, scope: OpScopeRef, field_name: &str, ) -> Result<Option<DataSlice>>

pub async fn build_flow(&self) -> Result<Flow>

pub async fn build_transient_flow(&self) -> Result<TransientFlow>

Trait Implementations

impl Display for FlowBuilder

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

Formats the value using the given formatter.