Package io.dapr.durabletask.runner

Class DurableRunner

java.lang.Object

io.dapr.durabletask.runner.DurableRunner

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ActivityRunner, OrchestratorRunner

public abstract class DurableRunner
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
final TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub	sidecarClient
final io.opentelemetry.api.trace.Tracer	tracer
final OrchestratorService.WorkItem	workItem

Constructor Summary

Constructors

Constructor	Description
DurableRunner(OrchestratorService.WorkItem workItem, TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient, io.opentelemetry.api.trace.Tracer tracer)	Constructs a new instance of the DurableRunner.

Method Summary

Modifier and Type	Method	Description
protected String	getSidecarAddress()
protected void	logException(io.grpc.StatusRuntimeException e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Runnable

run

Field Details

sidecarClient

public final TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient

workItem

public final OrchestratorService.WorkItem workItem

tracer

@Nullable
public final io.opentelemetry.api.trace.Tracer tracer

Constructor Details

DurableRunner

public DurableRunner(OrchestratorService.WorkItem workItem,
 TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient,
 @Nullable
 io.opentelemetry.api.trace.Tracer tracer)

Constructs a new instance of the DurableRunner.

Parameters:

workItem - the work item to be executed

sidecarClient - the sidecar client used to communicate with the durable task sidecar

tracer - the tracer used for tracing operations; can be null if tracing is not required

Method Details

getSidecarAddress

protected String getSidecarAddress()

logException

protected void logException(io.grpc.StatusRuntimeException e)