HubPipelineDataEventTargetWaker
Namespace: Meshmakers.Octo.Sdk.Common.Services
The adapter's waker: skips a target registered in THIS process (the sender is running, so the target is too — the common in-workload chaining case pays nothing), and otherwise asks the controller over the adapter hub, which resolves the target's workload and wakes it.
public sealed class HubPipelineDataEventTargetWaker : IPipelineDataEventTargetWaker
Inheritance Object → HubPipelineDataEventTargetWaker
Implements IPipelineDataEventTargetWaker
Constructors
HubPipelineDataEventTargetWaker(IAdapterHubClient, IPipelineRegistryService, ILogger<HubPipelineDataEventTargetWaker>)
The adapter's waker: skips a target registered in THIS process (the sender is running, so the target is too — the common in-workload chaining case pays nothing), and otherwise asks the controller over the adapter hub, which resolves the target's workload and wakes it.
public HubPipelineDataEventTargetWaker(IAdapterHubClient adapterHubClient, IPipelineRegistryService pipelineRegistryService, ILogger<HubPipelineDataEventTargetWaker> logger)
Parameters
adapterHubClient IAdapterHubClient
pipelineRegistryService IPipelineRegistryService
logger ILogger<HubPipelineDataEventTargetWaker>
Methods
EnsureTargetRunningAsync(String, RtEntityId, CancellationToken)
public Task EnsureTargetRunningAsync(string tenantId, RtEntityId targetPipelineRtEntityId, CancellationToken cancellationToken)
Parameters
tenantId String
targetPipelineRtEntityId RtEntityId
cancellationToken CancellationToken