Documentation
¶
Index ¶
- Constants
- Variables
- type BackendType
- type DumpAllInternalResponse
- type GetCurrentTimerInfosQueryResponse
- type GetDataObjectsQueryRequest
- type GetDataObjectsQueryResponse
- type InternalTimerStatus
- type InterpreterWorkflowInput
- type InterpreterWorkflowOutput
- type IwfWorkflowExecution
- type PendingStateExecutionCompletedCommands
- type PendingStateExecutionRequestCommands
- type SkipTimerSignalRequest
- type StateDecideActivityInput
- type StateExecutionCounterInfo
- type StateStartActivityInput
- type TimerInfo
Constants ¶
View Source
const ( TaskQueue = "Interpreter_DEFAULT" GracefulCompletingWorkflowStateId = "_SYS_GRACEFUL_COMPLETING_WORKFLOW" ForceCompletingWorkflowStateId = "_SYS_FORCE_COMPLETING_WORKFLOW" ForceFailingWorkflowStateId = "_SYS_FORCE_FAILING_WORKFLOW" StateStartApi = "/api/v1/workflowState/start" StateDecideApi = "/api/v1/workflowState/decide" GetDataObjectsWorkflowQueryType = "GetDataObjects" GetCurrentTimerInfosQueryType = "GetCurrentTimerInfos" DumpAllInternalQueryType = "DumpAllInternal" SearchAttributeGlobalVersion = "IwfGlobalWorkflowVersion" SearchAttributeExecutingStateIds = "IwfExecutingStateIds" SearchAttributeIwfWorkflowType = "IwfWorkflowType" BackendTypeCadence BackendType = "cadence" BackendTypeTemporal BackendType = "temporal" IwfSystemSignalPrefix = "__IwfSystem_" SkipTimerSignalChannelName = IwfSystemSignalPrefix + "SkipTimerChannel" )
Variables ¶
View Source
var ValidIwfSystemSignalNames map[string]bool = map[string]bool{ SkipTimerSignalChannelName: true, }
Functions ¶
This section is empty.
Types ¶
type BackendType ¶
type BackendType string
type DumpAllInternalResponse ¶ added in v1.3.0
type DumpAllInternalResponse struct {
InterStateChannelReceived map[string][]*iwfidl.EncodedObject
SignalChannelReceived map[string][]*iwfidl.EncodedObject
StateExecutionCounterInfo StateExecutionCounterInfo
PendingStateExecutionsCompletedCommands map[string]PendingStateExecutionCompletedCommands
PendingStateExecutionsRequestCommands map[string]PendingStateExecutionRequestCommands
DataObjects []iwfidl.KeyValue
SearchAttributes []iwfidl.SearchAttribute
}
type GetCurrentTimerInfosQueryResponse ¶ added in v1.2.0
type GetDataObjectsQueryRequest ¶
type GetDataObjectsQueryRequest struct {
Keys []string
}
type InternalTimerStatus ¶ added in v1.2.0
type InternalTimerStatus string
const ( TimerPending InternalTimerStatus = "Pending" TimerFired InternalTimerStatus = "Fired" TimerSkipped InternalTimerStatus = "Skipped" )
type InterpreterWorkflowInput ¶
type InterpreterWorkflowInput struct {
IwfWorkflowType string `json:"iwfWorkflowType,omitempty"`
IwfWorkerUrl string `json:"iwfWorkerUrl,omitempty"`
StartStateId string `json:"startStateId,omitempty"`
StateInput iwfidl.EncodedObject `json:"stateInput,omitempty"`
StateOptions iwfidl.WorkflowStateOptions `json:"stateOptions,omitempty"`
InitSearchAttributes []iwfidl.SearchAttribute `json:"initSearchAttributes,omitempty"`
}
type InterpreterWorkflowOutput ¶
type InterpreterWorkflowOutput struct {
StateCompletionOutputs []iwfidl.StateCompletionOutput `json:"stateCompletionOutputs,omitempty"`
}
type IwfWorkflowExecution ¶
type PendingStateExecutionCompletedCommands ¶ added in v1.3.0
type PendingStateExecutionCompletedCommands struct {
CompletedTimerCommands map[int]bool
CompletedSignalCommands map[int]*iwfidl.EncodedObject
CompletedInterStateChannelCommands map[int]*iwfidl.EncodedObject
}
type PendingStateExecutionRequestCommands ¶ added in v1.3.0
type PendingStateExecutionRequestCommands struct {
TimerCommands []iwfidl.TimerCommand
SignalCommands []iwfidl.SignalCommand
InterStateChannelCommands []iwfidl.InterStateChannelCommand
}
type SkipTimerSignalRequest ¶ added in v1.2.0
type StateDecideActivityInput ¶
type StateDecideActivityInput struct {
IwfWorkerUrl string
Request iwfidl.WorkflowStateDecideRequest
}
type StateExecutionCounterInfo ¶ added in v1.3.0
type StateStartActivityInput ¶
type StateStartActivityInput struct {
IwfWorkerUrl string
Request iwfidl.WorkflowStateStartRequest
}
type TimerInfo ¶ added in v1.2.0
type TimerInfo struct {
CommandId string
FiringUnixTimestampSeconds int64
Status InternalTimerStatus
}
func ValidateTimerSkipRequest ¶ added in v1.2.0
func ValidateTimerSkipRequest(stateExeTimerInfos map[string][]*TimerInfo, stateExeId, timerId string, timerIdx int) (*TimerInfo, bool)
ValidateTimerSkipRequest validates if the skip timer request is valid return true if it's valid, along with the timer pointer use timerIdx if timerId is not empty
Click to show internal directories.
Click to hide internal directories.