IEtlDataOrchestrator
Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline
Interface for an extract-transform-load data orchestrator
public interface IEtlDataOrchestrator
Methods
ExecutePipelineAsync<TEtlContext>(NodeDefinitionRoot, TEtlContext, IPipelineDebugger, Object, IPipelineExecutionMode)
Executes the pipeline
Task<object> ExecutePipelineAsync<TEtlContext>(NodeDefinitionRoot nodeDefinitionRoot, TEtlContext etlContext, IPipelineDebugger pipelineDebugger, object value, IPipelineExecutionMode executionMode)
Type Parameters
TEtlContext
Parameters
nodeDefinitionRoot NodeDefinitionRoot
Configuration of the data pipeline to run
etlContext TEtlContext
Context the data pipeline is running in to pass information about tenants, adapters etc.
pipelineDebugger IPipelineDebugger
An optional pipeline debugger
value Object
An optional value to pass to the pipeline
executionMode IPipelineExecutionMode
Optional per-execution mode flags surfaced to nodes via
INodeContext.PipelineExecutionMode. When IsDryRun is true,
Load nodes that honour the flag suppress their real sink and record a "would-have-written"
payload via INodeContext.RecordDryRunIntent(String, Object). Null restores classic
(real-effect) behaviour.