swf

package
v0.0.0-...-1a19813 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 21, 2015 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivityType

type ActivityType struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

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 FailWorkflowExecutionDecisionAttributes

type FailWorkflowExecutionDecisionAttributes struct {
	Details string `json:"details"`
	Reason  string `json:"reason"`
}

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 (*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 (*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 RecordMarkerDecisionAttributes

type RecordMarkerDecisionAttributes struct {
	Details    string `json:"details"`
	MarkerName string `json:"markerName"`
}

type RequestCancelActivityTaskDecisionAttributes

type RequestCancelActivityTaskDecisionAttributes struct {
	ActivityId string `json:"activityId"`
}

type RequestCancelExternalWorkflowExecutionDecisionAttributes

type RequestCancelExternalWorkflowExecutionDecisionAttributes struct {
	Control    string `json:"control"`
	RunId      string `json:"runId"`
	WorkflowId string `json:"workflowId"`
}

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 (*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 (*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 (*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 (*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 (*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 SignalExternalWorkflowExecutionDecisionAttributes

type SignalExternalWorkflowExecutionDecisionAttributes struct {
	Control    string `json:"control"`
	Input      string `json:"input"`
	RunId      string `json:"runId"`
	SignalName string `json:"signalName"`
	WorkflowId string `json:"workflowId"`
}

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 StartTimerDecisionAttributes

type StartTimerDecisionAttributes struct {
	Control            string `json:"control"`
	StartToFireTimeout string `json:"startToFireTimeout"`
	TimerId            string `json:"timerId"`
}

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 (*StartWorkflowExecutionRequest) VerifyInput

func (req *StartWorkflowExecutionRequest) VerifyInput() error

type StartWorkflowExecutionResponse

type StartWorkflowExecutionResponse struct {
	RunId string `json:"runId"`
}

type TaskList

type TaskList struct {
	Name string `json:"name"`
}

type WorkflowExecution

type WorkflowExecution struct {
	RunId      string `json:"runId"`
	WorkflowId string `json:"workflowId"`
}

type WorkflowType

type WorkflowType struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL