Skip to main content

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

Returns​

Task