Class: OpenTelemetryInboundInterceptor

opentelemetry.OpenTelemetryInboundInterceptor

Intercepts calls to run a Workflow

Wraps the operation in an opentelemetry Span and links it to a parent Span context if one is provided in the Workflow input headers.

Implements

• WorkflowInboundCallsInterceptor

Constructors

constructor

• new OpenTelemetryInboundInterceptor(): OpenTelemetryInboundInterceptor

Returns

OpenTelemetryInboundInterceptor

Methods

execute

▸ execute(input, next): Promise<unknown>

Called when Workflow execute method is called

Parameters

Name	Type
input	WorkflowExecuteInput
next	OmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>>

Returns

Promise<unknown>

result of the Workflow execution

Implementation of

WorkflowInboundCallsInterceptor.execute

---

handleSignal

▸ handleSignal(input, next): Promise<void>

Called when signal is delivered to a Workflow execution

Parameters

Name	Type
input	SignalInput
next	OmitLastParam<(input: SignalInput, next: OmitLastParam<(input: SignalInput, next: OmitLastParam<...>) => Promise<void>>) => Promise<void>>

Returns

Promise<void>

Implementation of

WorkflowInboundCallsInterceptor.handleSignal