Class: OpenTelemetryOutboundInterceptor
opentelemetryV2.OpenTelemetryOutboundInterceptor
Intercepts outbound calls to schedule an Activity
Wraps the operation in an opentelemetry Span and passes it to the Activity via headers.
@temporalio/workflow must be provided by host package in order to function.
This interceptor is experimental and APIs may change without notice.
Implements
Constructors
constructor
• new OpenTelemetryOutboundInterceptor(): OpenTelemetryOutboundInterceptor
Returns
OpenTelemetryOutboundInterceptor
Methods
continueAsNew
▸ continueAsNew(input, next): Promise<never>
Parameters
| Name | Type |
|---|---|
input | ContinueAsNewInput |
next | OmitLastParam<(input: ContinueAsNewInput, next: OmitLastParam<(input: ContinueAsNewInput, next: OmitLastParam<...>) => Promise<never>>) => Promise<never>> |
Returns
Promise<never>
Implementation of
WorkflowOutboundCallsInterceptor.continueAsNew
getLogAttributes
▸ getLogAttributes(input, next): Record<string, unknown>
Parameters
| Name | Type |
|---|---|
input | GetLogAttributesInput |
next | OmitLastParam<(input: GetLogAttributesInput, next: OmitLastParam<(input: GetLogAttributesInput, next: OmitLastParam<...>) => Record<string, unknown>>) => Record<string, unknown>> |
Returns
Record<string, unknown>
Implementation of
WorkflowOutboundCallsInterceptor.getLogAttributes
getMetricTags
▸ getMetricTags(input, next): MetricTags
Parameters
| Name | Type |
|---|---|
input | MetricTags |
next | OmitLastParam<(input: MetricTags, next: OmitLastParam<(input: MetricTags, next: OmitLastParam<...>) => MetricTags>) => MetricTags> |
Returns
Implementation of
WorkflowOutboundCallsInterceptor.getMetricTags
scheduleActivity
▸ scheduleActivity(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | ActivityInput |
next | OmitLastParam<(input: ActivityInput, next: OmitLastParam<(input: ActivityInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowOutboundCallsInterceptor.scheduleActivity
scheduleLocalActivity
▸ scheduleLocalActivity(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | LocalActivityInput |
next | OmitLastParam<(input: LocalActivityInput, next: OmitLastParam<(input: LocalActivityInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowOutboundCallsInterceptor.scheduleLocalActivity
signalWithStartWorkflow
▸ signalWithStartWorkflow(input, next): Promise<NexusOperationHandle<SignalWithStartWorkflowResponse>>
Parameters
| Name | Type |
|---|---|
input | SignalWithStartWorkflowRequest |
next | OmitLastParam<(input: SignalWithStartWorkflowRequest, next: (input: SignalWithStartWorkflowRequest) => Promise<NexusOperationHandle<SignalWithStartWorkflowResponse>>) => Promise<NexusOperationHandle<SignalWithStartWorkflowResponse>>> |
Returns
Promise<NexusOperationHandle<SignalWithStartWorkflowResponse>>
Implementation of
WorkflowOutboundCallsInterceptor.signalWithStartWorkflow
signalWorkflow
▸ signalWorkflow(input, next): Promise<void>
Parameters
| Name | Type |
|---|---|
input | SignalWorkflowInput |
next | OmitLastParam<(input: SignalWorkflowInput, next: OmitLastParam<(input: SignalWorkflowInput, next: OmitLastParam<...>) => Promise<void>>) => Promise<void>> |
Returns
Promise<void>
Implementation of
WorkflowOutboundCallsInterceptor.signalWorkflow
startChildWorkflowExecution
▸ startChildWorkflowExecution(input, next): Promise<[Promise<string>, Promise<unknown>]>
Parameters
| Name | Type |
|---|---|
input | StartChildWorkflowExecutionInput |
next | OmitLastParam<(input: StartChildWorkflowExecutionInput, next: OmitLastParam<(input: StartChildWorkflowExecutionInput, next: OmitLastParam<...>) => Promise<[Promise<string>, Promise<unknown>]>>) => Promise<[Promise<string>, Promise<unknown>]>> |
Returns
Promise<[Promise<string>, Promise<unknown>]>
Implementation of
WorkflowOutboundCallsInterceptor.startChildWorkflowExecution
startNexusOperation
▸ startNexusOperation(input, next): Promise<StartNexusOperationOutput>
Parameters
| Name | Type |
|---|---|
input | StartNexusOperationInput |
next | OmitLastParam<(input: StartNexusOperationInput, next: OmitLastParam<(input: StartNexusOperationInput, next: OmitLastParam<...>) => Promise<StartNexusOperationOutput>>) => Promise<StartNexusOperationOutput>> |
Returns
Promise<StartNexusOperationOutput>