Documentation ¶
Index ¶
- type ActivityType
- type CancelTimerDecisionAttributes
- type CancelWorkflowExecutionDecisionAttributes
- type CompleteWorkflowExecutionDecisionAttributes
- type ContinueAsNewWorkflowExecutionDecisionAttributes
- type Decision
- type FailWorkflowExecutionDecisionAttributes
- type HistoryEvent
- type PollForActivityTaskRequest
- type PollForActivityTaskResponse
- type PollForDecisionTaskRequest
- type PollForDecisionTaskResponse
- type RecordMarkerDecisionAttributes
- type RequestCancelActivityTaskDecisionAttributes
- type RequestCancelExternalWorkflowExecutionDecisionAttributes
- type RespondActivityTaskCanceledRequest
- func (req RespondActivityTaskCanceledRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
- func (req RespondActivityTaskCanceledRequest) Request() (*RespondActivityTaskCanceledResponse, error)
- func (req *RespondActivityTaskCanceledRequest) VerifyInput() error
- type RespondActivityTaskCanceledResponse
- type RespondActivityTaskCompletedRequest
- func (req RespondActivityTaskCompletedRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
- func (req RespondActivityTaskCompletedRequest) Request() (*RespondActivityTaskCompletedResponse, error)
- func (req *RespondActivityTaskCompletedRequest) VerifyInput() error
- type RespondActivityTaskCompletedResponse
- type RespondActivityTaskFailedRequest
- type RespondActivityTaskFailedResponse
- type RespondActivityTaskHeartbeatRequest
- func (req RespondActivityTaskHeartbeatRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
- func (req RespondActivityTaskHeartbeatRequest) Request() (*RespondActivityTaskHeartbeatResponse, error)
- func (req *RespondActivityTaskHeartbeatRequest) VerifyInput() error
- type RespondActivityTaskHeartbeatResponse
- type RespondDecisionTaskCompletedRequest
- func (req RespondDecisionTaskCompletedRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
- func (req RespondDecisionTaskCompletedRequest) Request() (*RespondDecisionTaskCompletedResponse, error)
- func (req *RespondDecisionTaskCompletedRequest) VerifyInput() error
- type RespondDecisionTaskCompletedResponse
- type ScheduleActivityTaskDecisionAttributes
- type SignalExternalWorkflowExecutionDecisionAttributes
- type StartChildWorkflowExecutionDecisionAttributes
- type StartTimerDecisionAttributes
- type StartWorkflowExecutionRequest
- type StartWorkflowExecutionResponse
- type TaskList
- type WorkflowExecution
- type WorkflowType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivityType ¶
type CancelTimerDecisionAttributes ¶
type CancelTimerDecisionAttributes struct {
TimerId string `json:"timerId"`
}
type CancelWorkflowExecutionDecisionAttributes ¶
type CancelWorkflowExecutionDecisionAttributes struct {
Details string `json:"details"`
}
type CompleteWorkflowExecutionDecisionAttributes ¶
type CompleteWorkflowExecutionDecisionAttributes struct {
Result string `json:"result"`
}
type ContinueAsNewWorkflowExecutionDecisionAttributes ¶
type ContinueAsNewWorkflowExecutionDecisionAttributes struct { ChildPolicy string `json:"childPolicy,omitempty"` ExecutionStartToCloseTimeout string `json:"executionStartToCloseTimeout,omitempty"` Input string `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` TaskStartToCloseTimeout string `json:"taskStartToCloseTimeout,omitempty"` WorkflowTypeVersion string `json:"workflowTypeVersion,omitempty"` }
type Decision ¶
type Decision struct { DecisionType string `json:"decisionType"` CancelTimerDecisionAttributes *CancelTimerDecisionAttributes `json:"cancelTimerDecisionAttributes,omitempty"` CancelWorkflowExecutionDecisionAttributes *CancelWorkflowExecutionDecisionAttributes `json:"cancelWorkflowExecutionDecisionAttributes,omitempty"` CompleteWorkflowExecutionDecisionAttributes *CompleteWorkflowExecutionDecisionAttributes `json:"completeWorkflowExecutionDecisionAttributes,omitempty"` ContinueAsNewWorkflowExecutionDecisionAttributes *ContinueAsNewWorkflowExecutionDecisionAttributes `json:"continueAsNewWorkflowExecutionDecisionAttributes,omitempty"` 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"` }
type HistoryEvent ¶
type HistoryEvent struct { EventId int64 `json:"eventId"` EventTimestamp float64 `json:"eventTimestamp"` EventType string `json:"eventType"` ActivityTaskCanceledEventAttributes *activityTaskCanceledEventAttributes `json:"activityTaskCanceledEventAttributes,omitempty"` ActivityTaskCancelRequestedEventAttributes *activityTaskCancelRequestedEventAttributes `json:"activityTaskCancelRequestedEventAttributes,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"` 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"` DecisionTaskCompletedEventAttributes *decisionTaskCompletedEventAttributes `json:"decisionTaskCompletedEventAttributes,omitempty"` DecisionTaskScheduledEventAttributes *decisionTaskScheduledEventAttributes `json:"decisionTaskScheduledEventAttributes,omitempty"` DecisionTaskStartedEventAttributes *decisionTaskStartedEventAttributes `json:"decisionTaskStartedEventAttributes,omitempty"` DecisionTaskTimedOutEventAttributes *decisionTaskTimedOutEventAttributes `json:"decisionTaskTimedOutEventAttributes,omitempty"` ExternalWorkflowExecutionCancelRequestedEventAttributes *externalWorkflowExecutionCancelRequestedEventAttributes `json:"externalWorkflowExecutionCancelRequestedEventAttributes,omitempty"` ExternalWorkflowExecutionSignaledEventAttributes *externalWorkflowExecutionSignaledEventAttributes `json:"externalWorkflowExecutionSignaledEventAttributes,omitempty"` MarkerRecordedEventAttributes *markerRecordedEventAttributes `json:"markerRecordedEventAttributes,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"` WorkflowExecutionCanceledEventAttributes *workflowExecutionCanceledEventAttributes `json:"workflowExecutionCanceledEventAttributes,omitempty"` WorkflowExecutionCancelRequestedEventAttributes *workflowExecutionCancelRequestedEventAttributes `json:"workflowExecutionCancelRequestedEventAttributes,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"` }
type PollForActivityTaskRequest ¶
type PollForActivityTaskRequest struct { awsgo.RequestBuilder Domain string `json:"domain"` Identity string `json:"identity"` TaskList TaskList `json:"taskList"` }
func NewPollForActivityTaskRequest ¶
func NewPollForActivityTaskRequest() *PollForActivityTaskRequest
func (PollForActivityTaskRequest) DeMarshalResponse ¶
func (req PollForActivityTaskRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (PollForActivityTaskRequest) Request ¶
func (req PollForActivityTaskRequest) Request() (*PollForActivityTaskResponse, error)
func (*PollForActivityTaskRequest) VerifyInput ¶
func (req *PollForActivityTaskRequest) VerifyInput() error
type PollForActivityTaskResponse ¶
type PollForActivityTaskResponse struct { ActivityId string `json:"activityId"` ActivityType ActivityType `json:"activityType"` Input string `json:"input"` StartedEventId int64 `json:"startedEventId"` TaskToken string `json:"taskToken"` WorkflowExecution WorkflowExecution `json:"workflowExecution"` }
type PollForDecisionTaskRequest ¶
type PollForDecisionTaskRequest struct { awsgo.RequestBuilder Domain string `json:"domain"` Identity string `json:"identity"` MaximumPageSize int `json:"maximumPageSize"` NextPageToken string `json:"nextPageToken,omitempty"` ReverseOrder bool `json:"reverseOrder,omitempty"` TaskList TaskList `json:"taskList"` }
func NewPollForDecisionTaskRequest ¶
func NewPollForDecisionTaskRequest() *PollForDecisionTaskRequest
func (PollForDecisionTaskRequest) DeMarshalResponse ¶
func (req PollForDecisionTaskRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (PollForDecisionTaskRequest) Request ¶
func (req PollForDecisionTaskRequest) Request() (*PollForDecisionTaskResponse, error)
func (*PollForDecisionTaskRequest) VerifyInput ¶
func (req *PollForDecisionTaskRequest) VerifyInput() error
type PollForDecisionTaskResponse ¶
type PollForDecisionTaskResponse struct { Events []HistoryEvent `json:"events"` NextPageToken string `json:"nextPageToken"` PreviousStartedEventId int64 `json:"previousStartedEventId"` StartedEventId int64 `json:"startedEventId"` TaskToken string `json:"taskToken"` WorkflowExecution WorkflowExecution `json:"workflowExecution"` WorkflowType WorkflowType `json:"workflowType"` }
type RequestCancelActivityTaskDecisionAttributes ¶
type RequestCancelActivityTaskDecisionAttributes struct {
ActivityId string `json:"activityId"`
}
type RespondActivityTaskCanceledRequest ¶
type RespondActivityTaskCanceledRequest struct { awsgo.RequestBuilder Details string `json:"details"` TaskToken string `json:"taskToken"` }
func NewRespondActivityTaskCanceledRequest ¶
func NewRespondActivityTaskCanceledRequest() *RespondActivityTaskCanceledRequest
func (RespondActivityTaskCanceledRequest) DeMarshalResponse ¶
func (req RespondActivityTaskCanceledRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (RespondActivityTaskCanceledRequest) Request ¶
func (req RespondActivityTaskCanceledRequest) Request() (*RespondActivityTaskCanceledResponse, error)
func (*RespondActivityTaskCanceledRequest) VerifyInput ¶
func (req *RespondActivityTaskCanceledRequest) VerifyInput() error
type RespondActivityTaskCanceledResponse ¶
type RespondActivityTaskCanceledResponse struct { }
type RespondActivityTaskCompletedRequest ¶
type RespondActivityTaskCompletedRequest struct { awsgo.RequestBuilder Result string `json:"result"` TaskToken string `json:"taskToken"` }
func NewRespondActivityTaskCompletedRequest ¶
func NewRespondActivityTaskCompletedRequest() *RespondActivityTaskCompletedRequest
func (RespondActivityTaskCompletedRequest) DeMarshalResponse ¶
func (req RespondActivityTaskCompletedRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (RespondActivityTaskCompletedRequest) Request ¶
func (req RespondActivityTaskCompletedRequest) Request() (*RespondActivityTaskCompletedResponse, error)
func (*RespondActivityTaskCompletedRequest) VerifyInput ¶
func (req *RespondActivityTaskCompletedRequest) VerifyInput() error
type RespondActivityTaskCompletedResponse ¶
type RespondActivityTaskCompletedResponse struct { }
type RespondActivityTaskFailedRequest ¶
type RespondActivityTaskFailedRequest struct { awsgo.RequestBuilder Details string `json:"details"` TaskToken string `json:"taskToken"` Reason string `json:"reason"` }
func NewRespondActivityTaskFailedRequest ¶
func NewRespondActivityTaskFailedRequest() *RespondActivityTaskFailedRequest
func (RespondActivityTaskFailedRequest) DeMarshalResponse ¶
func (req RespondActivityTaskFailedRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (RespondActivityTaskFailedRequest) Request ¶
func (req RespondActivityTaskFailedRequest) Request() (*RespondActivityTaskFailedResponse, error)
func (*RespondActivityTaskFailedRequest) VerifyInput ¶
func (req *RespondActivityTaskFailedRequest) VerifyInput() error
type RespondActivityTaskFailedResponse ¶
type RespondActivityTaskFailedResponse struct { }
type RespondActivityTaskHeartbeatRequest ¶
type RespondActivityTaskHeartbeatRequest struct { awsgo.RequestBuilder Details string `json:"details"` TaskToken string `json:"taskToken"` }
func NewRespondActivityTaskHeartbeatRequest ¶
func NewRespondActivityTaskHeartbeatRequest() *RespondActivityTaskHeartbeatRequest
func (RespondActivityTaskHeartbeatRequest) DeMarshalResponse ¶
func (req RespondActivityTaskHeartbeatRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (RespondActivityTaskHeartbeatRequest) Request ¶
func (req RespondActivityTaskHeartbeatRequest) Request() (*RespondActivityTaskHeartbeatResponse, error)
func (*RespondActivityTaskHeartbeatRequest) VerifyInput ¶
func (req *RespondActivityTaskHeartbeatRequest) VerifyInput() error
type RespondActivityTaskHeartbeatResponse ¶
type RespondActivityTaskHeartbeatResponse struct {
CancelRequested bool `json:"cancelRequested"`
}
type RespondDecisionTaskCompletedRequest ¶
type RespondDecisionTaskCompletedRequest struct { awsgo.RequestBuilder Decisions []Decision `json:"decisions"` ExecutionContext string `json:"executionContext"` TaskToken string `json:"taskToken"` }
func NewRespondDecisionTaskCompletedRequest ¶
func NewRespondDecisionTaskCompletedRequest() *RespondDecisionTaskCompletedRequest
func (RespondDecisionTaskCompletedRequest) DeMarshalResponse ¶
func (req RespondDecisionTaskCompletedRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (RespondDecisionTaskCompletedRequest) Request ¶
func (req RespondDecisionTaskCompletedRequest) Request() (*RespondDecisionTaskCompletedResponse, error)
func (*RespondDecisionTaskCompletedRequest) VerifyInput ¶
func (req *RespondDecisionTaskCompletedRequest) VerifyInput() error
type RespondDecisionTaskCompletedResponse ¶
type RespondDecisionTaskCompletedResponse struct { }
type ScheduleActivityTaskDecisionAttributes ¶
type ScheduleActivityTaskDecisionAttributes struct { ActivityId string `json:"activityId"` ActivityType ActivityType `json:"activityType"` Control string `json:"control,omitempty"` HeartbeatTimeout string `json:"heartbeatTimeout,omitempty"` Input string `json:"input,omitempty"` ScheduleToCloseTimeout string `json:"scheduleToCloseTimeout,omitempty"` ScheduleToStartTimeout string `json:"scheduleToStartTimeout,omitempty"` StartToCloseTimeout string `json:"startToCloseTimeout,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` }
type StartChildWorkflowExecutionDecisionAttributes ¶
type StartChildWorkflowExecutionDecisionAttributes struct { ChildPolicy string `json:"childPolicy"` Control string `json:"control"` ExecutionStartToCloseTimeout string `json:"executionStartToCloseTimeout"` Input string `json:"input"` TagList []string `json:"tagList"` TaskList TaskList `json:"taskList"` TaskStartToCloseTimeout string `json:"taskStartToCloseTimeout"` WorkflowId string `json:"workflowId"` WorkflowType WorkflowType `json:"workflowType"` }
type StartWorkflowExecutionRequest ¶
type StartWorkflowExecutionRequest struct { awsgo.RequestBuilder ChildPolicy string `json:"childPolicy,omitempty"` Domain string `json:"domain"` ExecutionStartToCloseTimeout string `json:"executionStartToCloseTimeout,omitempty"` Input string `json:"input,omitempty"` TagList []string `json:"tagList,omitempty"` TaskList *TaskList `json:"taskList,omitempty"` TaskStartToCloseTimeout string `json:"taskStartToCloseTimeout,omitempty"` WorkflowId string `json:"workflowId"` WorkflowType WorkflowType `json:"workflowType"` }
func NewStartWorkflowExecutionRequest ¶
func NewStartWorkflowExecutionRequest() *StartWorkflowExecutionRequest
func (StartWorkflowExecutionRequest) DeMarshalResponse ¶
func (req StartWorkflowExecutionRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
func (StartWorkflowExecutionRequest) Request ¶
func (req StartWorkflowExecutionRequest) Request() (*StartWorkflowExecutionResponse, error)
func (*StartWorkflowExecutionRequest) VerifyInput ¶
func (req *StartWorkflowExecutionRequest) VerifyInput() error
type StartWorkflowExecutionResponse ¶
type StartWorkflowExecutionResponse struct {
RunId string `json:"runId"`
}
type WorkflowExecution ¶
type WorkflowType ¶
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
The SwfHelper is meant to make the decision process execution task easier.
|
The SwfHelper is meant to make the decision process execution task easier. |
Click to show internal directories.
Click to hide internal directories.