Documentation ¶
Overview ¶
Package swf provides a client for Amazon Simple Workflow Service.
Index ¶
- Constants
- type ActivityTask
- type ActivityTaskCancelRequestedEventAttributes
- type ActivityTaskCanceledEventAttributes
- type ActivityTaskCompletedEventAttributes
- type ActivityTaskFailedEventAttributes
- type ActivityTaskScheduledEventAttributes
- type ActivityTaskStartedEventAttributes
- type ActivityTaskStatus
- type ActivityTaskTimedOutEventAttributes
- type ActivityType
- type ActivityTypeConfiguration
- type ActivityTypeDetail
- type ActivityTypeInfo
- type ActivityTypeInfos
- type CancelTimerDecisionAttributes
- type CancelTimerFailedEventAttributes
- type CancelWorkflowExecutionDecisionAttributes
- type CancelWorkflowExecutionFailedEventAttributes
- type ChildWorkflowExecutionCanceledEventAttributes
- type ChildWorkflowExecutionCompletedEventAttributes
- type ChildWorkflowExecutionFailedEventAttributes
- type ChildWorkflowExecutionStartedEventAttributes
- type ChildWorkflowExecutionTerminatedEventAttributes
- type ChildWorkflowExecutionTimedOutEventAttributes
- type CloseStatusFilter
- type CompleteWorkflowExecutionDecisionAttributes
- type CompleteWorkflowExecutionFailedEventAttributes
- type ContinueAsNewWorkflowExecutionDecisionAttributes
- type ContinueAsNewWorkflowExecutionFailedEventAttributes
- type CountClosedWorkflowExecutionsInput
- type CountOpenWorkflowExecutionsInput
- type CountPendingActivityTasksInput
- type CountPendingDecisionTasksInput
- type Decision
- type DecisionTask
- type DecisionTaskCompletedEventAttributes
- type DecisionTaskScheduledEventAttributes
- type DecisionTaskStartedEventAttributes
- type DecisionTaskTimedOutEventAttributes
- type DeprecateActivityTypeInput
- type DeprecateDomainInput
- type DeprecateWorkflowTypeInput
- type DescribeActivityTypeInput
- type DescribeDomainInput
- type DescribeWorkflowExecutionInput
- type DescribeWorkflowTypeInput
- type DomainConfiguration
- type DomainDetail
- type DomainInfo
- type DomainInfos
- type ExecutionTimeFilter
- type ExternalWorkflowExecutionCancelRequestedEventAttributes
- type ExternalWorkflowExecutionSignaledEventAttributes
- type FailWorkflowExecutionDecisionAttributes
- type FailWorkflowExecutionFailedEventAttributes
- type GetWorkflowExecutionHistoryInput
- type History
- type HistoryEvent
- type ListActivityTypesInput
- type ListClosedWorkflowExecutionsInput
- type ListDomainsInput
- type ListOpenWorkflowExecutionsInput
- type ListWorkflowTypesInput
- type MarkerRecordedEventAttributes
- type PendingTaskCount
- type PollForActivityTaskInput
- type PollForDecisionTaskInput
- type RecordActivityTaskHeartbeatInput
- type RecordMarkerDecisionAttributes
- type RecordMarkerFailedEventAttributes
- type RegisterActivityTypeInput
- type RegisterDomainInput
- type RegisterWorkflowTypeInput
- type RequestCancelActivityTaskDecisionAttributes
- type RequestCancelActivityTaskFailedEventAttributes
- type RequestCancelExternalWorkflowExecutionDecisionAttributes
- type RequestCancelExternalWorkflowExecutionFailedEventAttributes
- type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
- type RequestCancelWorkflowExecutionInput
- type RespondActivityTaskCanceledInput
- type RespondActivityTaskCompletedInput
- type RespondActivityTaskFailedInput
- type RespondDecisionTaskCompletedInput
- type Run
- type SWF
- func (c *SWF) CountClosedWorkflowExecutions(req *CountClosedWorkflowExecutionsInput) (resp *WorkflowExecutionCount, err error)
- func (c *SWF) CountOpenWorkflowExecutions(req *CountOpenWorkflowExecutionsInput) (resp *WorkflowExecutionCount, err error)
- func (c *SWF) CountPendingActivityTasks(req *CountPendingActivityTasksInput) (resp *PendingTaskCount, err error)
- func (c *SWF) CountPendingDecisionTasks(req *CountPendingDecisionTasksInput) (resp *PendingTaskCount, err error)
- func (c *SWF) DeprecateActivityType(req *DeprecateActivityTypeInput) (err error)
- func (c *SWF) DeprecateDomain(req *DeprecateDomainInput) (err error)
- func (c *SWF) DeprecateWorkflowType(req *DeprecateWorkflowTypeInput) (err error)
- func (c *SWF) DescribeActivityType(req *DescribeActivityTypeInput) (resp *ActivityTypeDetail, err error)
- func (c *SWF) DescribeDomain(req *DescribeDomainInput) (resp *DomainDetail, err error)
- func (c *SWF) DescribeWorkflowExecution(req *DescribeWorkflowExecutionInput) (resp *WorkflowExecutionDetail, err error)
- func (c *SWF) DescribeWorkflowType(req *DescribeWorkflowTypeInput) (resp *WorkflowTypeDetail, err error)
- func (c *SWF) GetWorkflowExecutionHistory(req *GetWorkflowExecutionHistoryInput) (resp *History, err error)
- func (c *SWF) ListActivityTypes(req *ListActivityTypesInput) (resp *ActivityTypeInfos, err error)
- func (c *SWF) ListClosedWorkflowExecutions(req *ListClosedWorkflowExecutionsInput) (resp *WorkflowExecutionInfos, err error)
- func (c *SWF) ListDomains(req *ListDomainsInput) (resp *DomainInfos, err error)
- func (c *SWF) ListOpenWorkflowExecutions(req *ListOpenWorkflowExecutionsInput) (resp *WorkflowExecutionInfos, err error)
- func (c *SWF) ListWorkflowTypes(req *ListWorkflowTypesInput) (resp *WorkflowTypeInfos, err error)
- func (c *SWF) PollForActivityTask(req *PollForActivityTaskInput) (resp *ActivityTask, err error)
- func (c *SWF) PollForDecisionTask(req *PollForDecisionTaskInput) (resp *DecisionTask, err error)
- func (c *SWF) RecordActivityTaskHeartbeat(req *RecordActivityTaskHeartbeatInput) (resp *ActivityTaskStatus, err error)
- func (c *SWF) RegisterActivityType(req *RegisterActivityTypeInput) (err error)
- func (c *SWF) RegisterDomain(req *RegisterDomainInput) (err error)
- func (c *SWF) RegisterWorkflowType(req *RegisterWorkflowTypeInput) (err error)
- func (c *SWF) RequestCancelWorkflowExecution(req *RequestCancelWorkflowExecutionInput) (err error)
- func (c *SWF) RespondActivityTaskCanceled(req *RespondActivityTaskCanceledInput) (err error)
- func (c *SWF) RespondActivityTaskCompleted(req *RespondActivityTaskCompletedInput) (err error)
- func (c *SWF) RespondActivityTaskFailed(req *RespondActivityTaskFailedInput) (err error)
- func (c *SWF) RespondDecisionTaskCompleted(req *RespondDecisionTaskCompletedInput) (err error)
- func (c *SWF) SignalWorkflowExecution(req *SignalWorkflowExecutionInput) (err error)
- func (c *SWF) StartWorkflowExecution(req *StartWorkflowExecutionInput) (resp *Run, err error)
- func (c *SWF) TerminateWorkflowExecution(req *TerminateWorkflowExecutionInput) (err error)
- type ScheduleActivityTaskDecisionAttributes
- type ScheduleActivityTaskFailedEventAttributes
- type SignalExternalWorkflowExecutionDecisionAttributes
- type SignalExternalWorkflowExecutionFailedEventAttributes
- type SignalExternalWorkflowExecutionInitiatedEventAttributes
- type SignalWorkflowExecutionInput
- type StartChildWorkflowExecutionDecisionAttributes
- type StartChildWorkflowExecutionFailedEventAttributes
- type StartChildWorkflowExecutionInitiatedEventAttributes
- type StartTimerDecisionAttributes
- type StartTimerFailedEventAttributes
- type StartWorkflowExecutionInput
- type TagFilter
- type TaskList
- type TerminateWorkflowExecutionInput
- type TimerCanceledEventAttributes
- type TimerFiredEventAttributes
- type TimerStartedEventAttributes
- type WorkflowExecution
- type WorkflowExecutionCancelRequestedEventAttributes
- type WorkflowExecutionCanceledEventAttributes
- type WorkflowExecutionCompletedEventAttributes
- type WorkflowExecutionConfiguration
- type WorkflowExecutionContinuedAsNewEventAttributes
- type WorkflowExecutionCount
- type WorkflowExecutionDetail
- type WorkflowExecutionFailedEventAttributes
- type WorkflowExecutionFilter
- type WorkflowExecutionInfo
- type WorkflowExecutionInfos
- type WorkflowExecutionOpenCounts
- type WorkflowExecutionSignaledEventAttributes
- type WorkflowExecutionStartedEventAttributes
- type WorkflowExecutionTerminatedEventAttributes
- type WorkflowExecutionTimedOutEventAttributes
- type WorkflowType
- type WorkflowTypeConfiguration
- type WorkflowTypeDetail
- type WorkflowTypeFilter
- type WorkflowTypeInfo
- type WorkflowTypeInfos
Constants ¶
const ( ActivityTaskTimeoutTypeHeartbeat = "HEARTBEAT" ActivityTaskTimeoutTypeScheduleToClose = "SCHEDULE_TO_CLOSE" ActivityTaskTimeoutTypeScheduleToStart = "SCHEDULE_TO_START" ActivityTaskTimeoutTypeStartToClose = "START_TO_CLOSE" )
Possible values for SWF.
const ( CancelTimerFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" CancelTimerFailedCauseTimerIDUnknown = "TIMER_ID_UNKNOWN" )
Possible values for SWF.
const ( CancelWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" CancelWorkflowExecutionFailedCauseUnhandledDecision = "UNHANDLED_DECISION" )
Possible values for SWF.
const ( ChildPolicyAbandon = "ABANDON" ChildPolicyRequestCancel = "REQUEST_CANCEL" ChildPolicyTerminate = "TERMINATE" )
Possible values for SWF.
const ( CloseStatusCanceled = "CANCELED" CloseStatusCompleted = "COMPLETED" CloseStatusContinuedAsNew = "CONTINUED_AS_NEW" CloseStatusFailed = "FAILED" CloseStatusTerminated = "TERMINATED" CloseStatusTimedOut = "TIMED_OUT" )
Possible values for SWF.
const ( CompleteWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" CompleteWorkflowExecutionFailedCauseUnhandledDecision = "UNHANDLED_DECISION" )
Possible values for SWF.
const ( ContinueAsNewWorkflowExecutionFailedCauseDefaultChildPolicyUndefined = "DEFAULT_CHILD_POLICY_UNDEFINED" ContinueAsNewWorkflowExecutionFailedCauseDefaultExecutionStartToCloseTimeoutUndefined = "DEFAULT_EXECUTION_START_TO_CLOSE_TIMEOUT_UNDEFINED" ContinueAsNewWorkflowExecutionFailedCauseDefaultTaskListUndefined = "DEFAULT_TASK_LIST_UNDEFINED" ContinueAsNewWorkflowExecutionFailedCauseDefaultTaskStartToCloseTimeoutUndefined = "DEFAULT_TASK_START_TO_CLOSE_TIMEOUT_UNDEFINED" ContinueAsNewWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" ContinueAsNewWorkflowExecutionFailedCauseUnhandledDecision = "UNHANDLED_DECISION" ContinueAsNewWorkflowExecutionFailedCauseWorkflowTypeDeprecated = "WORKFLOW_TYPE_DEPRECATED" ContinueAsNewWorkflowExecutionFailedCauseWorkflowTypeDoesNotExist = "WORKFLOW_TYPE_DOES_NOT_EXIST" )
Possible values for SWF.
const ( DecisionTypeCancelTimer = "CancelTimer" DecisionTypeCancelWorkflowExecution = "CancelWorkflowExecution" DecisionTypeCompleteWorkflowExecution = "CompleteWorkflowExecution" DecisionTypeContinueAsNewWorkflowExecution = "ContinueAsNewWorkflowExecution" DecisionTypeFailWorkflowExecution = "FailWorkflowExecution" DecisionTypeRecordMarker = "RecordMarker" DecisionTypeRequestCancelActivityTask = "RequestCancelActivityTask" DecisionTypeRequestCancelExternalWorkflowExecution = "RequestCancelExternalWorkflowExecution" DecisionTypeScheduleActivityTask = "ScheduleActivityTask" DecisionTypeSignalExternalWorkflowExecution = "SignalExternalWorkflowExecution" DecisionTypeStartChildWorkflowExecution = "StartChildWorkflowExecution" DecisionTypeStartTimer = "StartTimer" )
Possible values for SWF.
const ( EventTypeActivityTaskCancelRequested = "ActivityTaskCancelRequested" EventTypeActivityTaskCanceled = "ActivityTaskCanceled" EventTypeActivityTaskCompleted = "ActivityTaskCompleted" EventTypeActivityTaskFailed = "ActivityTaskFailed" EventTypeActivityTaskScheduled = "ActivityTaskScheduled" EventTypeActivityTaskStarted = "ActivityTaskStarted" EventTypeActivityTaskTimedOut = "ActivityTaskTimedOut" EventTypeCancelTimerFailed = "CancelTimerFailed" EventTypeCancelWorkflowExecutionFailed = "CancelWorkflowExecutionFailed" EventTypeChildWorkflowExecutionCanceled = "ChildWorkflowExecutionCanceled" EventTypeChildWorkflowExecutionCompleted = "ChildWorkflowExecutionCompleted" EventTypeChildWorkflowExecutionFailed = "ChildWorkflowExecutionFailed" EventTypeChildWorkflowExecutionStarted = "ChildWorkflowExecutionStarted" EventTypeChildWorkflowExecutionTerminated = "ChildWorkflowExecutionTerminated" EventTypeChildWorkflowExecutionTimedOut = "ChildWorkflowExecutionTimedOut" EventTypeCompleteWorkflowExecutionFailed = "CompleteWorkflowExecutionFailed" EventTypeContinueAsNewWorkflowExecutionFailed = "ContinueAsNewWorkflowExecutionFailed" EventTypeDecisionTaskCompleted = "DecisionTaskCompleted" EventTypeDecisionTaskScheduled = "DecisionTaskScheduled" EventTypeDecisionTaskStarted = "DecisionTaskStarted" EventTypeDecisionTaskTimedOut = "DecisionTaskTimedOut" EventTypeExternalWorkflowExecutionCancelRequested = "ExternalWorkflowExecutionCancelRequested" EventTypeExternalWorkflowExecutionSignaled = "ExternalWorkflowExecutionSignaled" EventTypeFailWorkflowExecutionFailed = "FailWorkflowExecutionFailed" EventTypeMarkerRecorded = "MarkerRecorded" EventTypeRecordMarkerFailed = "RecordMarkerFailed" EventTypeRequestCancelActivityTaskFailed = "RequestCancelActivityTaskFailed" EventTypeRequestCancelExternalWorkflowExecutionFailed = "RequestCancelExternalWorkflowExecutionFailed" EventTypeRequestCancelExternalWorkflowExecutionInitiated = "RequestCancelExternalWorkflowExecutionInitiated" EventTypeScheduleActivityTaskFailed = "ScheduleActivityTaskFailed" EventTypeSignalExternalWorkflowExecutionFailed = "SignalExternalWorkflowExecutionFailed" EventTypeSignalExternalWorkflowExecutionInitiated = "SignalExternalWorkflowExecutionInitiated" EventTypeStartChildWorkflowExecutionFailed = "StartChildWorkflowExecutionFailed" EventTypeStartChildWorkflowExecutionInitiated = "StartChildWorkflowExecutionInitiated" EventTypeStartTimerFailed = "StartTimerFailed" EventTypeTimerCanceled = "TimerCanceled" EventTypeTimerFired = "TimerFired" EventTypeTimerStarted = "TimerStarted" EventTypeWorkflowExecutionCancelRequested = "WorkflowExecutionCancelRequested" EventTypeWorkflowExecutionCanceled = "WorkflowExecutionCanceled" EventTypeWorkflowExecutionCompleted = "WorkflowExecutionCompleted" EventTypeWorkflowExecutionContinuedAsNew = "WorkflowExecutionContinuedAsNew" EventTypeWorkflowExecutionFailed = "WorkflowExecutionFailed" EventTypeWorkflowExecutionSignaled = "WorkflowExecutionSignaled" EventTypeWorkflowExecutionStarted = "WorkflowExecutionStarted" EventTypeWorkflowExecutionTerminated = "WorkflowExecutionTerminated" EventTypeWorkflowExecutionTimedOut = "WorkflowExecutionTimedOut" )
Possible values for SWF.
const ( ExecutionStatusClosed = "CLOSED" ExecutionStatusOpen = "OPEN" )
Possible values for SWF.
const ( FailWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" FailWorkflowExecutionFailedCauseUnhandledDecision = "UNHANDLED_DECISION" )
Possible values for SWF.
const ( RegistrationStatusDeprecated = "DEPRECATED" RegistrationStatusRegistered = "REGISTERED" )
Possible values for SWF.
const ( RequestCancelActivityTaskFailedCauseActivityIDUnknown = "ACTIVITY_ID_UNKNOWN" RequestCancelActivityTaskFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" )
Possible values for SWF.
const ( RequestCancelExternalWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" RequestCancelExternalWorkflowExecutionFailedCauseRequestCancelExternalWorkflowExecutionRateExceeded = "REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_RATE_EXCEEDED" RequestCancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution = "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION" )
Possible values for SWF.
const ( ScheduleActivityTaskFailedCauseActivityCreationRateExceeded = "ACTIVITY_CREATION_RATE_EXCEEDED" ScheduleActivityTaskFailedCauseActivityIDAlreadyInUse = "ACTIVITY_ID_ALREADY_IN_USE" ScheduleActivityTaskFailedCauseActivityTypeDeprecated = "ACTIVITY_TYPE_DEPRECATED" ScheduleActivityTaskFailedCauseActivityTypeDoesNotExist = "ACTIVITY_TYPE_DOES_NOT_EXIST" ScheduleActivityTaskFailedCauseDefaultHeartbeatTimeoutUndefined = "DEFAULT_HEARTBEAT_TIMEOUT_UNDEFINED" ScheduleActivityTaskFailedCauseDefaultScheduleToCloseTimeoutUndefined = "DEFAULT_SCHEDULE_TO_CLOSE_TIMEOUT_UNDEFINED" ScheduleActivityTaskFailedCauseDefaultScheduleToStartTimeoutUndefined = "DEFAULT_SCHEDULE_TO_START_TIMEOUT_UNDEFINED" ScheduleActivityTaskFailedCauseDefaultStartToCloseTimeoutUndefined = "DEFAULT_START_TO_CLOSE_TIMEOUT_UNDEFINED" ScheduleActivityTaskFailedCauseDefaultTaskListUndefined = "DEFAULT_TASK_LIST_UNDEFINED" ScheduleActivityTaskFailedCauseOpenActivitiesLimitExceeded = "OPEN_ACTIVITIES_LIMIT_EXCEEDED" ScheduleActivityTaskFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" )
Possible values for SWF.
const ( SignalExternalWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" SignalExternalWorkflowExecutionFailedCauseSignalExternalWorkflowExecutionRateExceeded = "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_RATE_EXCEEDED" SignalExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution = "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION" )
Possible values for SWF.
const ( StartChildWorkflowExecutionFailedCauseChildCreationRateExceeded = "CHILD_CREATION_RATE_EXCEEDED" StartChildWorkflowExecutionFailedCauseDefaultChildPolicyUndefined = "DEFAULT_CHILD_POLICY_UNDEFINED" StartChildWorkflowExecutionFailedCauseDefaultExecutionStartToCloseTimeoutUndefined = "DEFAULT_EXECUTION_START_TO_CLOSE_TIMEOUT_UNDEFINED" StartChildWorkflowExecutionFailedCauseDefaultTaskListUndefined = "DEFAULT_TASK_LIST_UNDEFINED" StartChildWorkflowExecutionFailedCauseDefaultTaskStartToCloseTimeoutUndefined = "DEFAULT_TASK_START_TO_CLOSE_TIMEOUT_UNDEFINED" StartChildWorkflowExecutionFailedCauseOpenChildrenLimitExceeded = "OPEN_CHILDREN_LIMIT_EXCEEDED" StartChildWorkflowExecutionFailedCauseOpenWorkflowsLimitExceeded = "OPEN_WORKFLOWS_LIMIT_EXCEEDED" StartChildWorkflowExecutionFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" StartChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning = "WORKFLOW_ALREADY_RUNNING" StartChildWorkflowExecutionFailedCauseWorkflowTypeDeprecated = "WORKFLOW_TYPE_DEPRECATED" StartChildWorkflowExecutionFailedCauseWorkflowTypeDoesNotExist = "WORKFLOW_TYPE_DOES_NOT_EXIST" )
Possible values for SWF.
const ( StartTimerFailedCauseOpenTimersLimitExceeded = "OPEN_TIMERS_LIMIT_EXCEEDED" StartTimerFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED" StartTimerFailedCauseTimerCreationRateExceeded = "TIMER_CREATION_RATE_EXCEEDED" StartTimerFailedCauseTimerIDAlreadyInUse = "TIMER_ID_ALREADY_IN_USE" )
Possible values for SWF.
const ( WorkflowExecutionTerminatedCauseChildPolicyApplied = "CHILD_POLICY_APPLIED" WorkflowExecutionTerminatedCauseEventLimitExceeded = "EVENT_LIMIT_EXCEEDED" WorkflowExecutionTerminatedCauseOperatorInitiated = "OPERATOR_INITIATED" )
Possible values for SWF.
const (
DecisionTaskTimeoutTypeStartToClose = "START_TO_CLOSE"
)
Possible values for SWF.
const (
RecordMarkerFailedCauseOperationNotPermitted = "OPERATION_NOT_PERMITTED"
)
Possible values for SWF.
const (
WorkflowExecutionCancelRequestedCauseChildPolicyApplied = "CHILD_POLICY_APPLIED"
)
Possible values for SWF.
const (
WorkflowExecutionTimeoutTypeStartToClose = "START_TO_CLOSE"
)
Possible values for SWF.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivityTask ¶
type ActivityTask struct { ActivityID aws.StringValue `json:"activityId"` ActivityType *ActivityType `json:"activityType"` Input aws.StringValue `json:"input,omitempty"` StartedEventID aws.LongValue `json:"startedEventId"` TaskToken aws.StringValue `json:"taskToken"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` }
ActivityTask is undocumented.
type ActivityTaskCancelRequestedEventAttributes ¶
type ActivityTaskCancelRequestedEventAttributes struct { ActivityID aws.StringValue `json:"activityId"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
ActivityTaskCancelRequestedEventAttributes is undocumented.
type ActivityTaskCanceledEventAttributes ¶
type ActivityTaskCanceledEventAttributes struct { Details aws.StringValue `json:"details,omitempty"` LatestCancelRequestedEventID aws.LongValue `json:"latestCancelRequestedEventId,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` }
ActivityTaskCanceledEventAttributes is undocumented.
type ActivityTaskCompletedEventAttributes ¶
type ActivityTaskCompletedEventAttributes struct { Result aws.StringValue `json:"result,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` }
ActivityTaskCompletedEventAttributes is undocumented.
type ActivityTaskFailedEventAttributes ¶
type ActivityTaskFailedEventAttributes struct { Details aws.StringValue `json:"details,omitempty"` Reason aws.StringValue `json:"reason,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` }
ActivityTaskFailedEventAttributes is undocumented.
type ActivityTaskScheduledEventAttributes ¶
type ActivityTaskScheduledEventAttributes struct { ActivityID aws.StringValue `json:"activityId"` ActivityType *ActivityType `json:"activityType"` Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` HeartbeatTimeout aws.StringValue `json:"heartbeatTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` ScheduleToCloseTimeout aws.StringValue `json:"scheduleToCloseTimeout,omitempty"` ScheduleToStartTimeout aws.StringValue `json:"scheduleToStartTimeout,omitempty"` StartToCloseTimeout aws.StringValue `json:"startToCloseTimeout,omitempty"` TaskList *TaskList `json:"taskList"` }
ActivityTaskScheduledEventAttributes is undocumented.
type ActivityTaskStartedEventAttributes ¶
type ActivityTaskStartedEventAttributes struct { Identity aws.StringValue `json:"identity,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` }
ActivityTaskStartedEventAttributes is undocumented.
type ActivityTaskStatus ¶
type ActivityTaskStatus struct {
CancelRequested aws.BooleanValue `json:"cancelRequested"`
}
ActivityTaskStatus is undocumented.
type ActivityTaskTimedOutEventAttributes ¶
type ActivityTaskTimedOutEventAttributes struct { Details aws.StringValue `json:"details,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` TimeoutType aws.StringValue `json:"timeoutType"` }
ActivityTaskTimedOutEventAttributes is undocumented.
type ActivityType ¶
type ActivityType struct { Name aws.StringValue `json:"name"` Version aws.StringValue `json:"version"` }
ActivityType is undocumented.
type ActivityTypeConfiguration ¶
type ActivityTypeConfiguration struct { DefaultTaskHeartbeatTimeout aws.StringValue `json:"defaultTaskHeartbeatTimeout,omitempty"` DefaultTaskList *TaskList `json:"defaultTaskList,omitempty"` DefaultTaskScheduleToCloseTimeout aws.StringValue `json:"defaultTaskScheduleToCloseTimeout,omitempty"` DefaultTaskScheduleToStartTimeout aws.StringValue `json:"defaultTaskScheduleToStartTimeout,omitempty"` DefaultTaskStartToCloseTimeout aws.StringValue `json:"defaultTaskStartToCloseTimeout,omitempty"` }
ActivityTypeConfiguration is undocumented.
type ActivityTypeDetail ¶
type ActivityTypeDetail struct { Configuration *ActivityTypeConfiguration `json:"configuration"` TypeInfo *ActivityTypeInfo `json:"typeInfo"` }
ActivityTypeDetail is undocumented.
type ActivityTypeInfo ¶
type ActivityTypeInfo struct { ActivityType *ActivityType `json:"activityType"` CreationDate time.Time `json:"creationDate"` DeprecationDate time.Time `json:"deprecationDate,omitempty"` Description aws.StringValue `json:"description,omitempty"` Status aws.StringValue `json:"status"` }
ActivityTypeInfo is undocumented.
type ActivityTypeInfos ¶
type ActivityTypeInfos struct { NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` TypeInfos []ActivityTypeInfo `json:"typeInfos"` }
ActivityTypeInfos is undocumented.
type CancelTimerDecisionAttributes ¶
type CancelTimerDecisionAttributes struct {
TimerID aws.StringValue `json:"timerId"`
}
CancelTimerDecisionAttributes is undocumented.
type CancelTimerFailedEventAttributes ¶
type CancelTimerFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` TimerID aws.StringValue `json:"timerId"` }
CancelTimerFailedEventAttributes is undocumented.
type CancelWorkflowExecutionDecisionAttributes ¶
type CancelWorkflowExecutionDecisionAttributes struct {
Details aws.StringValue `json:"details,omitempty"`
}
CancelWorkflowExecutionDecisionAttributes is undocumented.
type CancelWorkflowExecutionFailedEventAttributes ¶
type CancelWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
CancelWorkflowExecutionFailedEventAttributes is undocumented.
type ChildWorkflowExecutionCanceledEventAttributes ¶
type ChildWorkflowExecutionCanceledEventAttributes struct { Details aws.StringValue `json:"details,omitempty"` InitiatedEventID aws.LongValue `json:"initiatedEventId"` StartedEventID aws.LongValue `json:"startedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionCanceledEventAttributes is undocumented.
type ChildWorkflowExecutionCompletedEventAttributes ¶
type ChildWorkflowExecutionCompletedEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` Result aws.StringValue `json:"result,omitempty"` StartedEventID aws.LongValue `json:"startedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionCompletedEventAttributes is undocumented.
type ChildWorkflowExecutionFailedEventAttributes ¶
type ChildWorkflowExecutionFailedEventAttributes struct { Details aws.StringValue `json:"details,omitempty"` InitiatedEventID aws.LongValue `json:"initiatedEventId"` Reason aws.StringValue `json:"reason,omitempty"` StartedEventID aws.LongValue `json:"startedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionFailedEventAttributes is undocumented.
type ChildWorkflowExecutionStartedEventAttributes ¶
type ChildWorkflowExecutionStartedEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionStartedEventAttributes is undocumented.
type ChildWorkflowExecutionTerminatedEventAttributes ¶
type ChildWorkflowExecutionTerminatedEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` StartedEventID aws.LongValue `json:"startedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionTerminatedEventAttributes is undocumented.
type ChildWorkflowExecutionTimedOutEventAttributes ¶
type ChildWorkflowExecutionTimedOutEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` StartedEventID aws.LongValue `json:"startedEventId"` TimeoutType aws.StringValue `json:"timeoutType"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
ChildWorkflowExecutionTimedOutEventAttributes is undocumented.
type CloseStatusFilter ¶
type CloseStatusFilter struct {
Status aws.StringValue `json:"status"`
}
CloseStatusFilter is undocumented.
type CompleteWorkflowExecutionDecisionAttributes ¶
type CompleteWorkflowExecutionDecisionAttributes struct {
Result aws.StringValue `json:"result,omitempty"`
}
CompleteWorkflowExecutionDecisionAttributes is undocumented.
type CompleteWorkflowExecutionFailedEventAttributes ¶
type CompleteWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
CompleteWorkflowExecutionFailedEventAttributes is undocumented.
type ContinueAsNewWorkflowExecutionDecisionAttributes ¶
type ContinueAsNewWorkflowExecutionDecisionAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy,omitempty"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowTypeVersion aws.StringValue `json:"workflowTypeVersion,omitempty"` }
ContinueAsNewWorkflowExecutionDecisionAttributes is undocumented.
type ContinueAsNewWorkflowExecutionFailedEventAttributes ¶
type ContinueAsNewWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
ContinueAsNewWorkflowExecutionFailedEventAttributes is undocumented.
type CountClosedWorkflowExecutionsInput ¶
type CountClosedWorkflowExecutionsInput struct { CloseStatusFilter *CloseStatusFilter `json:"closeStatusFilter,omitempty"` CloseTimeFilter *ExecutionTimeFilter `json:"closeTimeFilter,omitempty"` Domain aws.StringValue `json:"domain"` ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"` StartTimeFilter *ExecutionTimeFilter `json:"startTimeFilter,omitempty"` TagFilter *TagFilter `json:"tagFilter,omitempty"` TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"` }
CountClosedWorkflowExecutionsInput is undocumented.
type CountOpenWorkflowExecutionsInput ¶
type CountOpenWorkflowExecutionsInput struct { Domain aws.StringValue `json:"domain"` ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"` StartTimeFilter *ExecutionTimeFilter `json:"startTimeFilter"` TagFilter *TagFilter `json:"tagFilter,omitempty"` TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"` }
CountOpenWorkflowExecutionsInput is undocumented.
type CountPendingActivityTasksInput ¶
type CountPendingActivityTasksInput struct { Domain aws.StringValue `json:"domain"` TaskList *TaskList `json:"taskList"` }
CountPendingActivityTasksInput is undocumented.
type CountPendingDecisionTasksInput ¶
type CountPendingDecisionTasksInput struct { Domain aws.StringValue `json:"domain"` TaskList *TaskList `json:"taskList"` }
CountPendingDecisionTasksInput is undocumented.
type Decision ¶
type Decision struct { CancelTimerDecisionAttributes *CancelTimerDecisionAttributes `json:"cancelTimerDecisionAttributes,omitempty"` CancelWorkflowExecutionDecisionAttributes *CancelWorkflowExecutionDecisionAttributes `json:"cancelWorkflowExecutionDecisionAttributes,omitempty"` CompleteWorkflowExecutionDecisionAttributes *CompleteWorkflowExecutionDecisionAttributes `json:"completeWorkflowExecutionDecisionAttributes,omitempty"` ContinueAsNewWorkflowExecutionDecisionAttributes *ContinueAsNewWorkflowExecutionDecisionAttributes `json:"continueAsNewWorkflowExecutionDecisionAttributes,omitempty"` DecisionType aws.StringValue `json:"decisionType"` FailWorkflowExecutionDecisionAttributes *FailWorkflowExecutionDecisionAttributes `json:"failWorkflowExecutionDecisionAttributes,omitempty"` RecordMarkerDecisionAttributes *RecordMarkerDecisionAttributes `json:"recordMarkerDecisionAttributes,omitempty"` RequestCancelActivityTaskDecisionAttributes *RequestCancelActivityTaskDecisionAttributes `json:"requestCancelActivityTaskDecisionAttributes,omitempty"` RequestCancelExternalWorkflowExecutionDecisionAttributes *RequestCancelExternalWorkflowExecutionDecisionAttributes `json:"requestCancelExternalWorkflowExecutionDecisionAttributes,omitempty"` ScheduleActivityTaskDecisionAttributes *ScheduleActivityTaskDecisionAttributes `json:"scheduleActivityTaskDecisionAttributes,omitempty"` SignalExternalWorkflowExecutionDecisionAttributes *SignalExternalWorkflowExecutionDecisionAttributes `json:"signalExternalWorkflowExecutionDecisionAttributes,omitempty"` StartChildWorkflowExecutionDecisionAttributes *StartChildWorkflowExecutionDecisionAttributes `json:"startChildWorkflowExecutionDecisionAttributes,omitempty"` StartTimerDecisionAttributes *StartTimerDecisionAttributes `json:"startTimerDecisionAttributes,omitempty"` }
Decision is undocumented.
type DecisionTask ¶
type DecisionTask struct { Events []HistoryEvent `json:"events"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` PreviousStartedEventID aws.LongValue `json:"previousStartedEventId,omitempty"` StartedEventID aws.LongValue `json:"startedEventId"` TaskToken aws.StringValue `json:"taskToken"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` WorkflowType *WorkflowType `json:"workflowType"` }
DecisionTask is undocumented.
type DecisionTaskCompletedEventAttributes ¶
type DecisionTaskCompletedEventAttributes struct { ExecutionContext aws.StringValue `json:"executionContext,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` }
DecisionTaskCompletedEventAttributes is undocumented.
type DecisionTaskScheduledEventAttributes ¶
type DecisionTaskScheduledEventAttributes struct { StartToCloseTimeout aws.StringValue `json:"startToCloseTimeout,omitempty"` TaskList *TaskList `json:"taskList"` }
DecisionTaskScheduledEventAttributes is undocumented.
type DecisionTaskStartedEventAttributes ¶
type DecisionTaskStartedEventAttributes struct { Identity aws.StringValue `json:"identity,omitempty"` ScheduledEventID aws.LongValue `json:"scheduledEventId"` }
DecisionTaskStartedEventAttributes is undocumented.
type DecisionTaskTimedOutEventAttributes ¶
type DecisionTaskTimedOutEventAttributes struct { ScheduledEventID aws.LongValue `json:"scheduledEventId"` StartedEventID aws.LongValue `json:"startedEventId"` TimeoutType aws.StringValue `json:"timeoutType"` }
DecisionTaskTimedOutEventAttributes is undocumented.
type DeprecateActivityTypeInput ¶
type DeprecateActivityTypeInput struct { ActivityType *ActivityType `json:"activityType"` Domain aws.StringValue `json:"domain"` }
DeprecateActivityTypeInput is undocumented.
type DeprecateDomainInput ¶
type DeprecateDomainInput struct {
Name aws.StringValue `json:"name"`
}
DeprecateDomainInput is undocumented.
type DeprecateWorkflowTypeInput ¶
type DeprecateWorkflowTypeInput struct { Domain aws.StringValue `json:"domain"` WorkflowType *WorkflowType `json:"workflowType"` }
DeprecateWorkflowTypeInput is undocumented.
type DescribeActivityTypeInput ¶
type DescribeActivityTypeInput struct { ActivityType *ActivityType `json:"activityType"` Domain aws.StringValue `json:"domain"` }
DescribeActivityTypeInput is undocumented.
type DescribeDomainInput ¶
type DescribeDomainInput struct {
Name aws.StringValue `json:"name"`
}
DescribeDomainInput is undocumented.
type DescribeWorkflowExecutionInput ¶
type DescribeWorkflowExecutionInput struct { Domain aws.StringValue `json:"domain"` Execution *WorkflowExecution `json:"execution"` }
DescribeWorkflowExecutionInput is undocumented.
type DescribeWorkflowTypeInput ¶
type DescribeWorkflowTypeInput struct { Domain aws.StringValue `json:"domain"` WorkflowType *WorkflowType `json:"workflowType"` }
DescribeWorkflowTypeInput is undocumented.
type DomainConfiguration ¶
type DomainConfiguration struct {
WorkflowExecutionRetentionPeriodInDays aws.StringValue `json:"workflowExecutionRetentionPeriodInDays"`
}
DomainConfiguration is undocumented.
type DomainDetail ¶
type DomainDetail struct { Configuration *DomainConfiguration `json:"configuration"` DomainInfo *DomainInfo `json:"domainInfo"` }
DomainDetail is undocumented.
type DomainInfo ¶
type DomainInfo struct { Description aws.StringValue `json:"description,omitempty"` Name aws.StringValue `json:"name"` Status aws.StringValue `json:"status"` }
DomainInfo is undocumented.
type DomainInfos ¶
type DomainInfos struct { DomainInfos []DomainInfo `json:"domainInfos"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` }
DomainInfos is undocumented.
type ExecutionTimeFilter ¶
type ExecutionTimeFilter struct { LatestDate time.Time `json:"latestDate,omitempty"` OldestDate time.Time `json:"oldestDate"` }
ExecutionTimeFilter is undocumented.
type ExternalWorkflowExecutionCancelRequestedEventAttributes ¶
type ExternalWorkflowExecutionCancelRequestedEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` }
ExternalWorkflowExecutionCancelRequestedEventAttributes is undocumented.
type ExternalWorkflowExecutionSignaledEventAttributes ¶
type ExternalWorkflowExecutionSignaledEventAttributes struct { InitiatedEventID aws.LongValue `json:"initiatedEventId"` WorkflowExecution *WorkflowExecution `json:"workflowExecution"` }
ExternalWorkflowExecutionSignaledEventAttributes is undocumented.
type FailWorkflowExecutionDecisionAttributes ¶
type FailWorkflowExecutionDecisionAttributes struct { Details aws.StringValue `json:"details,omitempty"` Reason aws.StringValue `json:"reason,omitempty"` }
FailWorkflowExecutionDecisionAttributes is undocumented.
type FailWorkflowExecutionFailedEventAttributes ¶
type FailWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
FailWorkflowExecutionFailedEventAttributes is undocumented.
type GetWorkflowExecutionHistoryInput ¶
type GetWorkflowExecutionHistoryInput struct { Domain aws.StringValue `json:"domain"` Execution *WorkflowExecution `json:"execution"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` }
GetWorkflowExecutionHistoryInput is undocumented.
type History ¶
type History struct { Events []HistoryEvent `json:"events"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` }
History is undocumented.
type HistoryEvent ¶
type HistoryEvent struct { ActivityTaskCancelRequestedEventAttributes *ActivityTaskCancelRequestedEventAttributes `json:"activityTaskCancelRequestedEventAttributes,omitempty"` ActivityTaskCanceledEventAttributes *ActivityTaskCanceledEventAttributes `json:"activityTaskCanceledEventAttributes,omitempty"` ActivityTaskCompletedEventAttributes *ActivityTaskCompletedEventAttributes `json:"activityTaskCompletedEventAttributes,omitempty"` ActivityTaskFailedEventAttributes *ActivityTaskFailedEventAttributes `json:"activityTaskFailedEventAttributes,omitempty"` ActivityTaskScheduledEventAttributes *ActivityTaskScheduledEventAttributes `json:"activityTaskScheduledEventAttributes,omitempty"` ActivityTaskStartedEventAttributes *ActivityTaskStartedEventAttributes `json:"activityTaskStartedEventAttributes,omitempty"` ActivityTaskTimedOutEventAttributes *ActivityTaskTimedOutEventAttributes `json:"activityTaskTimedOutEventAttributes,omitempty"` CancelTimerFailedEventAttributes *CancelTimerFailedEventAttributes `json:"cancelTimerFailedEventAttributes,omitempty"` CancelWorkflowExecutionFailedEventAttributes *CancelWorkflowExecutionFailedEventAttributes `json:"cancelWorkflowExecutionFailedEventAttributes,omitempty"` ChildWorkflowExecutionCanceledEventAttributes *ChildWorkflowExecutionCanceledEventAttributes `json:"childWorkflowExecutionCanceledEventAttributes,omitempty"` ChildWorkflowExecutionCompletedEventAttributes *ChildWorkflowExecutionCompletedEventAttributes `json:"childWorkflowExecutionCompletedEventAttributes,omitempty"` ChildWorkflowExecutionFailedEventAttributes *ChildWorkflowExecutionFailedEventAttributes `json:"childWorkflowExecutionFailedEventAttributes,omitempty"` ChildWorkflowExecutionStartedEventAttributes *ChildWorkflowExecutionStartedEventAttributes `json:"childWorkflowExecutionStartedEventAttributes,omitempty"` ChildWorkflowExecutionTerminatedEventAttributes *ChildWorkflowExecutionTerminatedEventAttributes `json:"childWorkflowExecutionTerminatedEventAttributes,omitempty"` ChildWorkflowExecutionTimedOutEventAttributes *ChildWorkflowExecutionTimedOutEventAttributes `json:"childWorkflowExecutionTimedOutEventAttributes,omitempty"` CompleteWorkflowExecutionFailedEventAttributes *CompleteWorkflowExecutionFailedEventAttributes `json:"completeWorkflowExecutionFailedEventAttributes,omitempty"` ContinueAsNewWorkflowExecutionFailedEventAttributes *ContinueAsNewWorkflowExecutionFailedEventAttributes `json:"continueAsNewWorkflowExecutionFailedEventAttributes,omitempty"` DecisionTaskCompletedEventAttributes *DecisionTaskCompletedEventAttributes `json:"decisionTaskCompletedEventAttributes,omitempty"` DecisionTaskScheduledEventAttributes *DecisionTaskScheduledEventAttributes `json:"decisionTaskScheduledEventAttributes,omitempty"` DecisionTaskStartedEventAttributes *DecisionTaskStartedEventAttributes `json:"decisionTaskStartedEventAttributes,omitempty"` DecisionTaskTimedOutEventAttributes *DecisionTaskTimedOutEventAttributes `json:"decisionTaskTimedOutEventAttributes,omitempty"` EventID aws.LongValue `json:"eventId"` EventTimestamp time.Time `json:"eventTimestamp"` EventType aws.StringValue `json:"eventType"` ExternalWorkflowExecutionCancelRequestedEventAttributes *ExternalWorkflowExecutionCancelRequestedEventAttributes `json:"externalWorkflowExecutionCancelRequestedEventAttributes,omitempty"` ExternalWorkflowExecutionSignaledEventAttributes *ExternalWorkflowExecutionSignaledEventAttributes `json:"externalWorkflowExecutionSignaledEventAttributes,omitempty"` FailWorkflowExecutionFailedEventAttributes *FailWorkflowExecutionFailedEventAttributes `json:"failWorkflowExecutionFailedEventAttributes,omitempty"` MarkerRecordedEventAttributes *MarkerRecordedEventAttributes `json:"markerRecordedEventAttributes,omitempty"` RecordMarkerFailedEventAttributes *RecordMarkerFailedEventAttributes `json:"recordMarkerFailedEventAttributes,omitempty"` RequestCancelActivityTaskFailedEventAttributes *RequestCancelActivityTaskFailedEventAttributes `json:"requestCancelActivityTaskFailedEventAttributes,omitempty"` RequestCancelExternalWorkflowExecutionFailedEventAttributes *RequestCancelExternalWorkflowExecutionFailedEventAttributes `json:"requestCancelExternalWorkflowExecutionFailedEventAttributes,omitempty"` RequestCancelExternalWorkflowExecutionInitiatedEventAttributes *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes `json:"requestCancelExternalWorkflowExecutionInitiatedEventAttributes,omitempty"` ScheduleActivityTaskFailedEventAttributes *ScheduleActivityTaskFailedEventAttributes `json:"scheduleActivityTaskFailedEventAttributes,omitempty"` SignalExternalWorkflowExecutionFailedEventAttributes *SignalExternalWorkflowExecutionFailedEventAttributes `json:"signalExternalWorkflowExecutionFailedEventAttributes,omitempty"` SignalExternalWorkflowExecutionInitiatedEventAttributes *SignalExternalWorkflowExecutionInitiatedEventAttributes `json:"signalExternalWorkflowExecutionInitiatedEventAttributes,omitempty"` StartChildWorkflowExecutionFailedEventAttributes *StartChildWorkflowExecutionFailedEventAttributes `json:"startChildWorkflowExecutionFailedEventAttributes,omitempty"` StartChildWorkflowExecutionInitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes `json:"startChildWorkflowExecutionInitiatedEventAttributes,omitempty"` StartTimerFailedEventAttributes *StartTimerFailedEventAttributes `json:"startTimerFailedEventAttributes,omitempty"` TimerCanceledEventAttributes *TimerCanceledEventAttributes `json:"timerCanceledEventAttributes,omitempty"` TimerFiredEventAttributes *TimerFiredEventAttributes `json:"timerFiredEventAttributes,omitempty"` TimerStartedEventAttributes *TimerStartedEventAttributes `json:"timerStartedEventAttributes,omitempty"` WorkflowExecutionCancelRequestedEventAttributes *WorkflowExecutionCancelRequestedEventAttributes `json:"workflowExecutionCancelRequestedEventAttributes,omitempty"` WorkflowExecutionCanceledEventAttributes *WorkflowExecutionCanceledEventAttributes `json:"workflowExecutionCanceledEventAttributes,omitempty"` WorkflowExecutionCompletedEventAttributes *WorkflowExecutionCompletedEventAttributes `json:"workflowExecutionCompletedEventAttributes,omitempty"` WorkflowExecutionContinuedAsNewEventAttributes *WorkflowExecutionContinuedAsNewEventAttributes `json:"workflowExecutionContinuedAsNewEventAttributes,omitempty"` WorkflowExecutionFailedEventAttributes *WorkflowExecutionFailedEventAttributes `json:"workflowExecutionFailedEventAttributes,omitempty"` WorkflowExecutionSignaledEventAttributes *WorkflowExecutionSignaledEventAttributes `json:"workflowExecutionSignaledEventAttributes,omitempty"` WorkflowExecutionStartedEventAttributes *WorkflowExecutionStartedEventAttributes `json:"workflowExecutionStartedEventAttributes,omitempty"` WorkflowExecutionTerminatedEventAttributes *WorkflowExecutionTerminatedEventAttributes `json:"workflowExecutionTerminatedEventAttributes,omitempty"` WorkflowExecutionTimedOutEventAttributes *WorkflowExecutionTimedOutEventAttributes `json:"workflowExecutionTimedOutEventAttributes,omitempty"` }
HistoryEvent is undocumented.
type ListActivityTypesInput ¶
type ListActivityTypesInput struct { Domain aws.StringValue `json:"domain"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` Name aws.StringValue `json:"name,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` RegistrationStatus aws.StringValue `json:"registrationStatus"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` }
ListActivityTypesInput is undocumented.
type ListClosedWorkflowExecutionsInput ¶
type ListClosedWorkflowExecutionsInput struct { CloseStatusFilter *CloseStatusFilter `json:"closeStatusFilter,omitempty"` CloseTimeFilter *ExecutionTimeFilter `json:"closeTimeFilter,omitempty"` Domain aws.StringValue `json:"domain"` ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` StartTimeFilter *ExecutionTimeFilter `json:"startTimeFilter,omitempty"` TagFilter *TagFilter `json:"tagFilter,omitempty"` TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"` }
ListClosedWorkflowExecutionsInput is undocumented.
type ListDomainsInput ¶
type ListDomainsInput struct { MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` RegistrationStatus aws.StringValue `json:"registrationStatus"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` }
ListDomainsInput is undocumented.
type ListOpenWorkflowExecutionsInput ¶
type ListOpenWorkflowExecutionsInput struct { Domain aws.StringValue `json:"domain"` ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` StartTimeFilter *ExecutionTimeFilter `json:"startTimeFilter"` TagFilter *TagFilter `json:"tagFilter,omitempty"` TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"` }
ListOpenWorkflowExecutionsInput is undocumented.
type ListWorkflowTypesInput ¶
type ListWorkflowTypesInput struct { Domain aws.StringValue `json:"domain"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` Name aws.StringValue `json:"name,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` RegistrationStatus aws.StringValue `json:"registrationStatus"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` }
ListWorkflowTypesInput is undocumented.
type MarkerRecordedEventAttributes ¶
type MarkerRecordedEventAttributes struct { DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` Details aws.StringValue `json:"details,omitempty"` MarkerName aws.StringValue `json:"markerName"` }
MarkerRecordedEventAttributes is undocumented.
type PendingTaskCount ¶
type PendingTaskCount struct { Count aws.IntegerValue `json:"count"` Truncated aws.BooleanValue `json:"truncated,omitempty"` }
PendingTaskCount is undocumented.
type PollForActivityTaskInput ¶
type PollForActivityTaskInput struct { Domain aws.StringValue `json:"domain"` Identity aws.StringValue `json:"identity,omitempty"` TaskList *TaskList `json:"taskList"` }
PollForActivityTaskInput is undocumented.
type PollForDecisionTaskInput ¶
type PollForDecisionTaskInput struct { Domain aws.StringValue `json:"domain"` Identity aws.StringValue `json:"identity,omitempty"` MaximumPageSize aws.IntegerValue `json:"maximumPageSize,omitempty"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` ReverseOrder aws.BooleanValue `json:"reverseOrder,omitempty"` TaskList *TaskList `json:"taskList"` }
PollForDecisionTaskInput is undocumented.
type RecordActivityTaskHeartbeatInput ¶
type RecordActivityTaskHeartbeatInput struct { Details aws.StringValue `json:"details,omitempty"` TaskToken aws.StringValue `json:"taskToken"` }
RecordActivityTaskHeartbeatInput is undocumented.
type RecordMarkerDecisionAttributes ¶
type RecordMarkerDecisionAttributes struct { Details aws.StringValue `json:"details,omitempty"` MarkerName aws.StringValue `json:"markerName"` }
RecordMarkerDecisionAttributes is undocumented.
type RecordMarkerFailedEventAttributes ¶
type RecordMarkerFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` MarkerName aws.StringValue `json:"markerName"` }
RecordMarkerFailedEventAttributes is undocumented.
type RegisterActivityTypeInput ¶
type RegisterActivityTypeInput struct { DefaultTaskHeartbeatTimeout aws.StringValue `json:"defaultTaskHeartbeatTimeout,omitempty"` DefaultTaskList *TaskList `json:"defaultTaskList,omitempty"` DefaultTaskScheduleToCloseTimeout aws.StringValue `json:"defaultTaskScheduleToCloseTimeout,omitempty"` DefaultTaskScheduleToStartTimeout aws.StringValue `json:"defaultTaskScheduleToStartTimeout,omitempty"` DefaultTaskStartToCloseTimeout aws.StringValue `json:"defaultTaskStartToCloseTimeout,omitempty"` Description aws.StringValue `json:"description,omitempty"` Domain aws.StringValue `json:"domain"` Name aws.StringValue `json:"name"` Version aws.StringValue `json:"version"` }
RegisterActivityTypeInput is undocumented.
type RegisterDomainInput ¶
type RegisterDomainInput struct { Description aws.StringValue `json:"description,omitempty"` Name aws.StringValue `json:"name"` WorkflowExecutionRetentionPeriodInDays aws.StringValue `json:"workflowExecutionRetentionPeriodInDays"` }
RegisterDomainInput is undocumented.
type RegisterWorkflowTypeInput ¶
type RegisterWorkflowTypeInput struct { DefaultChildPolicy aws.StringValue `json:"defaultChildPolicy,omitempty"` DefaultExecutionStartToCloseTimeout aws.StringValue `json:"defaultExecutionStartToCloseTimeout,omitempty"` DefaultTaskList *TaskList `json:"defaultTaskList,omitempty"` DefaultTaskStartToCloseTimeout aws.StringValue `json:"defaultTaskStartToCloseTimeout,omitempty"` Description aws.StringValue `json:"description,omitempty"` Domain aws.StringValue `json:"domain"` Name aws.StringValue `json:"name"` Version aws.StringValue `json:"version"` }
RegisterWorkflowTypeInput is undocumented.
type RequestCancelActivityTaskDecisionAttributes ¶
type RequestCancelActivityTaskDecisionAttributes struct {
ActivityID aws.StringValue `json:"activityId"`
}
RequestCancelActivityTaskDecisionAttributes is undocumented.
type RequestCancelActivityTaskFailedEventAttributes ¶
type RequestCancelActivityTaskFailedEventAttributes struct { ActivityID aws.StringValue `json:"activityId"` Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
RequestCancelActivityTaskFailedEventAttributes is undocumented.
type RequestCancelExternalWorkflowExecutionDecisionAttributes ¶
type RequestCancelExternalWorkflowExecutionDecisionAttributes struct { Control aws.StringValue `json:"control,omitempty"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
RequestCancelExternalWorkflowExecutionDecisionAttributes is undocumented.
type RequestCancelExternalWorkflowExecutionFailedEventAttributes ¶
type RequestCancelExternalWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` InitiatedEventID aws.LongValue `json:"initiatedEventId"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
RequestCancelExternalWorkflowExecutionFailedEventAttributes is undocumented.
type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶
type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes struct { Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
RequestCancelExternalWorkflowExecutionInitiatedEventAttributes is undocumented.
type RequestCancelWorkflowExecutionInput ¶
type RequestCancelWorkflowExecutionInput struct { Domain aws.StringValue `json:"domain"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
RequestCancelWorkflowExecutionInput is undocumented.
type RespondActivityTaskCanceledInput ¶
type RespondActivityTaskCanceledInput struct { Details aws.StringValue `json:"details,omitempty"` TaskToken aws.StringValue `json:"taskToken"` }
RespondActivityTaskCanceledInput is undocumented.
type RespondActivityTaskCompletedInput ¶
type RespondActivityTaskCompletedInput struct { Result aws.StringValue `json:"result,omitempty"` TaskToken aws.StringValue `json:"taskToken"` }
RespondActivityTaskCompletedInput is undocumented.
type RespondActivityTaskFailedInput ¶
type RespondActivityTaskFailedInput struct { Details aws.StringValue `json:"details,omitempty"` Reason aws.StringValue `json:"reason,omitempty"` TaskToken aws.StringValue `json:"taskToken"` }
RespondActivityTaskFailedInput is undocumented.
type RespondDecisionTaskCompletedInput ¶
type RespondDecisionTaskCompletedInput struct { Decisions []Decision `json:"decisions,omitempty"` ExecutionContext aws.StringValue `json:"executionContext,omitempty"` TaskToken aws.StringValue `json:"taskToken"` }
RespondDecisionTaskCompletedInput is undocumented.
type SWF ¶
type SWF struct {
// contains filtered or unexported fields
}
SWF is a client for Amazon Simple Workflow Service.
func (*SWF) CountClosedWorkflowExecutions ¶
func (c *SWF) CountClosedWorkflowExecutions(req *CountClosedWorkflowExecutionsInput) (resp *WorkflowExecutionCount, err error)
CountClosedWorkflowExecutions returns the number of closed workflow executions within the given domain that meet the specified filtering criteria. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. tagFilter.tag : String constraint. The key is swf:tagFilter.tag typeFilter.name : String constraint. The key is swf:typeFilter.name typeFilter.version : String constraint. The key is swf:typeFilter.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) CountOpenWorkflowExecutions ¶
func (c *SWF) CountOpenWorkflowExecutions(req *CountOpenWorkflowExecutionsInput) (resp *WorkflowExecutionCount, err error)
CountOpenWorkflowExecutions returns the number of open workflow executions within the given domain that meet the specified filtering criteria. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. tagFilter.tag : String constraint. The key is swf:tagFilter.tag typeFilter.name : String constraint. The key is swf:typeFilter.name typeFilter.version : String constraint. The key is swf:typeFilter.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) CountPendingActivityTasks ¶
func (c *SWF) CountPendingActivityTasks(req *CountPendingActivityTasksInput) (resp *PendingTaskCount, err error)
CountPendingActivityTasks returns the estimated number of activity tasks in the specified task list. The count returned is an approximation and is not guaranteed to be exact. If you specify a task list that no activity task was ever scheduled in then 0 will be returned. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the taskList.name parameter by using a Condition element with the swf:taskList.name key to allow the action to access only certain task lists. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) CountPendingDecisionTasks ¶
func (c *SWF) CountPendingDecisionTasks(req *CountPendingDecisionTasksInput) (resp *PendingTaskCount, err error)
CountPendingDecisionTasks returns the estimated number of decision tasks in the specified task list. The count returned is an approximation and is not guaranteed to be exact. If you specify a task list that no decision task was ever scheduled in then 0 will be returned. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the taskList.name parameter by using a Condition element with the swf:taskList.name key to allow the action to access only certain task lists. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DeprecateActivityType ¶
func (c *SWF) DeprecateActivityType(req *DeprecateActivityTypeInput) (err error)
DeprecateActivityType deprecates the specified activity type . After an activity type has been deprecated, you cannot create new tasks of that activity type. Tasks of this type that were scheduled before the type was deprecated will continue to run. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. activityType.name : String constraint. The key is swf:activityType.name activityType.version : String constraint. The key is swf:activityType.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DeprecateDomain ¶
func (c *SWF) DeprecateDomain(req *DeprecateDomainInput) (err error)
DeprecateDomain deprecates the specified domain. After a domain has been deprecated it cannot be used to create new workflow executions or register new types. However, you can still use visibility actions on this domain. Deprecating a domain also deprecates all activity and workflow types registered in the domain. Executions that were started before the domain was deprecated will continue to run. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DeprecateWorkflowType ¶
func (c *SWF) DeprecateWorkflowType(req *DeprecateWorkflowTypeInput) (err error)
DeprecateWorkflowType deprecates the specified workflow type . After a workflow type has been deprecated, you cannot create new executions of that type. Executions that were started before the type was deprecated will continue to run. A deprecated workflow type may still be used when calling visibility actions. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. workflowType.name : String constraint. The key is swf:workflowType.name workflowType.version : String constraint. The key is swf:workflowType.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DescribeActivityType ¶
func (c *SWF) DescribeActivityType(req *DescribeActivityTypeInput) (resp *ActivityTypeDetail, err error)
DescribeActivityType returns information about the specified activity type. This includes configuration settings provided at registration time as well as other general information about the type. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. activityType.name : String constraint. The key is swf:activityType.name activityType.version : String constraint. The key is swf:activityType.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DescribeDomain ¶
func (c *SWF) DescribeDomain(req *DescribeDomainInput) (resp *DomainDetail, err error)
DescribeDomain returns information about the specified domain including description and status. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DescribeWorkflowExecution ¶
func (c *SWF) DescribeWorkflowExecution(req *DescribeWorkflowExecutionInput) (resp *WorkflowExecutionDetail, err error)
DescribeWorkflowExecution returns information about the specified workflow execution including its type and some statistics. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) DescribeWorkflowType ¶
func (c *SWF) DescribeWorkflowType(req *DescribeWorkflowTypeInput) (resp *WorkflowTypeDetail, err error)
DescribeWorkflowType returns information about the specified workflow type . This includes configuration settings specified when the type was registered and other information such as creation date, current status, etc. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. workflowType.name : String constraint. The key is swf:workflowType.name workflowType.version : String constraint. The key is swf:workflowType.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) GetWorkflowExecutionHistory ¶
func (c *SWF) GetWorkflowExecutionHistory(req *GetWorkflowExecutionHistoryInput) (resp *History, err error)
GetWorkflowExecutionHistory returns the history of the specified workflow execution. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) ListActivityTypes ¶
func (c *SWF) ListActivityTypes(req *ListActivityTypesInput) (resp *ActivityTypeInfos, err error)
ListActivityTypes returns information about all activities registered in the specified domain that match the specified name and registration status. The result includes information like creation date, current status of the activity, etc. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) ListClosedWorkflowExecutions ¶
func (c *SWF) ListClosedWorkflowExecutions(req *ListClosedWorkflowExecutionsInput) (resp *WorkflowExecutionInfos, err error)
ListClosedWorkflowExecutions returns a list of closed workflow executions in the specified domain that meet the filtering criteria. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. tagFilter.tag : String constraint. The key is swf:tagFilter.tag typeFilter.name : String constraint. The key is swf:typeFilter.name typeFilter.version : String constraint. The key is swf:typeFilter.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) ListDomains ¶
func (c *SWF) ListDomains(req *ListDomainsInput) (resp *DomainInfos, err error)
ListDomains returns the list of domains registered in the account. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. The element must be set to arn:aws:swf::AccountID:domain/*" , where "AccountID" is the account ID, with no dashes. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) ListOpenWorkflowExecutions ¶
func (c *SWF) ListOpenWorkflowExecutions(req *ListOpenWorkflowExecutionsInput) (resp *WorkflowExecutionInfos, err error)
ListOpenWorkflowExecutions returns a list of open workflow executions in the specified domain that meet the filtering criteria. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. tagFilter.tag : String constraint. The key is swf:tagFilter.tag typeFilter.name : String constraint. The key is swf:typeFilter.name typeFilter.version : String constraint. The key is swf:typeFilter.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) ListWorkflowTypes ¶
func (c *SWF) ListWorkflowTypes(req *ListWorkflowTypesInput) (resp *WorkflowTypeInfos, err error)
ListWorkflowTypes returns information about workflow types in the specified domain. The results may be split into multiple pages that can be retrieved by making the call repeatedly. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) PollForActivityTask ¶
func (c *SWF) PollForActivityTask(req *PollForActivityTaskInput) (resp *ActivityTask, err error)
PollForActivityTask used by workers to get an ActivityTask from the specified activity taskList . This initiates a long poll, where the service holds the connection open and responds as soon as a task becomes available. The maximum time the service holds on to the request before responding is 60 seconds. If no task is available within 60 seconds, the poll will return an empty result. An empty result, in this context, means that an ActivityTask is returned, but that the value of taskToken is an empty string. If a task is returned, the worker should use its type to identify and process it correctly. Workers should set their client side socket timeout to at least 70 seconds (10 seconds higher than the maximum time service may hold the poll request). You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the taskList.name parameter by using a Condition element with the swf:taskList.name key to allow the action to access only certain task lists. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) PollForDecisionTask ¶
func (c *SWF) PollForDecisionTask(req *PollForDecisionTaskInput) (resp *DecisionTask, err error)
PollForDecisionTask used by deciders to get a DecisionTask from the specified decision taskList . A decision task may be returned for any open workflow execution that is using the specified task list. The task includes a paginated view of the history of the workflow execution. The decider should use the workflow type and the history to determine how to properly handle the task. This action initiates a long poll, where the service holds the connection open and responds as soon a task becomes available. If no decision task is available in the specified task list before the timeout of 60 seconds expires, an empty result is returned. An empty result, in this context, means that a DecisionTask is returned, but that the value of taskToken is an empty string. Deciders should set their client side socket timeout to at least 70 seconds (10 seconds higher than the timeout). Because the number of workflow history events for a single workflow execution might be very large, the result returned might be split up across a number of pages. To retrieve subsequent pages, make additional calls to PollForDecisionTask using the nextPageToken returned by the initial call. Note that you do not call GetWorkflowExecutionHistory with this nextPageToken . Instead, call PollForDecisionTask again. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the taskList.name parameter by using a Condition element with the swf:taskList.name key to allow the action to access only certain task lists. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RecordActivityTaskHeartbeat ¶
func (c *SWF) RecordActivityTaskHeartbeat(req *RecordActivityTaskHeartbeatInput) (resp *ActivityTaskStatus, err error)
RecordActivityTaskHeartbeat used by activity workers to report to the service that the ActivityTask represented by the specified taskToken is still making progress. The worker can also (optionally) specify details of the progress, for example percent complete, using the details parameter. This action can also be used by the worker as a mechanism to check if cancellation is being requested for the activity task. If a cancellation is being attempted for the specified task, then the boolean cancelRequested flag returned by the service is set to true . This action resets the taskHeartbeatTimeout clock. The taskHeartbeatTimeout is specified in RegisterActivityType . This action does not in itself create an event in the workflow execution history. However, if the task times out, the workflow execution history will contain a ActivityTaskTimedOut event that contains the information from the last heartbeat generated by the activity worker. If the cancelRequested flag returns true , a cancellation is being attempted. If the worker can cancel the activity, it should respond with RespondActivityTaskCanceled . Otherwise, it should ignore the cancellation request. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RegisterActivityType ¶
func (c *SWF) RegisterActivityType(req *RegisterActivityTypeInput) (err error)
RegisterActivityType registers a new activity type along with its configuration settings in the specified domain. A TypeAlreadyExists fault is returned if the type already exists in the domain. You cannot change any configuration settings of the type after its registration, and it must be registered as a new version. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. defaultTaskList.name : String constraint. The key is swf:defaultTaskList.name name : String constraint. The key is swf:name version : String constraint. The key is swf:version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RegisterDomain ¶
func (c *SWF) RegisterDomain(req *RegisterDomainInput) (err error)
RegisterDomain you can use IAM policies to control this action's access to Amazon SWF resources as follows: You cannot use an IAM policy to control domain access for this action. The name of the domain being registered is available as the resource of this action. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RegisterWorkflowType ¶
func (c *SWF) RegisterWorkflowType(req *RegisterWorkflowTypeInput) (err error)
RegisterWorkflowType registers a new workflow type and its configuration settings in the specified domain. The retention period for the workflow history is set by the RegisterDomain action. If the type already exists, then a TypeAlreadyExists fault is returned. You cannot change the configuration settings of a workflow type once it is registered and it must be registered as a new version. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. defaultTaskList.name : String constraint. The key is swf:defaultTaskList.name name : String constraint. The key is swf:name version : String constraint. The key is swf:version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RequestCancelWorkflowExecution ¶
func (c *SWF) RequestCancelWorkflowExecution(req *RequestCancelWorkflowExecutionInput) (err error)
RequestCancelWorkflowExecution records a WorkflowExecutionCancelRequested event in the currently running workflow execution identified by the given domain, workflowId, and runId. This logically requests the cancellation of the workflow execution as a whole. It is up to the decider to take appropriate actions when it receives an execution history with this event. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RespondActivityTaskCanceled ¶
func (c *SWF) RespondActivityTaskCanceled(req *RespondActivityTaskCanceledInput) (err error)
RespondActivityTaskCanceled used by workers to tell the service that the ActivityTask identified by the taskToken was successfully canceled. Additional details can be optionally provided using the details argument. These details (if provided) appear in the ActivityTaskCanceled event added to the workflow history. Only use this operation if the canceled flag of a RecordActivityTaskHeartbeat request returns true and if the activity can be safely undone or abandoned. A task is considered open from the time that it is scheduled until it is closed. Therefore a task is reported as open while a worker is processing it. A task is closed after it has been specified in a call to RespondActivityTaskCompleted , RespondActivityTaskCanceled, RespondActivityTaskFailed , or the task has timed out . You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RespondActivityTaskCompleted ¶
func (c *SWF) RespondActivityTaskCompleted(req *RespondActivityTaskCompletedInput) (err error)
RespondActivityTaskCompleted used by workers to tell the service that the ActivityTask identified by the taskToken completed successfully with a result (if provided). The result appears in the ActivityTaskCompleted event in the workflow history. If the requested task does not complete successfully, use RespondActivityTaskFailed instead. If the worker finds that the task is canceled through the canceled flag returned by RecordActivityTaskHeartbeat , it should cancel the task, clean up and then call RespondActivityTaskCanceled . A task is considered open from the time that it is scheduled until it is closed. Therefore a task is reported as open while a worker is processing it. A task is closed after it has been specified in a call to RespondActivityTaskCompleted, RespondActivityTaskCanceled , RespondActivityTaskFailed , or the task has timed out . You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RespondActivityTaskFailed ¶
func (c *SWF) RespondActivityTaskFailed(req *RespondActivityTaskFailedInput) (err error)
RespondActivityTaskFailed used by workers to tell the service that the ActivityTask identified by the taskToken has failed with reason (if specified). The reason and details appear in the ActivityTaskFailed event added to the workflow history. A task is considered open from the time that it is scheduled until it is closed. Therefore a task is reported as open while a worker is processing it. A task is closed after it has been specified in a call to RespondActivityTaskCompleted , RespondActivityTaskCanceled , RespondActivityTaskFailed, or the task has timed out . You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) RespondDecisionTaskCompleted ¶
func (c *SWF) RespondDecisionTaskCompleted(req *RespondDecisionTaskCompletedInput) (err error)
RespondDecisionTaskCompleted used by deciders to tell the service that the DecisionTask identified by the taskToken has successfully completed. The decisions argument specifies the list of decisions made while processing the task. A DecisionTaskCompleted event is added to the workflow history. The executionContext specified is attached to the event in the workflow execution history. If an IAM policy grants permission to use RespondDecisionTaskCompleted , it can express permissions for the list of decisions in the decisions parameter. Each of the decisions has one or more parameters, much like a regular API call. To allow for policies to be as readable as possible, you can express permissions on decisions as if they were actual API calls, including applying conditions to some parameters. For more information, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) SignalWorkflowExecution ¶
func (c *SWF) SignalWorkflowExecution(req *SignalWorkflowExecutionInput) (err error)
SignalWorkflowExecution records a WorkflowExecutionSignaled event in the workflow execution history and creates a decision task for the workflow execution identified by the given domain, workflowId and runId. The event is recorded with the specified user defined signalName and input (if provided). You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) StartWorkflowExecution ¶
func (c *SWF) StartWorkflowExecution(req *StartWorkflowExecutionInput) (resp *Run, err error)
StartWorkflowExecution starts an execution of the workflow type in the specified domain using the provided workflowId and input data. This action returns the newly started workflow execution. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. Constrain the following parameters by using a Condition element with the appropriate keys. tagList.member.0 : The key is swf:tagList.member.0 tagList.member.1 : The key is swf:tagList.member.1 tagList.member.2 : The key is swf:tagList.member.2 tagList.member.3 : The key is swf:tagList.member.3 tagList.member.4 : The key is swf:tagList.member.4 taskList : String constraint. The key is swf:taskList.name name : String constraint. The key is swf:workflowType.name version : String constraint. The key is swf:workflowType.version If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
func (*SWF) TerminateWorkflowExecution ¶
func (c *SWF) TerminateWorkflowExecution(req *TerminateWorkflowExecutionInput) (err error)
TerminateWorkflowExecution records a WorkflowExecutionTerminated event and forces closure of the workflow execution identified by the given domain, runId, and workflowId. The child policy, registered with the workflow type or specified when starting this execution, is applied to any open child workflow executions of this workflow execution. If the identified workflow execution was in progress, it is terminated immediately. You can use IAM policies to control this action's access to Amazon SWF resources as follows: Use a Resource element with the domain name to limit the action to only specified domains. Use an Action element to allow or deny permission to call this action. You cannot use an IAM policy to constrain this action's parameters. If the caller does not have sufficient permissions to invoke the action, or the parameter values fall outside the specified constraints, the action fails by throwing OperationNotPermitted . For details and example IAM policies, see Using IAM to Manage Access to Amazon SWF Workflows
type ScheduleActivityTaskDecisionAttributes ¶
type ScheduleActivityTaskDecisionAttributes struct { ActivityID aws.StringValue `json:"activityId"` ActivityType *ActivityType `json:"activityType"` Control aws.StringValue `json:"control,omitempty"` HeartbeatTimeout aws.StringValue `json:"heartbeatTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` ScheduleToCloseTimeout aws.StringValue `json:"scheduleToCloseTimeout,omitempty"` ScheduleToStartTimeout aws.StringValue `json:"scheduleToStartTimeout,omitempty"` StartToCloseTimeout aws.StringValue `json:"startToCloseTimeout,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` }
ScheduleActivityTaskDecisionAttributes is undocumented.
type ScheduleActivityTaskFailedEventAttributes ¶
type ScheduleActivityTaskFailedEventAttributes struct { ActivityID aws.StringValue `json:"activityId"` ActivityType *ActivityType `json:"activityType"` Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` }
ScheduleActivityTaskFailedEventAttributes is undocumented.
type SignalExternalWorkflowExecutionDecisionAttributes ¶
type SignalExternalWorkflowExecutionDecisionAttributes struct { Control aws.StringValue `json:"control,omitempty"` Input aws.StringValue `json:"input,omitempty"` RunID aws.StringValue `json:"runId,omitempty"` SignalName aws.StringValue `json:"signalName"` WorkflowID aws.StringValue `json:"workflowId"` }
SignalExternalWorkflowExecutionDecisionAttributes is undocumented.
type SignalExternalWorkflowExecutionFailedEventAttributes ¶
type SignalExternalWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` InitiatedEventID aws.LongValue `json:"initiatedEventId"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
SignalExternalWorkflowExecutionFailedEventAttributes is undocumented.
type SignalExternalWorkflowExecutionInitiatedEventAttributes ¶
type SignalExternalWorkflowExecutionInitiatedEventAttributes struct { Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` Input aws.StringValue `json:"input,omitempty"` RunID aws.StringValue `json:"runId,omitempty"` SignalName aws.StringValue `json:"signalName"` WorkflowID aws.StringValue `json:"workflowId"` }
SignalExternalWorkflowExecutionInitiatedEventAttributes is undocumented.
type SignalWorkflowExecutionInput ¶
type SignalWorkflowExecutionInput struct { Domain aws.StringValue `json:"domain"` Input aws.StringValue `json:"input,omitempty"` RunID aws.StringValue `json:"runId,omitempty"` SignalName aws.StringValue `json:"signalName"` WorkflowID aws.StringValue `json:"workflowId"` }
SignalWorkflowExecutionInput is undocumented.
type StartChildWorkflowExecutionDecisionAttributes ¶
type StartChildWorkflowExecutionDecisionAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy,omitempty"` Control aws.StringValue `json:"control,omitempty"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` WorkflowType *WorkflowType `json:"workflowType"` }
StartChildWorkflowExecutionDecisionAttributes is undocumented.
type StartChildWorkflowExecutionFailedEventAttributes ¶
type StartChildWorkflowExecutionFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` InitiatedEventID aws.LongValue `json:"initiatedEventId"` WorkflowID aws.StringValue `json:"workflowId"` WorkflowType *WorkflowType `json:"workflowType"` }
StartChildWorkflowExecutionFailedEventAttributes is undocumented.
type StartChildWorkflowExecutionInitiatedEventAttributes ¶
type StartChildWorkflowExecutionInitiatedEventAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy"` Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` WorkflowType *WorkflowType `json:"workflowType"` }
StartChildWorkflowExecutionInitiatedEventAttributes is undocumented.
type StartTimerDecisionAttributes ¶
type StartTimerDecisionAttributes struct { Control aws.StringValue `json:"control,omitempty"` StartToFireTimeout aws.StringValue `json:"startToFireTimeout"` TimerID aws.StringValue `json:"timerId"` }
StartTimerDecisionAttributes is undocumented.
type StartTimerFailedEventAttributes ¶
type StartTimerFailedEventAttributes struct { Cause aws.StringValue `json:"cause"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` TimerID aws.StringValue `json:"timerId"` }
StartTimerFailedEventAttributes is undocumented.
type StartWorkflowExecutionInput ¶
type StartWorkflowExecutionInput struct { ChildPolicy aws.StringValue `json:"childPolicy,omitempty"` Domain aws.StringValue `json:"domain"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` WorkflowType *WorkflowType `json:"workflowType"` }
StartWorkflowExecutionInput is undocumented.
type TagFilter ¶
type TagFilter struct {
Tag aws.StringValue `json:"tag"`
}
TagFilter is undocumented.
type TaskList ¶
type TaskList struct {
Name aws.StringValue `json:"name"`
}
TaskList is undocumented.
type TerminateWorkflowExecutionInput ¶
type TerminateWorkflowExecutionInput struct { ChildPolicy aws.StringValue `json:"childPolicy,omitempty"` Details aws.StringValue `json:"details,omitempty"` Domain aws.StringValue `json:"domain"` Reason aws.StringValue `json:"reason,omitempty"` RunID aws.StringValue `json:"runId,omitempty"` WorkflowID aws.StringValue `json:"workflowId"` }
TerminateWorkflowExecutionInput is undocumented.
type TimerCanceledEventAttributes ¶
type TimerCanceledEventAttributes struct { DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` StartedEventID aws.LongValue `json:"startedEventId"` TimerID aws.StringValue `json:"timerId"` }
TimerCanceledEventAttributes is undocumented.
type TimerFiredEventAttributes ¶
type TimerFiredEventAttributes struct { StartedEventID aws.LongValue `json:"startedEventId"` TimerID aws.StringValue `json:"timerId"` }
TimerFiredEventAttributes is undocumented.
type TimerStartedEventAttributes ¶
type TimerStartedEventAttributes struct { Control aws.StringValue `json:"control,omitempty"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` StartToFireTimeout aws.StringValue `json:"startToFireTimeout"` TimerID aws.StringValue `json:"timerId"` }
TimerStartedEventAttributes is undocumented.
type WorkflowExecution ¶
type WorkflowExecution struct { RunID aws.StringValue `json:"runId"` WorkflowID aws.StringValue `json:"workflowId"` }
WorkflowExecution is undocumented.
type WorkflowExecutionCancelRequestedEventAttributes ¶
type WorkflowExecutionCancelRequestedEventAttributes struct { Cause aws.StringValue `json:"cause,omitempty"` ExternalInitiatedEventID aws.LongValue `json:"externalInitiatedEventId,omitempty"` ExternalWorkflowExecution *WorkflowExecution `json:"externalWorkflowExecution,omitempty"` }
WorkflowExecutionCancelRequestedEventAttributes is undocumented.
type WorkflowExecutionCanceledEventAttributes ¶
type WorkflowExecutionCanceledEventAttributes struct { DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` Details aws.StringValue `json:"details,omitempty"` }
WorkflowExecutionCanceledEventAttributes is undocumented.
type WorkflowExecutionCompletedEventAttributes ¶
type WorkflowExecutionCompletedEventAttributes struct { DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` Result aws.StringValue `json:"result,omitempty"` }
WorkflowExecutionCompletedEventAttributes is undocumented.
type WorkflowExecutionConfiguration ¶
type WorkflowExecutionConfiguration struct { ChildPolicy aws.StringValue `json:"childPolicy"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout"` TaskList *TaskList `json:"taskList"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout"` }
WorkflowExecutionConfiguration is undocumented.
type WorkflowExecutionContinuedAsNewEventAttributes ¶
type WorkflowExecutionContinuedAsNewEventAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy"` DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` NewExecutionRunID aws.StringValue `json:"newExecutionRunId"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowType *WorkflowType `json:"workflowType"` }
WorkflowExecutionContinuedAsNewEventAttributes is undocumented.
type WorkflowExecutionCount ¶
type WorkflowExecutionCount struct { Count aws.IntegerValue `json:"count"` Truncated aws.BooleanValue `json:"truncated,omitempty"` }
WorkflowExecutionCount is undocumented.
type WorkflowExecutionDetail ¶
type WorkflowExecutionDetail struct { ExecutionConfiguration *WorkflowExecutionConfiguration `json:"executionConfiguration"` ExecutionInfo *WorkflowExecutionInfo `json:"executionInfo"` LatestActivityTaskTimestamp time.Time `json:"latestActivityTaskTimestamp,omitempty"` LatestExecutionContext aws.StringValue `json:"latestExecutionContext,omitempty"` OpenCounts *WorkflowExecutionOpenCounts `json:"openCounts"` }
WorkflowExecutionDetail is undocumented.
type WorkflowExecutionFailedEventAttributes ¶
type WorkflowExecutionFailedEventAttributes struct { DecisionTaskCompletedEventID aws.LongValue `json:"decisionTaskCompletedEventId"` Details aws.StringValue `json:"details,omitempty"` Reason aws.StringValue `json:"reason,omitempty"` }
WorkflowExecutionFailedEventAttributes is undocumented.
type WorkflowExecutionFilter ¶
type WorkflowExecutionFilter struct {
WorkflowID aws.StringValue `json:"workflowId"`
}
WorkflowExecutionFilter is undocumented.
type WorkflowExecutionInfo ¶
type WorkflowExecutionInfo struct { CancelRequested aws.BooleanValue `json:"cancelRequested,omitempty"` CloseStatus aws.StringValue `json:"closeStatus,omitempty"` CloseTimestamp time.Time `json:"closeTimestamp,omitempty"` Execution *WorkflowExecution `json:"execution"` ExecutionStatus aws.StringValue `json:"executionStatus"` Parent *WorkflowExecution `json:"parent,omitempty"` StartTimestamp time.Time `json:"startTimestamp"` TagList []string `json:"tagList,omitempty"` WorkflowType *WorkflowType `json:"workflowType"` }
WorkflowExecutionInfo is undocumented.
type WorkflowExecutionInfos ¶
type WorkflowExecutionInfos struct { ExecutionInfos []WorkflowExecutionInfo `json:"executionInfos"` NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` }
WorkflowExecutionInfos is undocumented.
type WorkflowExecutionOpenCounts ¶
type WorkflowExecutionOpenCounts struct { OpenActivityTasks aws.IntegerValue `json:"openActivityTasks"` OpenChildWorkflowExecutions aws.IntegerValue `json:"openChildWorkflowExecutions"` OpenDecisionTasks aws.IntegerValue `json:"openDecisionTasks"` OpenTimers aws.IntegerValue `json:"openTimers"` }
WorkflowExecutionOpenCounts is undocumented.
type WorkflowExecutionSignaledEventAttributes ¶
type WorkflowExecutionSignaledEventAttributes struct { ExternalInitiatedEventID aws.LongValue `json:"externalInitiatedEventId,omitempty"` ExternalWorkflowExecution *WorkflowExecution `json:"externalWorkflowExecution,omitempty"` Input aws.StringValue `json:"input,omitempty"` SignalName aws.StringValue `json:"signalName"` }
WorkflowExecutionSignaledEventAttributes is undocumented.
type WorkflowExecutionStartedEventAttributes ¶
type WorkflowExecutionStartedEventAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy"` ContinuedExecutionRunID aws.StringValue `json:"continuedExecutionRunId,omitempty"` ExecutionStartToCloseTimeout aws.StringValue `json:"executionStartToCloseTimeout,omitempty"` Input aws.StringValue `json:"input,omitempty"` ParentInitiatedEventID aws.LongValue `json:"parentInitiatedEventId,omitempty"` ParentWorkflowExecution *WorkflowExecution `json:"parentWorkflowExecution,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList"` TaskStartToCloseTimeout aws.StringValue `json:"taskStartToCloseTimeout,omitempty"` WorkflowType *WorkflowType `json:"workflowType"` }
WorkflowExecutionStartedEventAttributes is undocumented.
type WorkflowExecutionTerminatedEventAttributes ¶
type WorkflowExecutionTerminatedEventAttributes struct { Cause aws.StringValue `json:"cause,omitempty"` ChildPolicy aws.StringValue `json:"childPolicy"` Details aws.StringValue `json:"details,omitempty"` Reason aws.StringValue `json:"reason,omitempty"` }
WorkflowExecutionTerminatedEventAttributes is undocumented.
type WorkflowExecutionTimedOutEventAttributes ¶
type WorkflowExecutionTimedOutEventAttributes struct { ChildPolicy aws.StringValue `json:"childPolicy"` TimeoutType aws.StringValue `json:"timeoutType"` }
WorkflowExecutionTimedOutEventAttributes is undocumented.
type WorkflowType ¶
type WorkflowType struct { Name aws.StringValue `json:"name"` Version aws.StringValue `json:"version"` }
WorkflowType is undocumented.
type WorkflowTypeConfiguration ¶
type WorkflowTypeConfiguration struct { DefaultChildPolicy aws.StringValue `json:"defaultChildPolicy,omitempty"` DefaultExecutionStartToCloseTimeout aws.StringValue `json:"defaultExecutionStartToCloseTimeout,omitempty"` DefaultTaskList *TaskList `json:"defaultTaskList,omitempty"` DefaultTaskStartToCloseTimeout aws.StringValue `json:"defaultTaskStartToCloseTimeout,omitempty"` }
WorkflowTypeConfiguration is undocumented.
type WorkflowTypeDetail ¶
type WorkflowTypeDetail struct { Configuration *WorkflowTypeConfiguration `json:"configuration"` TypeInfo *WorkflowTypeInfo `json:"typeInfo"` }
WorkflowTypeDetail is undocumented.
type WorkflowTypeFilter ¶
type WorkflowTypeFilter struct { Name aws.StringValue `json:"name"` Version aws.StringValue `json:"version,omitempty"` }
WorkflowTypeFilter is undocumented.
type WorkflowTypeInfo ¶
type WorkflowTypeInfo struct { CreationDate time.Time `json:"creationDate"` DeprecationDate time.Time `json:"deprecationDate,omitempty"` Description aws.StringValue `json:"description,omitempty"` Status aws.StringValue `json:"status"` WorkflowType *WorkflowType `json:"workflowType"` }
WorkflowTypeInfo is undocumented.
type WorkflowTypeInfos ¶
type WorkflowTypeInfos struct { NextPageToken aws.StringValue `json:"nextPageToken,omitempty"` TypeInfos []WorkflowTypeInfo `json:"typeInfos"` }
WorkflowTypeInfos is undocumented.