![Introducing Enhanced Alert Actions and Triage Functionality](https://cdn.sanity.io/images/cgdhsj6q/production/fe71306d515f85de6139b46745ea7180362324f0-2530x946.png?w=800&fit=max&auto=format)
Product
Introducing Enhanced Alert Actions and Triage Functionality
Socket now supports four distinct alert actions instead of the previous two, and alert triaging allows users to override the actions taken for all individual alerts.
workflow-manager
Advanced tools
Readme
workflow-manager client library.
Request status log is used to to output the status of a request returned by the client.
workflow-manager client library.
Promise
Promise
Promise
Promise
Promise
Promise
Promise
Promise
Promise
Promise
Promise
Object
| function
| function
| function
Promise
Promise
Promise
Promise
Promise
Error
Error
Error
Error
workflow-manager client
Create a new client object.
Param | Type | Default | Description |
---|---|---|---|
options | Object | Options for constructing a client object. | |
[options.address] | string | URL where the server is located. Must provide this or the discovery argument | |
[options.discovery] | bool | Use clever-discovery to locate the server. Must provide this or the address argument | |
[options.timeout] | number | The timeout to use for all client requests, in milliseconds. This can be overridden on a per-request basis. | |
[options.retryPolicy] | RetryPolicies | RetryPolicies.Single | The logic to determine which requests to retry, as well as how many times to retry. |
[options.logger] | module:kayvee.Logger | logger.New("workflow-manager-wagclient") | The Kayvee logger to use in the client. |
[options.circuit] | Object | Options for constructing the client's circuit breaker. | |
[options.circuit.forceClosed] | bool | When set to true the circuit will always be closed. Default: true. | |
[options.circuit.maxConcurrentRequests] | number | the maximum number of concurrent requests the client can make at the same time. Default: 100. | |
[options.circuit.requestVolumeThreshold] | number | The minimum number of requests needed before a circuit can be tripped due to health. Default: 20. | |
[options.circuit.sleepWindow] | number | how long, in milliseconds, to wait after a circuit opens before testing for recovery. Default: 5000. | |
[options.circuit.errorPercentThreshold] | number | the threshold to place on the rolling error rate. Once the error rate exceeds this percentage, the circuit opens. Default: 90. |
Promise
Checks if the service is healthy
Kind: instance method of WorkflowManager
Fulfill: undefined
Reject: BadRequest
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
NewStateResource | ||
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: undefined
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.namespace | string | |
params.name | string | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.namespace | string | |
params.name | string | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.namespace | string | |
params.name | string | |
[params.NewStateResource] | ||
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Get the latest versions of all available WorkflowDefinitions
Kind: instance method of WorkflowManager
Fulfill: Object[]
Reject: BadRequest
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
NewWorkflowDefinitionRequest | ||
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object[]
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Default | Description |
---|---|---|---|
params | Object | ||
params.name | string | ||
[params.latest] | boolean | true | |
[options] | object | ||
[options.timeout] | number | A request specific timeout | |
[options.span] | Span | An OpenTracing span - For example from the parent request | |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy | |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
[params.NewWorkflowDefinitionRequest] | ||
params.name | string | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.name | string | |
params.version | number | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object[]
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Default | Description |
---|---|---|---|
params | Object | ||
[params.limit] | number | 10 | Maximum number of workflows to return. Defaults to 10. Restricted to a max of 10,000. |
[params.oldestFirst] | boolean | ||
[params.pageToken] | string | ||
[params.status] | string | The status of the workflow (queued, running, etc.). Cannot be sent in the same request as the resolvedByUser parameter. | |
[params.resolvedByUser] | boolean | A flag that indicates whether the workflow has been marked resolved by a user. Cannot be sent in the same request as the status parameter. | |
[params.summaryOnly] | boolean | Limits workflow data to the bare minimum - omits the full workflow definition and job data. | |
params.workflowDefinitionName | string | ||
[options] | object | ||
[options.timeout] | number | A request specific timeout | |
[options.span] | Span | An OpenTracing span - For example from the parent request | |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy | |
[cb] | function |
Object
| function
| function
| function
Kind: instance method of WorkflowManager
Returns: Object
- iterfunction
- iter.map - takes in a function, applies it to each resource, and returns a promise to the result as an arrayfunction
- iter.toArray - returns a promise to the resources as an arrayfunction
- iter.forEach - takes in a function, applies it to each resource
Param | Type | Default | Description |
---|---|---|---|
params | Object | ||
[params.limit] | number | 10 | Maximum number of workflows to return. Defaults to 10. Restricted to a max of 10,000. |
[params.oldestFirst] | boolean | ||
[params.pageToken] | string | ||
[params.status] | string | The status of the workflow (queued, running, etc.). Cannot be sent in the same request as the resolvedByUser parameter. | |
[params.resolvedByUser] | boolean | A flag that indicates whether the workflow has been marked resolved by a user. Cannot be sent in the same request as the status parameter. | |
[params.summaryOnly] | boolean | Limits workflow data to the bare minimum - omits the full workflow definition and job data. | |
params.workflowDefinitionName | string | ||
[options] | object | ||
[options.timeout] | number | A request specific timeout | |
[options.span] | Span | An OpenTracing span - For example from the parent request | |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
StartWorkflowRequest | Parameters for starting a workflow (workflow definition, input, and optionally namespace, queue, and tags) | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: undefined
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.workflowID | string | |
params.reason | ||
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
workflowID | string | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
params | Object | |
params.workflowID | string | |
params.overrides | ||
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Promise
Kind: instance method of WorkflowManager
Fulfill: undefined
Reject: BadRequest
Reject: NotFound
Reject: Conflict
Reject: InternalError
Reject: Error
Param | Type | Description |
---|---|---|
workflowID | string | |
[options] | object | |
[options.timeout] | number | A request specific timeout |
[options.span] | Span | An OpenTracing span - For example from the parent request |
[options.retryPolicy] | RetryPolicies | A request specific retryPolicy |
[cb] | function |
Retry policies available to use.
Kind: static property of WorkflowManager
The exponential retry policy will retry five times with an exponential backoff.
Kind: static constant of RetryPolicies
Use this retry policy to retry a request once.
Kind: static constant of RetryPolicies
Use this retry policy to turn off retries.
Kind: static constant of RetryPolicies
Errors returned by methods.
Kind: static property of WorkflowManager
Error
Error
Error
Error
Error
BadRequest
Kind: static class of Errors
Extends: Error
Properties
Name | Type |
---|---|
message | string |
Error
InternalError
Kind: static class of Errors
Extends: Error
Properties
Name | Type |
---|---|
message | string |
Error
NotFound
Kind: static class of Errors
Extends: Error
Properties
Name | Type |
---|---|
message | string |
Error
Conflict
Kind: static class of Errors
Extends: Error
Properties
Name | Type |
---|---|
message | string |
Default circuit breaker options.
Kind: static constant of WorkflowManager
Request status log is used to to output the status of a request returned by the client.
Kind: global function
FAQs
Orchestrator for AWS Step Functions
The npm package workflow-manager receives a total of 135 weekly downloads. As such, workflow-manager popularity was classified as not popular.
We found that workflow-manager demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 3 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Product
Socket now supports four distinct alert actions instead of the previous two, and alert triaging allows users to override the actions taken for all individual alerts.
Security News
Polyfill.io has been serving malware for months via its CDN, after the project's open source maintainer sold the service to a company based in China.
Security News
OpenSSF is warning open source maintainers to stay vigilant against reputation farming on GitHub, where users artificially inflate their status by manipulating interactions on closed issues and PRs.