Variables
Const ACTIVITY_POLLER_FACTORY
ACTIVITY_POLLER_FACTORY: unique symbol = Symbol('ACTIVITY_POLLER_FACTORY')
Const ACTIVITY_RUN_CONTEXT
ACTIVITY_RUN_CONTEXT: unique symbol = Symbol('ACTIVITY_RUN_CONTEXT')
Const ACTIVITY_RUN_CONTEXT_ZONE_KEY
ACTIVITY_RUN_CONTEXT_ZONE_KEY: "ACTIVITY_RUN_CONTEXT_ZONE_KEY" = "ACTIVITY_RUN_CONTEXT_ZONE_KEY"
Const ACTOR_CLIENT_TAG
ACTOR_CLIENT_TAG: "actor-client" = "actor-client"
Const ACTOR_WORKER_FACTORY
ACTOR_WORKER_FACTORY: unique symbol = Symbol('ACTOR_WORKER_FACTORY')
Const APPLICATION_CONFIGURATION
APPLICATION_CONFIGURATION: unique symbol = Symbol('APPLICATION_CONFIGURATION')
Const APP_CONTAINER
APP_CONTAINER: unique symbol = Symbol('APP_KERNEL')
Const AWS_ADAPTER
AWS_ADAPTER: unique symbol = Symbol('AWS_ADAPTER')
Const AWS_SWF_NATIVE_CLIENT
AWS_SWF_NATIVE_CLIENT: unique symbol = Symbol('AWS_SWF_NATIVE_CLIENT')
Const CANCELLED_TRANSITION
CANCELLED_
TRANSITION: EventType[] = [EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskCancelRequested,EventType.ActivityTaskCanceled,]
Const CANCEL_FAILED_TRANSITION
CANCEL_
FAILED_TRANSITION: EventType[] = [EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskCancelRequested,EventType.RequestCancelActivityTaskFailed,]
Const COMPLETED_TRANSITION
COMPLETED_
TRANSITION: EventType[] = [EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskCompleted,]
Const CONTEXT_CACHE
CONTEXT_CACHE: unique symbol = Symbol('CONTEXT_CACHE')
Const CORE
CORE: ContainerModule = new ContainerModule((bind: interfaces.Bind) => {bind<AWSClientProvider>(AWS_ADAPTER).to(DefaultAWSClientProvider).inSingletonScope();bind<WorkflowClient>(WORKFLOW_CLIENT).to(BaseWorkflowClient).inSingletonScope();bind<ActivityPollerFactory>(ACTIVITY_POLLER_FACTORY).to(GenericActivityPollerFactory).inSingletonScope();bind<DecisionPollerFactory>(DECISION_POLLER_FACTORY).to(GenericDecisionPollerFactory).inSingletonScope();bind<ImplementationHelper>(IMPLEMENTATION_HELPER).to(BaseImplementationHelper).inSingletonScope();bind<WorkflowClientFactory>(WORKFLOW_REMOTE_CLIENT_FACTORY).to(BaseRemoteWorkflowClientFactory).inSingletonScope();bind<ActorProxyFactory>(REMOTE_ACTOR_PROXY_FACTORY).to(RemoteActorProxyFactory).inSingletonScope();bind<Workflows>(WORKFLOWS).to(BaseWorkflows).inSingletonScope();bind<UuidGenerator>(UUID_GENERATOR).to(BaseUuidGenerator).inSingletonScope();bind<WorkflowWorkerFactory>(WORKFLOW_WORKER_FACTORY).to(BaseWorkflowWorkerFactory).inSingletonScope();bind<ContextCache>(CONTEXT_CACHE).to(BaseContextCache).inSingletonScope();bind<ContextResolutionStrategy<DecisionRunContext>>(DECISION_CONTEXT_RESOLUTION).toConstantValue(new ZoneContextResolutionStrategy<DecisionRunContext>(DECISION_RUN_CONTEXT_ZONE_KEY));bind<RemoteActivityAdapterFactory>(REMOTE_ACTIVITY_ADAPTER_FACTORY).to(DefaultRemoteActivityAdapterFactory).inSingletonScope();bind<ActorWorkerFactory>(ACTOR_WORKER_FACTORY).to(BaseActorWorkerFactory).inSingletonScope();bind<Logger>(LOGGER).to(DefaultLogger).inRequestScope();})
Const DECISION_CONTEXT_RESOLUTION
DECISION_CONTEXT_RESOLUTION: unique symbol = Symbol('DECISION_CONTEXT_RESOLUTION')
Const DECISION_POLLER_FACTORY
DECISION_POLLER_FACTORY: unique symbol = Symbol('DECISION_POLLER_FACTORY')
Const DECISION_RUN_CONTEXT
DECISION_RUN_CONTEXT: unique symbol = Symbol('DECISION_RUN_CONTEXT')
Const DECISION_RUN_CONTEXT_ZONE_KEY
DECISION_RUN_CONTEXT_ZONE_KEY: "DECISION_RUN_CONTEXT_ZONE_KEY" = "DECISION_RUN_CONTEXT_ZONE_KEY"
Const DEFAULT_ACTOR_TASK_LIST
DEFAULT_ACTOR_TASK_LIST: "default" = "default"
Const DEFINITION_SYMBOL
DEFINITION_SYMBOL: unique symbol = Symbol('DEFINITION_SYMBOL')
Const FAILED_TRANSITION
FAILED_
TRANSITION: EventType[] = [EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskFailed,]
Const IMPLEMENTATION_HELPER
IMPLEMENTATION_HELPER: unique symbol = Symbol('IMPLEMENTATION_HELPER')
Const LOGGER
LOGGER: unique symbol = Symbol('LOGGER')
Const REMOTE_ACTIVITY_ADAPTER_FACTORY
REMOTE_ACTIVITY_ADAPTER_FACTORY: unique symbol = Symbol('REMOTE_ACTIVITY_ADAPTER_FACTORY')
Const REMOTE_ACTOR_PROXY_FACTORY
REMOTE_ACTOR_PROXY_FACTORY: unique symbol = Symbol('REMOTE_ACTOR_PROXY_FACTORY')
Const TASK_LIST_TAG
TASK_LIST_TAG: "task-list-tag" = "task-list-tag"
Const TEST_ACTOR
TEST_ACTOR: unique symbol = Symbol('TEST_ACTOR')
Const TEST_PROPERTY
TEST_PROPERTY: "testProperty" = "testProperty"
Const TEST_PROPERTY_2
TEST_PROPERTY_2: "testProperty2" = "testProperty2"
Const TEST_TRANSITION_TABLE
TEST_
TRANSITION_TABLE: TransitionTable<TestStates> = [[TestStates.test1, TestStates.test2],[TestStates.test2, TestStates.test3],]
Const TEST_WF
TEST_WF: unique symbol = Symbol('TEST_WF')
Const TEST_WORKFLOW
TEST_WORKFLOW: unique symbol = Symbol('TEST_WORKFLOW')
Const TIMEOUTED_TRANSITION
TIMEOUTED_
TRANSITION: EventType[] = [EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskTimedOut,]
Const TRANSITION_TABLE
TRANSITION_
TABLE: TransitionTable<WES> = [[WES.Created, WES.CanceledBeforeSent],[WES.Created, WES.Sending],[WES.Sending, WES.Sent],[WES.Sent, WES.CancelledAfterSent],[WES.Sent, WES.Started],[WES.Created, WES.Started],[WES.Started, WES.CancelRequested],[WES.CancelRequested, WES.Canceled],[WES.CancelRequested, WES.CancelFailed],[WES.Started, WES.CompletedStateRequested],[WES.Started, WES.Completed],[WES.Started, WES.CompleteFailed],[WES.Started, WES.TimedOut],[WES.Started, WES.Terminated],[WES.Started, WES.ContinuedAsNew],[WES.Started, WES.ContinueAsNewFailed],[WES.CompletedStateRequested, WES.Completed],[WES.CompletedStateRequested, WES.CompleteFailed],[WES.CompletedStateRequested, WES.TimedOut],[WES.CompletedStateRequested, WES.Terminated],[WES.Started, WES.ExecutionFailedStateRequested],[WES.Started, WES.ExecutionFailed],[WES.ExecutionFailedStateRequested, WES.ExecutionFailed],[WES.Started, WES.FailFailed],]
Const UUID_GENERATOR
UUID_GENERATOR: unique symbol = Symbol('UUID_GENERATOR')
Const WORKFLOWS
WORKFLOWS: unique symbol = Symbol('WORKFLOWS')
Const WORKFLOW_CLIENT
WORKFLOW_CLIENT: unique symbol = Symbol('WORKFLOW_CLIENT')
Const WORKFLOW_CLIENT_TAG
WORKFLOW_CLIENT_TAG: "workflow-client-tag" = "workflow-client-tag"
Const WORKFLOW_LOCAL_CLIENT_FACTORY
WORKFLOW_LOCAL_CLIENT_FACTORY: unique symbol = Symbol('WORKFLOW_LOCAL_CLIENT_FACTORY')
Const WORKFLOW_REMOTE_CLIENT_FACTORY
WORKFLOW_REMOTE_CLIENT_FACTORY: unique symbol = Symbol('WORKFLOW_REMOTE_CLIENT_FACTORY')
Const WORKFLOW_STARTED_AND_COMPLETED_TRANSITION
WORKFLOW_
STARTED_AND_COMPLETED_TRANSITION: EventType[] = [EventType.WorkflowExecutionStarted,EventType.ActivityTaskScheduled,EventType.ActivityTaskStarted,EventType.ActivityTaskCompleted,EventType.WorkflowExecutionCompleted,]
Const WORKFLOW_WORKER_FACTORY
WORKFLOW_WORKER_FACTORY: unique symbol = Symbol('WORKFLOW_WORKER_FACTORY')
Const activity
activity: function = decoratorFactory<string>('name')
Const activityId
activityId: "12345" = "12345"
Const actorClient
actorClient: function = tagged(ACTOR_CLIENT_TAG, true)
Type declaration
-
- (target: any, targetKey: string, index?: number | undefined): void
-
Parameters
-
target: any
-
targetKey: string
-
Optional index: number | undefined
Returns void
Const arrayConcat
arrayConcat: concat = [].concat
Const childPolicy
childPolicy: function = decoratorFactory<ChildPolicy>('childPolicy')
Const configuration
configuration: function = createDecorator<ApplicationConfiguration>('configuration')
Const defaultChildPolicy
defaultChildPolicy: function = decoratorFactory<ChildPolicy>('defaultChildPolicy')
Const defaultExecutionStartToCloseTimeout
defaultExecutionStartToCloseTimeout: function = decoratorFactory<string>('defaultExecutionStartToCloseTimeout')
Const defaultLambdaRole
defaultLambdaRole: function = decoratorFactory<string>('defaultLambdaRole')
Const defaultTaskHeartbeatTimeout
defaultTaskHeartbeatTimeout: function = decoratorFactory<string>('defaultTaskHeartbeatTimeout')
Const defaultTaskList
defaultTaskList: function = decoratorFactory<TaskList>('defaultTaskList')
Const defaultTaskPriority
defaultTaskPriority: function = decoratorFactory<string>('defaultTaskPriority')
Const defaultTaskScheduleToCloseTimeout
defaultTaskScheduleToCloseTimeout: function = decoratorFactory<string>('defaultTaskScheduleToCloseTimeout')
Const defaultTaskScheduleToStartTimeout
defaultTaskScheduleToStartTimeout: function = decoratorFactory<string>('defaultTaskScheduleToStartTimeout')
Const defaultTaskStartToCloseTimeout
defaultTaskStartToCloseTimeout: function = decoratorFactory<string>('defaultTaskStartToCloseTimeout')
Const description
description: function = decoratorFactory<string>('description')
Const domain
domain: "expectedDomain" = "expectedDomain"
Const executionStartToCloseTimeout
executionStartToCloseTimeout: function = decoratorFactory<string>('executionStartToCloseTimeout')
Const expect
expect: ExpectStatic = chai.expect
Const heartbeatTimeout
heartbeatTimeout: function = decoratorFactory<string>('heartbeatTimeout')
Const lambdaRole
lambdaRole: function = decoratorFactory<string>('lambdaRole')
Const name
name: function = decoratorFactory<string>('name')
Const scheduleToCloseTimeout
scheduleToCloseTimeout: function = decoratorFactory<string>('scheduleToCloseTimeout')
Const scheduleToStartTimeout
scheduleToStartTimeout: function = decoratorFactory<string>('scheduleToStartTimeout')
Const serializer
serializer: function = decoratorFactory<Serializer>('serializer')
Const services
services: function = createDecorator<Binding[]>('services')
Const startToCloseTimeout
startToCloseTimeout: function = decoratorFactory<string>('startToCloseTimeout')
Const swf
swf: SWF = new SWF({ region: 'us-east-1' })
Const tagList
tagList: function = decoratorFactory<string[]>('tagList')
Const taskList
taskList: "expectedTaskList" = "expectedTaskList"
Const taskPriority
taskPriority: function = decoratorFactory<string>('taskPriority')
Const taskStartToCloseTimeout
taskStartToCloseTimeout: function = decoratorFactory<string>('taskStartToCloseTimeout')
Const testActivityName
testActivityName: "TestActivityName" = "TestActivityName"
Const testActivityVersion
testActivityVersion: "test-version-123" = "test-version-123"
Const testActorSymbol
testActorSymbol: unique symbol = Symbol('testActorSymbol')
Const testDeciderSymbol
testDeciderSymbol: unique symbol = Symbol('testDeciderSymbol')
Const testTaskList
testTaskList: "test-task-list" = "test-task-list"
Const testWorkflowSymbol
testWorkflowSymbol: unique symbol = Symbol('test wf symbol')
Const version
version: function = decoratorFactory<string>('version')
Const workflow
workflow: function = decoratorFactory<string>('name')
Const workflowClient
workflowClient: function = tagged(WORKFLOW_CLIENT_TAG, true)
Type declaration
-
- (target: any, targetKey: string, index?: number | undefined): void
-
Parameters
-
target: any
-
targetKey: string
-
Optional index: number | undefined
Returns void