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.
@temporalio/workflow must be provided by host package in order to function.
Implements
Constructors
constructor
• new OpenTelemetryInboundInterceptor(): OpenTelemetryInboundInterceptor
Returns
OpenTelemetryInboundInterceptor
Methods
execute
▸ execute(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | WorkflowExecuteInput |
next | OmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<(input: WorkflowExecuteInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowInboundCallsInterceptor.execute
handleQuery
▸ handleQuery(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | QueryInput |
next | OmitLastParam<(input: QueryInput, next: OmitLastParam<(input: QueryInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowInboundCallsInterceptor.handleQuery
handleSignal
▸ handleSignal(input, next): Promise<void>
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
handleUpdate
▸ handleUpdate(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | UpdateInput |
next | OmitLastParam<(input: UpdateInput, next: OmitLastParam<(input: UpdateInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowInboundCallsInterceptor.handleUpdate
validateUpdate
▸ validateUpdate(input, next): void
Parameters
| Name | Type |
|---|---|
input | UpdateInput |
next | OmitLastParam<(input: UpdateInput, next: OmitLastParam<(input: UpdateInput, next: OmitLastParam<...>) => void>) => void> |
Returns
void