service

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
  • func ValidateTimerSkipRequest(stateExeTimerInfos map[string][]*TimerInfo, stateExeId, timerId string, ...) (*TimerInfo, bool)

Constants

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

var ValidIwfSystemSignalNames map[string]bool = map[string]bool{
	SkipTimerSignalChannelName: true,
}

Types

type BackendType

type BackendType string

type DumpAllInternalResponse

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

type GetCurrentTimerInfosQueryResponse struct {
	StateExecutionCurrentTimerInfos map[string][]*TimerInfo // key is stateExecutionId
}

type GetDataObjectsQueryRequest

type GetDataObjectsQueryRequest struct {
	Keys []string
}

type GetDataObjectsQueryResponse

type GetDataObjectsQueryResponse struct {
	DataObjects []iwfidl.KeyValue
}

type InternalTimerStatus

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 IwfWorkflowExecution struct {
	IwfWorkerUrl     string
	WorkflowType     string
	WorkflowId       string
	RunId            string
	StartedTimestamp int64
}

type PendingStateExecutionCompletedCommands

type PendingStateExecutionCompletedCommands struct {
	CompletedTimerCommands             map[int]bool
	CompletedSignalCommands            map[int]*iwfidl.EncodedObject
	CompletedInterStateChannelCommands map[int]*iwfidl.EncodedObject
}

type PendingStateExecutionRequestCommands

type PendingStateExecutionRequestCommands struct {
	TimerCommands             []iwfidl.TimerCommand
	SignalCommands            []iwfidl.SignalCommand
	InterStateChannelCommands []iwfidl.InterStateChannelCommand
}

type SkipTimerSignalRequest

type SkipTimerSignalRequest struct {
	StateExecutionId string
	CommandId        string
	CommandIndex     int
}

type StateDecideActivityInput

type StateDecideActivityInput struct {
	IwfWorkerUrl string
	Request      iwfidl.WorkflowStateDecideRequest
}

type StateExecutionCounterInfo

type StateExecutionCounterInfo struct {
	ExecutedStateIdCount      map[string]int
	PendingStateIdCount       map[string]int
	TotalPendingStateExeCount int
}

type StateStartActivityInput

type StateStartActivityInput struct {
	IwfWorkerUrl string
	Request      iwfidl.WorkflowStateStartRequest
}

type TimerInfo

type TimerInfo struct {
	CommandId                  string
	FiringUnixTimestampSeconds int64
	Status                     InternalTimerStatus
}

func ValidateTimerSkipRequest

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