Class WorkerHeartbeatService

Namespace

Virtufin.WorkManager.Services

Assembly

Virtufin.WorkManager.dll

Periodically touches the actor for every worker registered locally on this instance, so a running worker's actor never gets idle-deactivated out from under it. See TouchAsync(CancellationToken)'s doc comment for why this is needed: message dispatch for a running worker happens entirely through WorkManager's topic-subscription pool, never through an actor method call, so a worker actively processing messages can still look idle to Dapr's actor runtime.

public sealed class WorkerHeartbeatService : BackgroundService, IHostedService, IDisposable

Inheritance

object

BackgroundService

WorkerHeartbeatService

Implements

IHostedService

IDisposable

Inherited Members

BackgroundService.Dispose()

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.ExecuteTask

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WorkerHeartbeatService(WorkManager, IActorProxyFactory, ILogger<WorkerHeartbeatService>)

public WorkerHeartbeatService(WorkManager workManager, IActorProxyFactory actorProxies, ILogger<WorkerHeartbeatService> logger)

Parameters

workManager WorkManager

actorProxies IActorProxyFactory

logger ILogger<WorkerHeartbeatService>

Methods

ExecuteAsync(CancellationToken)

This method is called when the IHostedService starts. The implementation should return a task that represents the lifetime of the long running operation(s) being performed.

protected override Task ExecuteAsync(CancellationToken stoppingToken)

Parameters

stoppingToken CancellationToken

Triggered when StopAsync(CancellationToken) is called.

Returns

Task

A Task that represents the long running operations.

Remarks

See Worker Services in .NET for implementation guidelines.