NodeContext
Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline.Nodes
Implementation of the node context
public class NodeContext : INodeContext
Inheritance Object → NodeContext
Implements INodeContext
Properties
ServiceProvider
public IServiceProvider ServiceProvider { get; }
Property Value
IServiceProvider
PipelineDebugger
public IPipelineDebugger PipelineDebugger { get; }
Property Value
PipelineExecutionMode
public IPipelineExecutionMode PipelineExecutionMode { get; }
Property Value
ScratchSpace
public IPipelineScratchSpace ScratchSpace { get; }
Property Value
SecretRegistry
public PipelineSecretRegistry SecretRegistry { get; }
Property Value
Parent
public INodeContext Parent { get; }
Property Value
NodePath
public NodePath NodePath { get; }
Property Value
NodePath
NodeId
public NodePath NodeId { get; }
Property Value
NodePath
SequenceNumber
public uint SequenceNumber { get; }
Property Value
NodeStack
public Stack<NodePath> NodeStack { get; }
Property Value
Stack<NodePath>
Methods
RegisterSecret(String)
public void RegisterSecret(string plaintext)
Parameters
plaintext String
Debug(String, Object[])
public void Debug(string message, Object[] args)
Parameters
message String
args Object[]
Info(String, Object[])
public void Info(string message, Object[] args)
Parameters
message String
args Object[]
Warning(String, Object[])
public void Warning(string message, Object[] args)
Parameters
message String
args Object[]
Error(String, Object[])
public void Error(string message, Object[] args)
Parameters
message String
args Object[]
Error(Exception, String, Object[])
public void Error(Exception exception, string message, Object[] args)
Parameters
exception Exception
message String
args Object[]
RecordDryRunIntent(String, Object)
public void RecordDryRunIntent(string nodeTypeName, object intentPayload)
Parameters
nodeTypeName String
intentPayload Object
Unregister(IDataContext)
public void Unregister(IDataContext dataContext)
Parameters
dataContext IDataContext
GetNodeConfiguration<T>()
public T GetNodeConfiguration<T>()
Type Parameters
T
Returns
T
RegisterChildNode(UInt32, INodeConfiguration, IDataContext)
public INodeContext RegisterChildNode(uint sequenceNumber, INodeConfiguration nodeConfiguration, IDataContext dataContext)
Parameters
sequenceNumber UInt32
nodeConfiguration INodeConfiguration
dataContext IDataContext
Returns
RegisterChildNode(String, UInt32, INodeConfiguration, IDataContext)
public INodeContext RegisterChildNode(string nodeQualifiedName, uint sequenceNumber, INodeConfiguration nodeConfiguration, IDataContext dataContext)
Parameters
nodeQualifiedName String
sequenceNumber UInt32
nodeConfiguration INodeConfiguration
dataContext IDataContext
Returns
RegisterChildNode(String, INodeConfiguration, IDataContext)
public INodeContext RegisterChildNode(string qualifiedName, INodeConfiguration nodeConfiguration, IDataContext dataContext)
Parameters
qualifiedName String
nodeConfiguration INodeConfiguration
dataContext IDataContext
Returns
CreateRootNodeContext(IServiceProvider, IPipelineLogger, IDataContext, IPipelineDebugger, IPipelineExecutionMode, IPipelineScratchSpace)
Creates a root node context
public static NodeContext CreateRootNodeContext(IServiceProvider serviceProvider, IPipelineLogger pipelineLogger, IDataContext dataContext, IPipelineDebugger pipelineDebugger, IPipelineExecutionMode pipelineExecutionMode, IPipelineScratchSpace scratchSpace)
Parameters
serviceProvider IServiceProvider
pipelineLogger IPipelineLogger
dataContext IDataContext
pipelineDebugger IPipelineDebugger
pipelineExecutionMode IPipelineExecutionMode
scratchSpace IPipelineScratchSpace
Returns
CreateRootNodeContext(IServiceProvider, IPipelineLogger, String, INodeConfiguration, IPipelineDebugger, IPipelineExecutionMode, IPipelineScratchSpace)
Creates a root node context with the specified node qualified name
public static NodeContext CreateRootNodeContext(IServiceProvider serviceProvider, IPipelineLogger pipelineLogger, string nodeQualifiedName, INodeConfiguration nodeConfiguration, IPipelineDebugger pipelineDebugger, IPipelineExecutionMode pipelineExecutionMode, IPipelineScratchSpace scratchSpace)
Parameters
serviceProvider IServiceProvider
pipelineLogger IPipelineLogger
nodeQualifiedName String
nodeConfiguration INodeConfiguration
pipelineDebugger IPipelineDebugger
pipelineExecutionMode IPipelineExecutionMode
scratchSpace IPipelineScratchSpace