Class: OpenTelemetryWorkflowClientInterceptor
opentelemetry.OpenTelemetryWorkflowClientInterceptor
Intercepts calls to start a Workflow.
Wraps the operation in an opentelemetry Span and passes it to the Workflow via headers.
Implements
Constructors
constructor
• new OpenTelemetryWorkflowClientInterceptor(options?): OpenTelemetryWorkflowClientInterceptor
Parameters
| Name | Type |
|---|---|
options? | InterceptorOptions |
Returns
OpenTelemetryWorkflowClientInterceptor
Methods
cancel
▸ cancel(input, next): Promise<IRequestCancelWorkflowExecutionResponse>
Parameters
| Name | Type |
|---|---|
input | WorkflowCancelInput |
next | OmitLastParam<(input: WorkflowCancelInput, next: OmitLastParam<(input: WorkflowCancelInput, next: OmitLastParam<...>) => Promise<IRequestCancelWorkflowExecutionResponse>>) => Promise<IRequestCancelWorkflowExecutionResponse>> |
Returns
Promise<IRequestCancelWorkflowExecutionResponse>
Implementation of
WorkflowClientInterceptor.cancel
describe
▸ describe(input, next): Promise<IDescribeWorkflowExecutionResponse>
Parameters
| Name | Type |
|---|---|
input | WorkflowDescribeInput |
next | OmitLastParam<(input: WorkflowDescribeInput, next: OmitLastParam<(input: WorkflowDescribeInput, next: OmitLastParam<...>) => Promise<IDescribeWorkflowExecutionResponse>>) => Promise<IDescribeWorkflowExecutionResponse>> |
Returns
Promise<IDescribeWorkflowExecutionResponse>
Implementation of
WorkflowClientInterceptor.describe
query
▸ query(input, next): Promise<unknown>
Parameters
| Name | Type |
|---|---|
input | WorkflowQueryInput |
next | OmitLastParam<(input: WorkflowQueryInput, next: OmitLastParam<(input: WorkflowQueryInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise<unknown>> |
Returns
Promise<unknown>
Implementation of
WorkflowClientInterceptor.query
signal
▸ signal(input, next): Promise<void>
Parameters
| Name | Type |
|---|---|
input | WorkflowSignalInput |
next | OmitLastParam<(input: WorkflowSignalInput, next: OmitLastParam<(input: WorkflowSignalInput, next: OmitLastParam<...>) => Promise<void>>) => Promise<void>> |
Returns
Promise<void>
Implementation of
WorkflowClientInterceptor.signal
signalWithStart
▸ signalWithStart(input, next): Promise<string>
Parameters
| Name | Type |
|---|---|
input | WorkflowSignalWithStartInput |
next | OmitLastParam<(input: WorkflowSignalWithStartInput, next: OmitLastParam<(input: WorkflowSignalWithStartInput, next: OmitLastParam<...>) => Promise<string>>) => Promise<string>> |
Returns
Promise<string>
Implementation of
WorkflowClientInterceptor.signalWithStart
start
▸ start(input, next): Promise<string>
Parameters
| Name | Type |
|---|---|
input | WorkflowStartInput |
next | OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<...>) => Promise<string>>) => Promise<string>> |
Returns
Promise<string>
Implementation of
WorkflowClientInterceptor.start
startUpdate
▸ startUpdate(input, next): Promise<WorkflowStartUpdateOutput>
Parameters
| Name | Type |
|---|---|
input | WorkflowStartUpdateInput |
next | OmitLastParam<(input: WorkflowStartUpdateInput, next: OmitLastParam<(input: WorkflowStartUpdateInput, next: OmitLastParam<...>) => Promise<WorkflowStartUpdateOutput>>) => Promise<WorkflowStartUpdateOutput>> |
Returns
Promise<WorkflowStartUpdateOutput>
Implementation of
WorkflowClientInterceptor.startUpdate
startUpdateWithStart
▸ startUpdateWithStart(input, next): Promise<WorkflowStartUpdateWithStartOutput>
Parameters
| Name | Type |
|---|---|
input | WorkflowStartUpdateWithStartInput |
next | OmitLastParam<(input: WorkflowStartUpdateWithStartInput, next: OmitLastParam<(input: WorkflowStartUpdateWithStartInput, next: OmitLastParam<...>) => Promise<WorkflowStartUpdateWithStartOutput>>) => Promise<WorkflowStartUpdateWithStartOutput>> |
Returns
Promise<WorkflowStartUpdateWithStartOutput>
Implementation of
WorkflowClientInterceptor.startUpdateWithStart
startWithDetails
▸ startWithDetails(input, next): Promise<WorkflowStartOutput>
Parameters
| Name | Type |
|---|---|
input | WorkflowStartInput |
next | OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<...>) => Promise<WorkflowStartOutput>>) => Promise<WorkflowStartOutput>> |
Returns
Promise<WorkflowStartOutput>
Implementation of
WorkflowClientInterceptor.startWithDetails
terminate
▸ terminate(input, next): Promise<ITerminateWorkflowExecutionResponse>
Parameters
| Name | Type |
|---|---|
input | WorkflowTerminateInput |
next | OmitLastParam<(input: WorkflowTerminateInput, next: OmitLastParam<(input: WorkflowTerminateInput, next: OmitLastParam<...>) => Promise<ITerminateWorkflowExecutionResponse>>) => Promise<ITerminateWorkflowExecutionResponse>> |
Returns
Promise<ITerminateWorkflowExecutionResponse>