Skip to main content

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

Constructors

constructor

new OpenTelemetryInboundInterceptor(): OpenTelemetryInboundInterceptor

Returns

OpenTelemetryInboundInterceptor

Methods

execute

execute(input, next): Promise<unknown>

Called when Workflow execute method is called

Parameters

NameType
inputWorkflowExecuteInput
nextOmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>>

Returns

Promise<unknown>

result of the Workflow execution

Implementation of

WorkflowInboundCallsInterceptor.execute