Class RedisWorkflowDispatcher

Namespace

JD.AI.Workflows.Distributed.Redis

Assembly

JD.AI.Workflows.Distributed.dll

Dispatches WorkflowWorkItem instances to a Redis Stream.

public sealed class RedisWorkflowDispatcher : IWorkflowDispatcher

Inheritance

object

RedisWorkflowDispatcher

Implements

IWorkflowDispatcher

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RedisWorkflowDispatcher(IConnectionMultiplexer, RedisWorkflowOptions)

Initializes the dispatcher.

public RedisWorkflowDispatcher(IConnectionMultiplexer redis, RedisWorkflowOptions options)

Parameters

redis IConnectionMultiplexer

options RedisWorkflowOptions

Methods

DispatchAsync(WorkflowWorkItem, CancellationToken)

Dispatches a workflow work item for execution.

public Task DispatchAsync(WorkflowWorkItem item, CancellationToken ct = default)

Parameters

item WorkflowWorkItem

The work item to dispatch.

ct CancellationToken

Cancellation token.

Returns

Task