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)
• type WorkflowConfig

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"`

	Config WorkflowConfig `json:"config,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

type WorkflowConfig

type WorkflowConfig struct {
	DisableSystemSearchAttributes bool `json:"disableSystemSearchAttributes,omitempty"`
}