workflow-manager

Modules

workflow-manager

workflow-manager client library.

Functions

responseLog()

Request status log is used to to output the status of a request returned by the client.

workflow-manager

workflow-manager client library.

• workflow-manager
  • WorkflowManager ⏏
    • new WorkflowManager(options)
    • instance
      • .healthCheck([options], [cb]) ⇒ Promise
      • .getJobsForWorkflow(workflowName, [options], [cb]) ⇒ Promise
      • .startJobForWorkflow(input, [options], [cb]) ⇒ Promise
      • .CancelJob(params, [options], [cb]) ⇒ Promise
      • .GetJob(jobId, [options], [cb]) ⇒ Promise
      • .postStateResource(NewStateResource, [options], [cb]) ⇒ Promise
      • .deleteStateResource(params, [options], [cb]) ⇒ Promise
      • .getStateResource(params, [options], [cb]) ⇒ Promise
      • .putStateResource(params, [options], [cb]) ⇒ Promise
      • .getWorkflows([options], [cb]) ⇒ Promise
      • .newWorkflow(NewWorkflowRequest, [options], [cb]) ⇒ Promise
      • .getWorkflowVersionsByName(params, [options], [cb]) ⇒ Promise
      • .updateWorkflow(params, [options], [cb]) ⇒ Promise
      • .getWorkflowByNameAndVersion(params, [options], [cb]) ⇒ Promise
    • static
      • .RetryPolicies
        • .Exponential
        • .Single
        • .None
      • .Errors
        • .BadRequest ⇐ Error
        • .InternalError ⇐ Error
        • .NotFound ⇐ Error
      • .DefaultCircuitOptions

WorkflowManager ⏏

workflow-manager client

Kind: Exported class

new WorkflowManager(options)

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.

workflowManager.healthCheck([options], [cb]) ⇒ 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

workflowManager.getJobsForWorkflow(workflowName, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: Object[]
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error

Param	Type	Description
workflowName	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

workflowManager.startJobForWorkflow(input, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error

Param	Type	Description
input
[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

workflowManager.CancelJob(params, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: undefined
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error

Param	Type	Description
params	Object
params.jobId	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

workflowManager.GetJob(jobId, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error

Param	Type	Description
jobId	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

workflowManager.postStateResource(NewStateResource, [options], [cb]) ⇒ 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

workflowManager.deleteStateResource(params, [options], [cb]) ⇒ 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

workflowManager.getStateResource(params, [options], [cb]) ⇒ 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

workflowManager.putStateResource(params, [options], [cb]) ⇒ 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

workflowManager.getWorkflows([options], [cb]) ⇒ Promise

Get the latest versions of all available workflows

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

workflowManager.newWorkflow(NewWorkflowRequest, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: InternalError
Reject: Error

Param	Type	Description
NewWorkflowRequest
[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

workflowManager.getWorkflowVersionsByName(params, [options], [cb]) ⇒ 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

workflowManager.updateWorkflow(params, [options], [cb]) ⇒ Promise

Kind: instance method of WorkflowManager
Fulfill: Object
Reject: BadRequest
Reject: NotFound
Reject: InternalError
Reject: Error

Param	Type	Description
params	Object
[params.NewWorkflowRequest]
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

workflowManager.getWorkflowByNameAndVersion(params, [options], [cb]) ⇒ 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

WorkflowManager.RetryPolicies

Retry policies available to use.

Kind: static property of WorkflowManager

• .RetryPolicies
  • .Exponential
  • .Single
  • .None

RetryPolicies.Exponential

The exponential retry policy will retry five times with an exponential backoff.

Kind: static constant of RetryPolicies

RetryPolicies.Single

Use this retry policy to retry a request once.

Kind: static constant of RetryPolicies

RetryPolicies.None

Use this retry policy to turn off retries.

Kind: static constant of RetryPolicies

WorkflowManager.Errors

Errors returned by methods.

Kind: static property of WorkflowManager

• .Errors
  • .BadRequest ⇐ Error
  • .InternalError ⇐ Error
  • .NotFound ⇐ Error

Errors.BadRequest ⇐ Error

BadRequest

Kind: static class of Errors
Extends: Error
Properties

Name	Type
message	string

Errors.InternalError ⇐ Error

InternalError

Kind: static class of Errors
Extends: Error
Properties

Name	Type
message	string

Errors.NotFound ⇐ Error

NotFound

Kind: static class of Errors
Extends: Error
Properties

Name	Type
message	string

WorkflowManager.DefaultCircuitOptions

Default circuit breaker options.

Kind: static constant of WorkflowManager

responseLog()

Request status log is used to to output the status of a request returned by the client.

Kind: global function