Zum Hauptinhalt springen

AdapterExecutionService

Namespace: Meshmakers.Octo.Sdk.Common.Adapters

Background service for the execution of an adapter.

public class AdapterExecutionService : IAdapterHubCallbacks

Inheritance Object → AdapterExecutionService
Implements IAdapterHubCallbacks

Constructors​

AdapterExecutionService(IAdapterHubClient, IOptions<AdapterOptions>, IAdapterService, IAdapterHubCallbackService, AdapterLifetimeManagement, IPipelineRegistryService, IPipelineExecutionReporter, INodeSchemaRegistry, IPipelineSchemaGenerator, IAdapterHubRegistrationState)​

Creates a new instance of AdapterExecutionService.

public AdapterExecutionService(IAdapterHubClient adapterHubClient, IOptions<AdapterOptions> adapterOptions, IAdapterService adapterService, IAdapterHubCallbackService adapterHubCallbackService, AdapterLifetimeManagement adapterLifetimeManagement, IPipelineRegistryService pipelineRegistryService, IPipelineExecutionReporter executionReporter, INodeSchemaRegistry nodeSchemaRegistry, IPipelineSchemaGenerator pipelineSchemaGenerator, IAdapterHubRegistrationState registrationState)

Parameters​

adapterHubClient IAdapterHubClient

adapterOptions IOptions<AdapterOptions>

adapterService IAdapterService

adapterHubCallbackService IAdapterHubCallbackService

adapterLifetimeManagement AdapterLifetimeManagement

pipelineRegistryService IPipelineRegistryService

executionReporter IPipelineExecutionReporter

nodeSchemaRegistry INodeSchemaRegistry

pipelineSchemaGenerator IPipelineSchemaGenerator

registrationState IAdapterHubRegistrationState
Tracks whether the adapter is registered at the adapter hub (AB#5409). Optional so existing callers keep compiling; the DI container supplies the shared singleton the readiness check and the recovery watchdog read.

Methods​

PreUpdateTenantAsync(String)​

public Task PreUpdateTenantAsync(string tenantId)

Parameters​

tenantId String

Returns​

Task

CkModelChangedAsync(String)​

public Task CkModelChangedAsync(string tenantId)

Parameters​

tenantId String

Returns​

Task

AdapterConfigurationUpdatedAsync(String, AdapterConfigurationDto)​

public Task AdapterConfigurationUpdatedAsync(string tenantId, AdapterConfigurationDto adapterConfiguration)

Parameters​

tenantId String

adapterConfiguration AdapterConfigurationDto

Returns​

Task

StartAsync(CancellationToken)​

Starts the adapter execution service.

public Task StartAsync(CancellationToken cancellationToken)

Parameters​

cancellationToken CancellationToken

Returns​

Task

StopAsync(CancellationToken)​

Stops the adapter execution service.

public Task StopAsync(CancellationToken cancellationToken)

Parameters​

cancellationToken CancellationToken

Returns​

Task