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
signal
▸ signal(input, next): Promise<void>
Intercept a service call to signalWorkflowExecution
If you implement this method, signalWithStart most likely needs to be implemented too
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
start
▸ start(input, next): Promise<string>
Intercept a service call to startWorkflowExecution
If you implement this method, signalWithStart most likely needs to be implemented too
Parameters
| Name | Type |
|---|---|
input | WorkflowStartInput |
next | OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<(input: WorkflowStartInput, next: OmitLastParam<...>) => Promise<string>>) => Promise<string>> |
Returns
Promise<string>