Table of Contents

Interface IWorkerRuntimeActor

Namespace
Virtufin.WorkManager.Actors
Assembly
Virtufin.WorkManager.dll
[GenerateActorClient]
public interface IWorkerRuntimeActor : IActor

Methods

CreateAsync(CreateRuntimeWorkerPayload, CancellationToken)

Task CreateAsync(CreateRuntimeWorkerPayload body, CancellationToken cancellationToken = default)

Parameters

body CreateRuntimeWorkerPayload
cancellationToken CancellationToken

Returns

Task

DeleteAsync(CancellationToken)

Task DeleteAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

LoadAsync(CancellationToken)

Load the registered worker's code (async CreateWorker); see the Runtime.

Task<RuntimeLoadResult> LoadAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task<RuntimeLoadResult>

LoadCodeAsync(LoadRuntimeCodePayload, CancellationToken)

Task LoadCodeAsync(LoadRuntimeCodePayload body, CancellationToken cancellationToken = default)

Parameters

body LoadRuntimeCodePayload
cancellationToken CancellationToken

Returns

Task

ProcessAsync(RuntimeCloudEventPayload, CancellationToken)

Task<RuntimeCloudEventPayload?> ProcessAsync(RuntimeCloudEventPayload evt, CancellationToken cancellationToken = default)

Parameters

evt RuntimeCloudEventPayload
cancellationToken CancellationToken

Returns

Task<RuntimeCloudEventPayload>

ReloadAsync(CancellationToken)

Reload the worker's code (library update); see the Runtime.

Task ReloadAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

StartAsync(CancellationToken)

Task StartAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

StopAsync(CancellationToken)

Task StopAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

TouchAsync(CancellationToken)

Task TouchAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task