ToPipelineDataEventNode
Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline.Nodes.Loads
Publishes the target object to the distribution event hub
public class ToPipelineDataEventNode : IPipelineNode
Inheritance Object → ToPipelineDataEventNode
Implements IPipelineNode
Constructors
ToPipelineDataEventNode(NodeDelegate, IEtlContext, IDistributionEventHubService, IPipelineDataEventTargetWaker)
Publishes the target object to the distribution event hub
public ToPipelineDataEventNode(NodeDelegate next, IEtlContext adapterEtlContext, IDistributionEventHubService distributionEventHubService, IPipelineDataEventTargetWaker targetWaker)
Parameters
next NodeDelegate
adapterEtlContext IEtlContext
distributionEventHubService IDistributionEventHubService
targetWaker IPipelineDataEventTargetWaker
Methods
ProcessObjectAsync(IDataContext, INodeContext)
public Task ProcessObjectAsync(IDataContext dataContext, INodeContext nodeContext)
Parameters
dataContext IDataContext
nodeContext INodeContext