Documentation
¶
Index ¶
- Constants
- func NewValidatorContext(object any) context.Context
- func ToInterface(object Object) any
- func ValidationWrap(fnCtx WorkflowValidator) validator.StructLevelFuncCtx
- type Action
- type ActionBuilder
- func (b *ActionBuilder) ActionDataFilter() *ActionDataFilterBuilder
- func (b *ActionBuilder) Build() Action
- func (b *ActionBuilder) Condition(input string) *ActionBuilder
- func (b *ActionBuilder) EventRef() *EventRefBuilder
- func (b *ActionBuilder) FunctionRef() *FunctionRefBuilder
- func (b *ActionBuilder) ID(input string) *ActionBuilder
- func (b *ActionBuilder) Name(input string) *ActionBuilder
- func (b *ActionBuilder) NonRetryableErrors(input []string) *ActionBuilder
- func (b *ActionBuilder) RetryRef(input string) *ActionBuilder
- func (b *ActionBuilder) RetryableErrors(input []string) *ActionBuilder
- func (b *ActionBuilder) Sleep() *SleepBuilder
- func (b *ActionBuilder) SubFlowRef() *WorkflowRefBuilder
- type ActionDataFilter
- type ActionDataFilterBuilder
- func (b *ActionDataFilterBuilder) Build() ActionDataFilter
- func (b *ActionDataFilterBuilder) FromStateData(input string) *ActionDataFilterBuilder
- func (b *ActionDataFilterBuilder) Results(input string) *ActionDataFilterBuilder
- func (b *ActionDataFilterBuilder) ToStateData(input string) *ActionDataFilterBuilder
- func (b *ActionDataFilterBuilder) UseResults(input bool) *ActionDataFilterBuilder
- type ActionMode
- type Auth
- type AuthBuilder
- type AuthProperties
- type AuthPropertiesBuilder
- type AuthType
- type Auths
- type AuthsBuilder
- type BaseState
- type BaseStateBuilder
- func (b *BaseStateBuilder) AddOnErrors() *OnErrorBuilder
- func (b *BaseStateBuilder) Build() BaseState
- func (b *BaseStateBuilder) CompensatedBy(input string) *BaseStateBuilder
- func (b *BaseStateBuilder) End() *EndBuilder
- func (b *BaseStateBuilder) ID(input string) *BaseStateBuilder
- func (b *BaseStateBuilder) Name(input string) *BaseStateBuilder
- func (b *BaseStateBuilder) RemoveOnErrors(remove *OnErrorBuilder)
- func (b *BaseStateBuilder) StateDataFilter() *StateDataFilterBuilder
- func (b *BaseStateBuilder) Transition() *TransitionBuilder
- func (b *BaseStateBuilder) Type(input StateType) *BaseStateBuilder
- func (b *BaseStateBuilder) UsedForCompensation(input bool) *BaseStateBuilder
- type BaseWorkflow
- type BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) AddAuth() *AuthBuilder
- func (b *BaseWorkflowBuilder) AddErrors() *ErrorBuilder
- func (b *BaseWorkflowBuilder) Annotations(input []string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) AutoRetries(input bool) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) Build() BaseWorkflow
- func (b *BaseWorkflowBuilder) Constants() *ConstantsBuilder
- func (b *BaseWorkflowBuilder) DataInputSchema() *DataInputSchemaBuilder
- func (b *BaseWorkflowBuilder) Description(input string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) ExpressionLang(input ExpressionLangType) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) ID(input string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) KeepActive(input bool) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) Key(input string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) Metadata(input Metadata) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) Name(input string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) RemoveAuth(remove *AuthBuilder)
- func (b *BaseWorkflowBuilder) RemoveErrors(remove *ErrorBuilder)
- func (b *BaseWorkflowBuilder) Secrets(input Secrets) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) SpecVersion(input string) *BaseWorkflowBuilder
- func (b *BaseWorkflowBuilder) Start() *StartBuilder
- func (b *BaseWorkflowBuilder) Timeouts() *TimeoutsBuilder
- func (b *BaseWorkflowBuilder) Version(input string) *BaseWorkflowBuilder
- type BasicAuthProperties
- type BasicAuthPropertiesBuilder
- func (b *BasicAuthPropertiesBuilder) Build() BasicAuthProperties
- func (b *BasicAuthPropertiesBuilder) Common() *CommonBuilder
- func (b *BasicAuthPropertiesBuilder) Password(input string) *BasicAuthPropertiesBuilder
- func (b *BasicAuthPropertiesBuilder) Secret(input string) *BasicAuthPropertiesBuilder
- func (b *BasicAuthPropertiesBuilder) Username(input string) *BasicAuthPropertiesBuilder
- type BearerAuthProperties
- type BearerAuthPropertiesBuilder
- func (b *BearerAuthPropertiesBuilder) Build() BearerAuthProperties
- func (b *BearerAuthPropertiesBuilder) Common() *CommonBuilder
- func (b *BearerAuthPropertiesBuilder) Secret(input string) *BearerAuthPropertiesBuilder
- func (b *BearerAuthPropertiesBuilder) Token(input string) *BearerAuthPropertiesBuilder
- type Branch
- type BranchBuilder
- type BranchTimeouts
- type BranchTimeoutsBuilder
- type CallbackState
- type CallbackStateBuilder
- func (b *CallbackStateBuilder) Action() *ActionBuilder
- func (b *CallbackStateBuilder) Build() CallbackState
- func (b *CallbackStateBuilder) EventDataFilter() *EventDataFilterBuilder
- func (b *CallbackStateBuilder) EventRef(input string) *CallbackStateBuilder
- func (b *CallbackStateBuilder) Timeouts() *CallbackStateTimeoutBuilder
- type CallbackStateTimeout
- type CallbackStateTimeoutBuilder
- func (b *CallbackStateTimeoutBuilder) ActionExecTimeout(input string) *CallbackStateTimeoutBuilder
- func (b *CallbackStateTimeoutBuilder) Build() CallbackStateTimeout
- func (b *CallbackStateTimeoutBuilder) EventTimeout(input string) *CallbackStateTimeoutBuilder
- func (b *CallbackStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
- type Common
- type CommonBuilder
- type CompletionType
- type Constants
- type ConstantsBuilder
- type ConstantsData
- type ConstantsDataBuilder
- type ContinueAs
- type ContinueAsBuilder
- func (b *ContinueAsBuilder) Build() ContinueAs
- func (b *ContinueAsBuilder) Data() *ObjectBuilder
- func (b *ContinueAsBuilder) Version(input string) *ContinueAsBuilder
- func (b *ContinueAsBuilder) WorkflowExecTimeout() *WorkflowExecTimeoutBuilder
- func (b *ContinueAsBuilder) WorkflowID(input string) *ContinueAsBuilder
- type Correlation
- type CorrelationBuilder
- type Cron
- type CronBuilder
- type DataCondition
- type DataConditionBuilder
- func (b *DataConditionBuilder) Build() DataCondition
- func (b *DataConditionBuilder) Condition(input string) *DataConditionBuilder
- func (b *DataConditionBuilder) End() *EndBuilder
- func (b *DataConditionBuilder) Metadata(input Metadata) *DataConditionBuilder
- func (b *DataConditionBuilder) Name(input string) *DataConditionBuilder
- func (b *DataConditionBuilder) Transition() *TransitionBuilder
- type DataInputSchema
- type DataInputSchemaBuilder
- type DefaultCondition
- type DefaultConditionBuilder
- type DelayState
- type DelayStateBuilder
- type End
- type EndBuilder
- func (b *EndBuilder) AddProduceEvents() *ProduceEventBuilder
- func (b *EndBuilder) Build() End
- func (b *EndBuilder) Compensate(input bool) *EndBuilder
- func (b *EndBuilder) ContinueAs() *ContinueAsBuilder
- func (b *EndBuilder) RemoveProduceEvents(remove *ProduceEventBuilder)
- func (b *EndBuilder) Terminate(input bool) *EndBuilder
- type Error
- type ErrorBuilder
- type Errors
- type ErrorsBuilder
- type Event
- type EventBuilder
- func (b *EventBuilder) AddCorrelation() *CorrelationBuilder
- func (b *EventBuilder) Build() Event
- func (b *EventBuilder) Common() *CommonBuilder
- func (b *EventBuilder) DataOnly(input bool) *EventBuilder
- func (b *EventBuilder) Kind(input EventKind) *EventBuilder
- func (b *EventBuilder) Name(input string) *EventBuilder
- func (b *EventBuilder) RemoveCorrelation(remove *CorrelationBuilder)
- func (b *EventBuilder) Source(input string) *EventBuilder
- func (b *EventBuilder) Type(input string) *EventBuilder
- type EventCondition
- type EventConditionBuilder
- func (b *EventConditionBuilder) Build() EventCondition
- func (b *EventConditionBuilder) End() *EndBuilder
- func (b *EventConditionBuilder) EventDataFilter() *EventDataFilterBuilder
- func (b *EventConditionBuilder) EventRef(input string) *EventConditionBuilder
- func (b *EventConditionBuilder) Metadata(input Metadata) *EventConditionBuilder
- func (b *EventConditionBuilder) Name(input string) *EventConditionBuilder
- func (b *EventConditionBuilder) Transition() *TransitionBuilder
- type EventConditions
- type EventConditionsBuilder
- type EventDataFilter
- type EventDataFilterBuilder
- type EventKind
- type EventRef
- type EventRefBuilder
- func (b *EventRefBuilder) Build() EventRef
- func (b *EventRefBuilder) ContextAttributes(input map[string]Object) *EventRefBuilder
- func (b *EventRefBuilder) Data() *ObjectBuilder
- func (b *EventRefBuilder) Invoke(input InvokeKind) *EventRefBuilder
- func (b *EventRefBuilder) ResultEventRef(input string) *EventRefBuilder
- func (b *EventRefBuilder) ResultEventTimeout(input string) *EventRefBuilder
- func (b *EventRefBuilder) TriggerEventRef(input string) *EventRefBuilder
- type EventState
- type EventStateBuilder
- func (b *EventStateBuilder) AddOnEvents() *OnEventsBuilder
- func (b *EventStateBuilder) Build() EventState
- func (b *EventStateBuilder) Exclusive(input bool) *EventStateBuilder
- func (b *EventStateBuilder) RemoveOnEvents(remove *OnEventsBuilder)
- func (b *EventStateBuilder) Timeouts() *EventStateTimeoutBuilder
- type EventStateTimeout
- type EventStateTimeoutBuilder
- func (b *EventStateTimeoutBuilder) ActionExecTimeout(input string) *EventStateTimeoutBuilder
- func (b *EventStateTimeoutBuilder) Build() EventStateTimeout
- func (b *EventStateTimeoutBuilder) EventTimeout(input string) *EventStateTimeoutBuilder
- func (b *EventStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
- type Events
- type EventsBuilder
- type ExpressionLangType
- type ForEachModeType
- type ForEachState
- type ForEachStateBuilder
- func (b *ForEachStateBuilder) AddActions() *ActionBuilder
- func (b *ForEachStateBuilder) BatchSize(input *intstr.IntOrString) *ForEachStateBuilder
- func (b *ForEachStateBuilder) Build() ForEachState
- func (b *ForEachStateBuilder) InputCollection(input string) *ForEachStateBuilder
- func (b *ForEachStateBuilder) IterationParam(input string) *ForEachStateBuilder
- func (b *ForEachStateBuilder) Mode(input ForEachModeType) *ForEachStateBuilder
- func (b *ForEachStateBuilder) OutputCollection(input string) *ForEachStateBuilder
- func (b *ForEachStateBuilder) RemoveActions(remove *ActionBuilder)
- func (b *ForEachStateBuilder) Timeouts() *ForEachStateTimeoutBuilder
- type ForEachStateTimeout
- type ForEachStateTimeoutBuilder
- type Function
- type FunctionBuilder
- func (b *FunctionBuilder) AuthRef(input string) *FunctionBuilder
- func (b *FunctionBuilder) Build() Function
- func (b *FunctionBuilder) Common() *CommonBuilder
- func (b *FunctionBuilder) Name(input string) *FunctionBuilder
- func (b *FunctionBuilder) Operation(input string) *FunctionBuilder
- func (b *FunctionBuilder) Type(input FunctionType) *FunctionBuilder
- type FunctionRef
- type FunctionRefBuilder
- func (b *FunctionRefBuilder) Arguments(input map[string]Object) *FunctionRefBuilder
- func (b *FunctionRefBuilder) Build() FunctionRef
- func (b *FunctionRefBuilder) Invoke(input InvokeKind) *FunctionRefBuilder
- func (b *FunctionRefBuilder) RefName(input string) *FunctionRefBuilder
- func (b *FunctionRefBuilder) SelectionSet(input string) *FunctionRefBuilder
- type FunctionType
- type Functions
- type FunctionsBuilder
- type GrantType
- type InjectState
- type InjectStateBuilder
- type InjectStateTimeout
- type InjectStateTimeoutBuilder
- type InvokeKind
- type Metadata
- type MetadataBuilder
- type OAuth2AuthProperties
- type OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Audiences(input []string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Authority(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Build() OAuth2AuthProperties
- func (b *OAuth2AuthPropertiesBuilder) ClientID(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) ClientSecret(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Common() *CommonBuilder
- func (b *OAuth2AuthPropertiesBuilder) GrantType(input GrantType) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Password(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) RequestedIssuer(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) RequestedSubject(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Scopes(input []string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Secret(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) SubjectToken(input string) *OAuth2AuthPropertiesBuilder
- func (b *OAuth2AuthPropertiesBuilder) Username(input string) *OAuth2AuthPropertiesBuilder
- type Object
- type ObjectBuilder
- func (b *ObjectBuilder) AddSliceValue() *ObjectBuilder
- func (b *ObjectBuilder) BoolValue(input bool) *ObjectBuilder
- func (b *ObjectBuilder) Build() Object
- func (b *ObjectBuilder) FloatValue(input float64) *ObjectBuilder
- func (b *ObjectBuilder) IntValue(input int32) *ObjectBuilder
- func (b *ObjectBuilder) MapValue(input map[string]Object) *ObjectBuilder
- func (b *ObjectBuilder) RemoveSliceValue(remove *ObjectBuilder)
- func (b *ObjectBuilder) StringValue(input string) *ObjectBuilder
- func (b *ObjectBuilder) Type(input Type) *ObjectBuilder
- type OnError
- type OnErrorBuilder
- type OnEvents
- type OnEventsBuilder
- func (b *OnEventsBuilder) ActionMode(input ActionMode) *OnEventsBuilder
- func (b *OnEventsBuilder) AddActions() *ActionBuilder
- func (b *OnEventsBuilder) Build() OnEvents
- func (b *OnEventsBuilder) EventDataFilter() *EventDataFilterBuilder
- func (b *OnEventsBuilder) EventRefs(input []string) *OnEventsBuilder
- func (b *OnEventsBuilder) RemoveActions(remove *ActionBuilder)
- type OnParentCompleteType
- type OperationState
- type OperationStateBuilder
- func (b *OperationStateBuilder) ActionMode(input ActionMode) *OperationStateBuilder
- func (b *OperationStateBuilder) AddActions() *ActionBuilder
- func (b *OperationStateBuilder) Build() OperationState
- func (b *OperationStateBuilder) RemoveActions(remove *ActionBuilder)
- func (b *OperationStateBuilder) Timeouts() *OperationStateTimeoutBuilder
- type OperationStateTimeout
- type OperationStateTimeoutBuilder
- type ParallelState
- type ParallelStateBuilder
- func (b *ParallelStateBuilder) AddBranches() *BranchBuilder
- func (b *ParallelStateBuilder) Build() ParallelState
- func (b *ParallelStateBuilder) CompletionType(input CompletionType) *ParallelStateBuilder
- func (b *ParallelStateBuilder) NumCompleted(input intstr.IntOrString) *ParallelStateBuilder
- func (b *ParallelStateBuilder) RemoveBranches(remove *BranchBuilder)
- func (b *ParallelStateBuilder) Timeouts() *ParallelStateTimeoutBuilder
- type ParallelStateTimeout
- type ParallelStateTimeoutBuilder
- type ProduceEvent
- type ProduceEventBuilder
- type Retries
- type RetriesBuilder
- type Retry
- type RetryBuilder
- func (b *RetryBuilder) Build() Retry
- func (b *RetryBuilder) Delay(input string) *RetryBuilder
- func (b *RetryBuilder) Increment(input string) *RetryBuilder
- func (b *RetryBuilder) Jitter(input floatstr.Float32OrString) *RetryBuilder
- func (b *RetryBuilder) MaxAttempts(input intstr.IntOrString) *RetryBuilder
- func (b *RetryBuilder) MaxDelay(input string) *RetryBuilder
- func (b *RetryBuilder) Multiplier(input *floatstr.Float32OrString) *RetryBuilder
- func (b *RetryBuilder) Name(input string) *RetryBuilder
- type Schedule
- type ScheduleBuilder
- type Secrets
- type SecretsBuilder
- type Sleep
- type SleepBuilder
- type SleepState
- type SleepStateBuilder
- type SleepStateTimeout
- type SleepStateTimeoutBuilder
- type Start
- type StartBuilder
- type State
- type StateBuilder
- func (b *StateBuilder) ActionMode(input ActionMode) *StateBuilder
- func (b *StateBuilder) Build() State
- func (b *StateBuilder) CallbackState() *CallbackStateBuilder
- func (b *StateBuilder) CompensatedBy(input string) *StateBuilder
- func (b *StateBuilder) CompletionType(input CompletionType) *StateBuilder
- func (b *StateBuilder) DelayState() *DelayStateBuilder
- func (b *StateBuilder) Duration(input string) *StateBuilder
- func (b *StateBuilder) EventRef(input string) *StateBuilder
- func (b *StateBuilder) EventState() *EventStateBuilder
- func (b *StateBuilder) Exclusive(input bool) *StateBuilder
- func (b *StateBuilder) ForEachState() *ForEachStateBuilder
- func (b *StateBuilder) ID(input string) *StateBuilder
- func (b *StateBuilder) InjectState() *InjectStateBuilder
- func (b *StateBuilder) InputCollection(input string) *StateBuilder
- func (b *StateBuilder) IterationParam(input string) *StateBuilder
- func (b *StateBuilder) Mode(input ForEachModeType) *StateBuilder
- func (b *StateBuilder) Name(input string) *StateBuilder
- func (b *StateBuilder) OperationState() *OperationStateBuilder
- func (b *StateBuilder) OutputCollection(input string) *StateBuilder
- func (b *StateBuilder) ParallelState() *ParallelStateBuilder
- func (b *StateBuilder) SleepState() *SleepStateBuilder
- func (b *StateBuilder) SwitchState() *SwitchStateBuilder
- func (b *StateBuilder) TimeDelay(input string) *StateBuilder
- func (b *StateBuilder) Type(input StateType) *StateBuilder
- func (b *StateBuilder) UsedForCompensation(input bool) *StateBuilder
- type StateDataFilter
- type StateDataFilterBuilder
- type StateExecTimeout
- type StateExecTimeoutBuilder
- type StateType
- type States
- type StatesBuilder
- type SwitchState
- type SwitchStateBuilder
- func (b *SwitchStateBuilder) AddDataConditions() *DataConditionBuilder
- func (b *SwitchStateBuilder) AddEventConditions() *EventConditionBuilder
- func (b *SwitchStateBuilder) Build() SwitchState
- func (b *SwitchStateBuilder) DefaultCondition() *DefaultConditionBuilder
- func (b *SwitchStateBuilder) RemoveDataConditions(remove *DataConditionBuilder)
- func (b *SwitchStateBuilder) RemoveEventConditions(remove *EventConditionBuilder)
- func (b *SwitchStateBuilder) Timeouts() *SwitchStateTimeoutBuilder
- type SwitchStateTimeout
- type SwitchStateTimeoutBuilder
- type Timeouts
- type TimeoutsBuilder
- func (b *TimeoutsBuilder) ActionExecTimeout(input string) *TimeoutsBuilder
- func (b *TimeoutsBuilder) BranchExecTimeout(input string) *TimeoutsBuilder
- func (b *TimeoutsBuilder) Build() Timeouts
- func (b *TimeoutsBuilder) EventTimeout(input string) *TimeoutsBuilder
- func (b *TimeoutsBuilder) StateExecTimeout() *StateExecTimeoutBuilder
- func (b *TimeoutsBuilder) WorkflowExecTimeout() *WorkflowExecTimeoutBuilder
- type Transition
- type TransitionBuilder
- func (b *TransitionBuilder) AddProduceEvents() *ProduceEventBuilder
- func (b *TransitionBuilder) Build() Transition
- func (b *TransitionBuilder) Compensate(input bool) *TransitionBuilder
- func (b *TransitionBuilder) NextState(input string) *TransitionBuilder
- func (b *TransitionBuilder) RemoveProduceEvents(remove *ProduceEventBuilder)
- type Type
- type ValidatorContext
- func (in *ValidatorContext) DeepCopy() *ValidatorContext
- func (in *ValidatorContext) DeepCopyInto(out *ValidatorContext)
- func (c *ValidatorContext) ExistError(name string) bool
- func (c *ValidatorContext) ExistEvent(name string) bool
- func (c *ValidatorContext) ExistFunction(name string) bool
- func (c *ValidatorContext) ExistRetry(name string) bool
- func (c *ValidatorContext) ExistState(name string) bool
- type Workflow
- type WorkflowBuilder
- func (b *WorkflowBuilder) AddEvents() *EventBuilder
- func (b *WorkflowBuilder) AddFunctions() *FunctionBuilder
- func (b *WorkflowBuilder) AddRetries() *RetryBuilder
- func (b *WorkflowBuilder) AddStates() *StateBuilder
- func (b *WorkflowBuilder) AutoRetries(input bool) *WorkflowBuilder
- func (b *WorkflowBuilder) Build() Workflow
- func (b *WorkflowBuilder) Description(input string) *WorkflowBuilder
- func (b *WorkflowBuilder) ExpressionLang(input ExpressionLangType) *WorkflowBuilder
- func (b *WorkflowBuilder) ID(input string) *WorkflowBuilder
- func (b *WorkflowBuilder) KeepActive(input bool) *WorkflowBuilder
- func (b *WorkflowBuilder) Key(input string) *WorkflowBuilder
- func (b *WorkflowBuilder) Name(input string) *WorkflowBuilder
- func (b *WorkflowBuilder) RemoveEvents(remove *EventBuilder)
- func (b *WorkflowBuilder) RemoveFunctions(remove *FunctionBuilder)
- func (b *WorkflowBuilder) RemoveRetries(remove *RetryBuilder)
- func (b *WorkflowBuilder) RemoveStates(remove *StateBuilder)
- func (b *WorkflowBuilder) SpecVersion(input string) *WorkflowBuilder
- func (b *WorkflowBuilder) Version(input string) *WorkflowBuilder
- type WorkflowExecTimeout
- type WorkflowExecTimeoutBuilder
- func (b *WorkflowExecTimeoutBuilder) Build() WorkflowExecTimeout
- func (b *WorkflowExecTimeoutBuilder) Duration(input string) *WorkflowExecTimeoutBuilder
- func (b *WorkflowExecTimeoutBuilder) Interrupt(input bool) *WorkflowExecTimeoutBuilder
- func (b *WorkflowExecTimeoutBuilder) RunBefore(input string) *WorkflowExecTimeoutBuilder
- type WorkflowRef
- type WorkflowRefBuilder
- func (b *WorkflowRefBuilder) Build() WorkflowRef
- func (b *WorkflowRefBuilder) Invoke(input InvokeKind) *WorkflowRefBuilder
- func (b *WorkflowRefBuilder) OnParentComplete(input OnParentCompleteType) *WorkflowRefBuilder
- func (b *WorkflowRefBuilder) Version(input string) *WorkflowRefBuilder
- func (b *WorkflowRefBuilder) WorkflowID(input string) *WorkflowRefBuilder
- type WorkflowValidator
Constants ¶
const (
// UnlimitedTimeout description for unlimited timeouts
UnlimitedTimeout = "unlimited"
)
const ValidatorContextValue contextValueKey = "value"
Variables ¶
This section is empty.
Functions ¶
func NewValidatorContext ¶ added in v2.2.4
func ToInterface ¶ added in v2.2.5
func ValidationWrap ¶ added in v2.2.4
func ValidationWrap(fnCtx WorkflowValidator) validator.StructLevelFuncCtx
Types ¶
type Action ¶
type Action struct { // Defines Unique action identifier. // +optional ID string `json:"id,omitempty"` // Defines Unique action name. // +optional Name string `json:"name,omitempty"` // References a reusable function definition. // +optional FunctionRef *FunctionRef `json:"functionRef,omitempty"` // References a 'trigger' and 'result' reusable event definitions. // +optional EventRef *EventRef `json:"eventRef,omitempty"` // References a workflow to be invoked. // +optional SubFlowRef *WorkflowRef `json:"subFlowRef,omitempty"` // Defines time period workflow execution should sleep before / after function execution. // +optional Sleep *Sleep `json:"sleep,omitempty"` // References a defined workflow retry definition. If not defined uses the default runtime retry definition. // +optional RetryRef string `json:"retryRef,omitempty"` // List of unique references to defined workflow errors for which the action should not be retried. // Used only when `autoRetries` is set to `true` // +optional NonRetryableErrors []string `json:"nonRetryableErrors,omitempty" validate:"omitempty,min=1"` // List of unique references to defined workflow errors for which the action should be retried. // Used only when `autoRetries` is set to `false` // +optional RetryableErrors []string `json:"retryableErrors,omitempty" validate:"omitempty,min=1"` // Filter the state data to select only the data that can be used within function definition arguments // using its fromStateData property. Filter the action results to select only the result data that should // be added/merged back into the state data using its results property. Select the part of state data which // the action data results should be added/merged to using the toStateData property. // +optional ActionDataFilter ActionDataFilter `json:"actionDataFilter,omitempty"` // Expression, if defined, must evaluate to true for this action to be performed. If false, action is disregarded. // +optional Condition string `json:"condition,omitempty"` }
Action specify invocations of services or other workflows during workflow execution. +builder-gen:new-call=ApplyDefault
func (*Action) ApplyDefault ¶ added in v2.2.3
func (a *Action) ApplyDefault()
ApplyDefault set the default values for Action
func (*Action) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Action.
func (*Action) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Action) UnmarshalJSON ¶ added in v2.2.0
UnmarshalJSON implements json.Unmarshaler
type ActionBuilder ¶ added in v2.3.0
type ActionBuilder struct {
// contains filtered or unexported fields
}
func NewActionBuilder ¶ added in v2.3.0
func NewActionBuilder() *ActionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActionBuilder) ActionDataFilter ¶ added in v2.3.0
func (b *ActionBuilder) ActionDataFilter() *ActionDataFilterBuilder
func (*ActionBuilder) Build ¶ added in v2.3.0
func (b *ActionBuilder) Build() Action
func (*ActionBuilder) Condition ¶ added in v2.3.0
func (b *ActionBuilder) Condition(input string) *ActionBuilder
func (*ActionBuilder) EventRef ¶ added in v2.3.0
func (b *ActionBuilder) EventRef() *EventRefBuilder
func (*ActionBuilder) FunctionRef ¶ added in v2.3.0
func (b *ActionBuilder) FunctionRef() *FunctionRefBuilder
func (*ActionBuilder) ID ¶ added in v2.3.0
func (b *ActionBuilder) ID(input string) *ActionBuilder
func (*ActionBuilder) Name ¶ added in v2.3.0
func (b *ActionBuilder) Name(input string) *ActionBuilder
func (*ActionBuilder) NonRetryableErrors ¶ added in v2.3.0
func (b *ActionBuilder) NonRetryableErrors(input []string) *ActionBuilder
func (*ActionBuilder) RetryRef ¶ added in v2.3.0
func (b *ActionBuilder) RetryRef(input string) *ActionBuilder
func (*ActionBuilder) RetryableErrors ¶ added in v2.3.0
func (b *ActionBuilder) RetryableErrors(input []string) *ActionBuilder
func (*ActionBuilder) Sleep ¶ added in v2.3.0
func (b *ActionBuilder) Sleep() *SleepBuilder
func (*ActionBuilder) SubFlowRef ¶ added in v2.3.0
func (b *ActionBuilder) SubFlowRef() *WorkflowRefBuilder
type ActionDataFilter ¶
type ActionDataFilter struct { // Workflow expression that filters state data that can be used by the action. // +optional FromStateData string `json:"fromStateData,omitempty"` // If set to false, action data results are not added/merged to state data. In this case 'results' // and 'toStateData' should be ignored. Default is true. // +optional UseResults bool `json:"useResults,omitempty"` // Workflow expression that filters the actions data results. // +optional Results string `json:"results,omitempty"` // Workflow expression that selects a state data element to which the action results should be // added/merged into. If not specified denotes the top-level state data element. // +optional ToStateData string `json:"toStateData,omitempty"` }
ActionDataFilter used to filter action data results. +optional +builder-gen:new-call=ApplyDefault
func (*ActionDataFilter) ApplyDefault ¶ added in v2.2.3
func (a *ActionDataFilter) ApplyDefault()
ApplyDefault set the default values for Action Data Filter
func (*ActionDataFilter) DeepCopy ¶ added in v2.2.0
func (in *ActionDataFilter) DeepCopy() *ActionDataFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActionDataFilter.
func (*ActionDataFilter) DeepCopyInto ¶ added in v2.2.0
func (in *ActionDataFilter) DeepCopyInto(out *ActionDataFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActionDataFilter) UnmarshalJSON ¶ added in v2.2.0
func (a *ActionDataFilter) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type ActionDataFilterBuilder ¶ added in v2.3.0
type ActionDataFilterBuilder struct {
// contains filtered or unexported fields
}
func NewActionDataFilterBuilder ¶ added in v2.3.0
func NewActionDataFilterBuilder() *ActionDataFilterBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActionDataFilterBuilder) Build ¶ added in v2.3.0
func (b *ActionDataFilterBuilder) Build() ActionDataFilter
func (*ActionDataFilterBuilder) FromStateData ¶ added in v2.3.0
func (b *ActionDataFilterBuilder) FromStateData(input string) *ActionDataFilterBuilder
func (*ActionDataFilterBuilder) Results ¶ added in v2.3.0
func (b *ActionDataFilterBuilder) Results(input string) *ActionDataFilterBuilder
func (*ActionDataFilterBuilder) ToStateData ¶ added in v2.3.0
func (b *ActionDataFilterBuilder) ToStateData(input string) *ActionDataFilterBuilder
func (*ActionDataFilterBuilder) UseResults ¶ added in v2.3.0
func (b *ActionDataFilterBuilder) UseResults(input bool) *ActionDataFilterBuilder
type ActionMode ¶
type ActionMode string
ActionMode specifies how actions are to be performed.
const ( // ActionModeSequential specifies actions should be performed in sequence ActionModeSequential ActionMode = "sequential" // ActionModeParallel specifies actions should be performed in parallel ActionModeParallel ActionMode = "parallel" )
func (ActionMode) KindValues ¶ added in v2.2.4
func (i ActionMode) KindValues() []string
func (ActionMode) String ¶ added in v2.2.4
func (i ActionMode) String() string
type Auth ¶ added in v2.1.0
type Auth struct { // Unique auth definition name. // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // Auth scheme, can be "basic", "bearer", or "oauth2". Default is "basic" // +kubebuilder:validation:Enum=basic;bearer;oauth2 // +kubebuilder:default=basic // +kubebuilder:validation:Required Scheme AuthType `json:"scheme" validate:"required,oneofkind"` // Auth scheme properties. Can be one of "Basic properties definition", "Bearer properties definition", // or "OAuth2 properties definition" // +kubebuilder:validation:Required Properties AuthProperties `json:"properties" validate:"required"` }
Auth definitions can be used to define authentication information that should be applied to resources defined in the operation property of function definitions. It is not used as authentication information for the function invocation, but just to access the resource containing the function invocation information.
func (*Auth) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Auth.
func (*Auth) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Auth) MarshalJSON ¶ added in v2.2.3
func (*Auth) UnmarshalJSON ¶ added in v2.1.0
UnmarshalJSON Auth definition
type AuthBuilder ¶ added in v2.3.0
type AuthBuilder struct {
// contains filtered or unexported fields
}
func NewAuthBuilder ¶ added in v2.3.0
func NewAuthBuilder() *AuthBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AuthBuilder) Build ¶ added in v2.3.0
func (b *AuthBuilder) Build() Auth
func (*AuthBuilder) Name ¶ added in v2.3.0
func (b *AuthBuilder) Name(input string) *AuthBuilder
func (*AuthBuilder) Properties ¶ added in v2.3.0
func (b *AuthBuilder) Properties() *AuthPropertiesBuilder
func (*AuthBuilder) Scheme ¶ added in v2.3.0
func (b *AuthBuilder) Scheme(input AuthType) *AuthBuilder
type AuthProperties ¶ added in v2.1.0
type AuthProperties struct { Basic *BasicAuthProperties `json:",omitempty"` Bearer *BearerAuthProperties `json:",omitempty"` OAuth2 *OAuth2AuthProperties `json:",omitempty"` }
AuthProperties ...
func (*AuthProperties) DeepCopy ¶ added in v2.2.3
func (in *AuthProperties) DeepCopy() *AuthProperties
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuthProperties.
func (*AuthProperties) DeepCopyInto ¶ added in v2.2.3
func (in *AuthProperties) DeepCopyInto(out *AuthProperties)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AuthPropertiesBuilder ¶ added in v2.3.0
type AuthPropertiesBuilder struct {
// contains filtered or unexported fields
}
func NewAuthPropertiesBuilder ¶ added in v2.3.0
func NewAuthPropertiesBuilder() *AuthPropertiesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AuthPropertiesBuilder) Basic ¶ added in v2.3.0
func (b *AuthPropertiesBuilder) Basic() *BasicAuthPropertiesBuilder
func (*AuthPropertiesBuilder) Bearer ¶ added in v2.3.0
func (b *AuthPropertiesBuilder) Bearer() *BearerAuthPropertiesBuilder
func (*AuthPropertiesBuilder) Build ¶ added in v2.3.0
func (b *AuthPropertiesBuilder) Build() AuthProperties
func (*AuthPropertiesBuilder) OAuth2 ¶ added in v2.3.0
func (b *AuthPropertiesBuilder) OAuth2() *OAuth2AuthPropertiesBuilder
type AuthType ¶ added in v2.1.0
type AuthType string
AuthType can be "basic", "bearer", or "oauth2". Default is "basic"
func (AuthType) KindValues ¶ added in v2.2.4
type Auths ¶ added in v2.2.3
type Auths []Auth
func (Auths) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Auths.
func (Auths) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Auths) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type AuthsBuilder ¶ added in v2.3.0
type AuthsBuilder struct {
// contains filtered or unexported fields
}
func NewAuthsBuilder ¶ added in v2.3.0
func NewAuthsBuilder() *AuthsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AuthsBuilder) Build ¶ added in v2.3.0
func (b *AuthsBuilder) Build() Auths
type BaseState ¶
type BaseState struct { // Unique State id. // +optional ID string `json:"id,omitempty"` // State name. // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // stateType can be any of delay, callback, event, foreach, inject, operation, parallel, sleep, switch // +kubebuilder:validation:Enum:=delay;callback;event;foreach;inject;operation;parallel;sleep;switch // +kubebuilder:validation:Required Type StateType `json:"type" validate:"required,oneofkind"` // States error handling and retries definitions. // +optional OnErrors []OnError `json:"onErrors,omitempty" validate:"omitempty,dive"` // Next transition of the workflow after the time delay. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Transition *Transition `json:"transition,omitempty"` // State data filter. // +optional StateDataFilter *StateDataFilter `json:"stateDataFilter,omitempty"` // Unique Name of a workflow state which is responsible for compensation of this state. // +optional CompensatedBy string `json:"compensatedBy,omitempty"` // If true, this state is used to compensate another state. Default is false. // +optional UsedForCompensation bool `json:"usedForCompensation,omitempty"` // State end definition. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional End *End `json:"end,omitempty"` // Metadata information. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Metadata *Metadata `json:"metadata,omitempty"` }
BaseState ...
func (*BaseState) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BaseState.
func (*BaseState) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BaseState) MarshalJSON ¶ added in v2.2.3
type BaseStateBuilder ¶ added in v2.3.0
type BaseStateBuilder struct {
// contains filtered or unexported fields
}
func NewBaseStateBuilder ¶ added in v2.3.0
func NewBaseStateBuilder() *BaseStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BaseStateBuilder) AddOnErrors ¶ added in v2.3.0
func (b *BaseStateBuilder) AddOnErrors() *OnErrorBuilder
func (*BaseStateBuilder) Build ¶ added in v2.3.0
func (b *BaseStateBuilder) Build() BaseState
func (*BaseStateBuilder) CompensatedBy ¶ added in v2.3.0
func (b *BaseStateBuilder) CompensatedBy(input string) *BaseStateBuilder
func (*BaseStateBuilder) End ¶ added in v2.3.0
func (b *BaseStateBuilder) End() *EndBuilder
func (*BaseStateBuilder) ID ¶ added in v2.3.0
func (b *BaseStateBuilder) ID(input string) *BaseStateBuilder
func (*BaseStateBuilder) Name ¶ added in v2.3.0
func (b *BaseStateBuilder) Name(input string) *BaseStateBuilder
func (*BaseStateBuilder) RemoveOnErrors ¶ added in v2.3.0
func (b *BaseStateBuilder) RemoveOnErrors(remove *OnErrorBuilder)
func (*BaseStateBuilder) StateDataFilter ¶ added in v2.3.0
func (b *BaseStateBuilder) StateDataFilter() *StateDataFilterBuilder
func (*BaseStateBuilder) Transition ¶ added in v2.3.0
func (b *BaseStateBuilder) Transition() *TransitionBuilder
func (*BaseStateBuilder) Type ¶ added in v2.3.0
func (b *BaseStateBuilder) Type(input StateType) *BaseStateBuilder
func (*BaseStateBuilder) UsedForCompensation ¶ added in v2.3.0
func (b *BaseStateBuilder) UsedForCompensation(input bool) *BaseStateBuilder
type BaseWorkflow ¶
type BaseWorkflow struct { // Workflow unique identifier // +optional ID string `json:"id,omitempty" validate:"required_without=Key"` // Key Domain-specific workflow identifier // +optional Key string `json:"key,omitempty" validate:"required_without=ID"` // Workflow name Name string `json:"name,omitempty"` // Workflow description. // +optional Description string `json:"description,omitempty"` // Workflow version. // +optional Version string `json:"version" validate:"omitempty,min=1"` // Workflow start definition. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Start *Start `json:"start,omitempty"` // Annotations List of helpful terms describing the workflows intended purpose, subject areas, or other important // qualities. // +optional Annotations []string `json:"annotations,omitempty"` // DataInputSchema URI or Object of the JSON Schema used to validate the workflow data input // +optional DataInputSchema *DataInputSchema `json:"dataInputSchema,omitempty"` // Serverless Workflow schema version // +kubebuilder:validation:Required // +kubebuilder:default="0.8" SpecVersion string `json:"specVersion" validate:"required"` // Secrets allow you to access sensitive information, such as passwords, OAuth tokens, ssh keys, etc, // inside your Workflow Expressions. // +optional Secrets Secrets `json:"secrets,omitempty" validate:"unique"` // Constants Workflow constants are used to define static, and immutable, data which is available to // Workflow Expressions. // +optional Constants *Constants `json:"constants,omitempty"` // Identifies the expression language used for workflow expressions. Default is 'jq'. // +kubebuilder:validation:Enum=jq;jsonpath;cel // +kubebuilder:default=jq // +optional ExpressionLang ExpressionLangType `json:"expressionLang,omitempty" validate:"required,oneofkind"` // Defines the workflow default timeout settings. // +optional Timeouts *Timeouts `json:"timeouts,omitempty"` // Defines checked errors that can be explicitly handled during workflow execution. // +optional Errors Errors `json:"errors,omitempty" validate:"unique=Name,dive"` // If "true", workflow instances is not terminated when there are no active execution paths. // Instance can be terminated with "terminate end definition" or reaching defined "workflowExecTimeout" // +optional KeepActive bool `json:"keepActive,omitempty"` // Metadata custom information shared with the runtime. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Metadata Metadata `json:"metadata,omitempty"` // AutoRetries If set to true, actions should automatically be retried on unchecked errors. Default is false // +optional AutoRetries bool `json:"autoRetries,omitempty"` // Auth definitions can be used to define authentication information that should be applied to resources defined // in the operation property of function definitions. It is not used as authentication information for the // function invocation, but just to access the resource containing the function invocation information. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Auth Auths `json:"auth,omitempty" validate:"unique=Name,dive"` }
BaseWorkflow describes the partial Workflow definition that does not rely on generic interfaces to make it easy for custom unmarshalers implementations to unmarshal the common data structure. +builder-gen:new-call=ApplyDefault
func (*BaseWorkflow) ApplyDefault ¶ added in v2.3.0
func (w *BaseWorkflow) ApplyDefault()
ApplyDefault set the default values for Workflow
func (*BaseWorkflow) DeepCopy ¶ added in v2.2.0
func (in *BaseWorkflow) DeepCopy() *BaseWorkflow
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BaseWorkflow.
func (*BaseWorkflow) DeepCopyInto ¶ added in v2.2.0
func (in *BaseWorkflow) DeepCopyInto(out *BaseWorkflow)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BaseWorkflowBuilder ¶ added in v2.3.0
type BaseWorkflowBuilder struct {
// contains filtered or unexported fields
}
func NewBaseWorkflowBuilder ¶ added in v2.3.0
func NewBaseWorkflowBuilder() *BaseWorkflowBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BaseWorkflowBuilder) AddAuth ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) AddAuth() *AuthBuilder
func (*BaseWorkflowBuilder) AddErrors ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) AddErrors() *ErrorBuilder
func (*BaseWorkflowBuilder) Annotations ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Annotations(input []string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) AutoRetries ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) AutoRetries(input bool) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) Build ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Build() BaseWorkflow
func (*BaseWorkflowBuilder) Constants ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Constants() *ConstantsBuilder
func (*BaseWorkflowBuilder) DataInputSchema ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) DataInputSchema() *DataInputSchemaBuilder
func (*BaseWorkflowBuilder) Description ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Description(input string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) ExpressionLang ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) ExpressionLang(input ExpressionLangType) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) ID ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) ID(input string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) KeepActive ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) KeepActive(input bool) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) Key ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Key(input string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) Metadata ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Metadata(input Metadata) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) Name ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Name(input string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) RemoveAuth ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) RemoveAuth(remove *AuthBuilder)
func (*BaseWorkflowBuilder) RemoveErrors ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) RemoveErrors(remove *ErrorBuilder)
func (*BaseWorkflowBuilder) Secrets ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Secrets(input Secrets) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) SpecVersion ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) SpecVersion(input string) *BaseWorkflowBuilder
func (*BaseWorkflowBuilder) Start ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Start() *StartBuilder
func (*BaseWorkflowBuilder) Timeouts ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Timeouts() *TimeoutsBuilder
func (*BaseWorkflowBuilder) Version ¶ added in v2.3.0
func (b *BaseWorkflowBuilder) Version(input string) *BaseWorkflowBuilder
type BasicAuthProperties ¶ added in v2.1.0
type BasicAuthProperties struct { Common `json:",inline"` // Secret Expression referencing a workflow secret that contains all needed auth info // +optional Secret string `json:"secret,omitempty"` // Username String or a workflow expression. Contains the username // +kubebuilder:validation:Required Username string `json:"username" validate:"required"` // Password String or a workflow expression. Contains the user password // +kubebuilder:validation:Required Password string `json:"password" validate:"required"` }
BasicAuthProperties Basic Auth Info
func (*BasicAuthProperties) DeepCopy ¶ added in v2.2.0
func (in *BasicAuthProperties) DeepCopy() *BasicAuthProperties
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BasicAuthProperties.
func (*BasicAuthProperties) DeepCopyInto ¶ added in v2.2.0
func (in *BasicAuthProperties) DeepCopyInto(out *BasicAuthProperties)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BasicAuthPropertiesBuilder ¶ added in v2.3.0
type BasicAuthPropertiesBuilder struct { CommonBuilder // contains filtered or unexported fields }
func NewBasicAuthPropertiesBuilder ¶ added in v2.3.0
func NewBasicAuthPropertiesBuilder() *BasicAuthPropertiesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BasicAuthPropertiesBuilder) Build ¶ added in v2.3.0
func (b *BasicAuthPropertiesBuilder) Build() BasicAuthProperties
func (*BasicAuthPropertiesBuilder) Common ¶ added in v2.3.0
func (b *BasicAuthPropertiesBuilder) Common() *CommonBuilder
func (*BasicAuthPropertiesBuilder) Password ¶ added in v2.3.0
func (b *BasicAuthPropertiesBuilder) Password(input string) *BasicAuthPropertiesBuilder
func (*BasicAuthPropertiesBuilder) Secret ¶ added in v2.3.0
func (b *BasicAuthPropertiesBuilder) Secret(input string) *BasicAuthPropertiesBuilder
func (*BasicAuthPropertiesBuilder) Username ¶ added in v2.3.0
func (b *BasicAuthPropertiesBuilder) Username(input string) *BasicAuthPropertiesBuilder
type BearerAuthProperties ¶ added in v2.1.0
type BearerAuthProperties struct { Common `json:",inline"` // Secret Expression referencing a workflow secret that contains all needed auth info // +optional Secret string `json:"secret,omitempty"` // Token String or a workflow expression. Contains the token // +kubebuilder:validation:Required Token string `json:"token" validate:"required"` }
BearerAuthProperties Bearer auth information
func (*BearerAuthProperties) DeepCopy ¶ added in v2.2.0
func (in *BearerAuthProperties) DeepCopy() *BearerAuthProperties
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BearerAuthProperties.
func (*BearerAuthProperties) DeepCopyInto ¶ added in v2.2.0
func (in *BearerAuthProperties) DeepCopyInto(out *BearerAuthProperties)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BearerAuthPropertiesBuilder ¶ added in v2.3.0
type BearerAuthPropertiesBuilder struct { CommonBuilder // contains filtered or unexported fields }
func NewBearerAuthPropertiesBuilder ¶ added in v2.3.0
func NewBearerAuthPropertiesBuilder() *BearerAuthPropertiesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BearerAuthPropertiesBuilder) Build ¶ added in v2.3.0
func (b *BearerAuthPropertiesBuilder) Build() BearerAuthProperties
func (*BearerAuthPropertiesBuilder) Common ¶ added in v2.3.0
func (b *BearerAuthPropertiesBuilder) Common() *CommonBuilder
func (*BearerAuthPropertiesBuilder) Secret ¶ added in v2.3.0
func (b *BearerAuthPropertiesBuilder) Secret(input string) *BearerAuthPropertiesBuilder
func (*BearerAuthPropertiesBuilder) Token ¶ added in v2.3.0
func (b *BearerAuthPropertiesBuilder) Token(input string) *BearerAuthPropertiesBuilder
type Branch ¶
type Branch struct { // Branch name // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // Actions to be executed in this branch // +kubebuilder:validation:MinItems=1 Actions []Action `json:"actions" validate:"required,min=1,dive"` // Branch specific timeout settings // +optional Timeouts *BranchTimeouts `json:"timeouts,omitempty"` }
Branch Definition
func (*Branch) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Branch.
func (*Branch) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BranchBuilder ¶ added in v2.3.0
type BranchBuilder struct {
// contains filtered or unexported fields
}
func NewBranchBuilder ¶ added in v2.3.0
func NewBranchBuilder() *BranchBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BranchBuilder) AddActions ¶ added in v2.3.0
func (b *BranchBuilder) AddActions() *ActionBuilder
func (*BranchBuilder) Build ¶ added in v2.3.0
func (b *BranchBuilder) Build() Branch
func (*BranchBuilder) Name ¶ added in v2.3.0
func (b *BranchBuilder) Name(input string) *BranchBuilder
func (*BranchBuilder) RemoveActions ¶ added in v2.3.0
func (b *BranchBuilder) RemoveActions(remove *ActionBuilder)
func (*BranchBuilder) Timeouts ¶ added in v2.3.0
func (b *BranchBuilder) Timeouts() *BranchTimeoutsBuilder
type BranchTimeouts ¶ added in v2.1.0
type BranchTimeouts struct { // Single actions definition execution timeout duration (ISO 8601 duration format) // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,iso8601duration"` // Single branch execution timeout duration (ISO 8601 duration format) // +optional BranchExecTimeout string `json:"branchExecTimeout,omitempty" validate:"omitempty,iso8601duration"` }
BranchTimeouts defines the specific timeout settings for branch
func (*BranchTimeouts) DeepCopy ¶ added in v2.2.0
func (in *BranchTimeouts) DeepCopy() *BranchTimeouts
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BranchTimeouts.
func (*BranchTimeouts) DeepCopyInto ¶ added in v2.2.0
func (in *BranchTimeouts) DeepCopyInto(out *BranchTimeouts)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BranchTimeoutsBuilder ¶ added in v2.3.0
type BranchTimeoutsBuilder struct {
// contains filtered or unexported fields
}
func NewBranchTimeoutsBuilder ¶ added in v2.3.0
func NewBranchTimeoutsBuilder() *BranchTimeoutsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BranchTimeoutsBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *BranchTimeoutsBuilder) ActionExecTimeout(input string) *BranchTimeoutsBuilder
func (*BranchTimeoutsBuilder) BranchExecTimeout ¶ added in v2.3.0
func (b *BranchTimeoutsBuilder) BranchExecTimeout(input string) *BranchTimeoutsBuilder
func (*BranchTimeoutsBuilder) Build ¶ added in v2.3.0
func (b *BranchTimeoutsBuilder) Build() BranchTimeouts
type CallbackState ¶
type CallbackState struct { // Defines the action to be executed. // +kubebuilder:validation:Required Action Action `json:"action"` // References a unique callback event name in the defined workflow events. // +kubebuilder:validation:Required EventRef string `json:"eventRef" validate:"required"` // Time period to wait for incoming events (ISO 8601 format) // +optional Timeouts *CallbackStateTimeout `json:"timeouts,omitempty"` // Event data filter definition. // +optional EventDataFilter *EventDataFilter `json:"eventDataFilter,omitempty"` }
CallbackState executes a function and waits for callback event that indicates completion of the task.
func (*CallbackState) DeepCopy ¶ added in v2.2.0
func (in *CallbackState) DeepCopy() *CallbackState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CallbackState.
func (*CallbackState) DeepCopyInto ¶ added in v2.2.0
func (in *CallbackState) DeepCopyInto(out *CallbackState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CallbackState) MarshalJSON ¶ added in v2.2.3
func (c *CallbackState) MarshalJSON() ([]byte, error)
type CallbackStateBuilder ¶ added in v2.3.0
type CallbackStateBuilder struct {
// contains filtered or unexported fields
}
func NewCallbackStateBuilder ¶ added in v2.3.0
func NewCallbackStateBuilder() *CallbackStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CallbackStateBuilder) Action ¶ added in v2.3.0
func (b *CallbackStateBuilder) Action() *ActionBuilder
func (*CallbackStateBuilder) Build ¶ added in v2.3.0
func (b *CallbackStateBuilder) Build() CallbackState
func (*CallbackStateBuilder) EventDataFilter ¶ added in v2.3.0
func (b *CallbackStateBuilder) EventDataFilter() *EventDataFilterBuilder
func (*CallbackStateBuilder) EventRef ¶ added in v2.3.0
func (b *CallbackStateBuilder) EventRef(input string) *CallbackStateBuilder
func (*CallbackStateBuilder) Timeouts ¶ added in v2.3.0
func (b *CallbackStateBuilder) Timeouts() *CallbackStateTimeoutBuilder
type CallbackStateTimeout ¶ added in v2.1.0
type CallbackStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Default single actions definition execution timeout (ISO 8601 duration format) // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,iso8601duration"` // Default timeout for consuming defined events (ISO 8601 duration format) // +optional EventTimeout string `json:"eventTimeout,omitempty" validate:"omitempty,iso8601duration"` }
CallbackStateTimeout defines timeout settings for callback state
func (*CallbackStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *CallbackStateTimeout) DeepCopy() *CallbackStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CallbackStateTimeout.
func (*CallbackStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *CallbackStateTimeout) DeepCopyInto(out *CallbackStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CallbackStateTimeoutBuilder ¶ added in v2.3.0
type CallbackStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewCallbackStateTimeoutBuilder ¶ added in v2.3.0
func NewCallbackStateTimeoutBuilder() *CallbackStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CallbackStateTimeoutBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *CallbackStateTimeoutBuilder) ActionExecTimeout(input string) *CallbackStateTimeoutBuilder
func (*CallbackStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *CallbackStateTimeoutBuilder) Build() CallbackStateTimeout
func (*CallbackStateTimeoutBuilder) EventTimeout ¶ added in v2.3.0
func (b *CallbackStateTimeoutBuilder) EventTimeout(input string) *CallbackStateTimeoutBuilder
func (*CallbackStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *CallbackStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type Common ¶
type Common struct { // Metadata information // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Metadata Metadata `json:"metadata,omitempty"` }
Common schema for Serverless Workflow specification
func (*Common) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Common.
func (*Common) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CommonBuilder ¶ added in v2.3.0
type CommonBuilder struct {
// contains filtered or unexported fields
}
func NewCommonBuilder ¶ added in v2.3.0
func NewCommonBuilder() *CommonBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CommonBuilder) Build ¶ added in v2.3.0
func (b *CommonBuilder) Build() Common
func (*CommonBuilder) Metadata ¶ added in v2.3.0
func (b *CommonBuilder) Metadata(input Metadata) *CommonBuilder
type CompletionType ¶
type CompletionType string
CompletionType define on how to complete branch execution.
const ( // CompletionTypeAllOf defines all branches must complete execution before the state can transition/end. CompletionTypeAllOf CompletionType = "allOf" // CompletionTypeAtLeast defines state can transition/end once at least the specified number of branches // have completed execution. CompletionTypeAtLeast CompletionType = "atLeast" )
func (CompletionType) KindValues ¶ added in v2.2.4
func (i CompletionType) KindValues() []string
func (CompletionType) String ¶ added in v2.2.4
func (i CompletionType) String() string
type Constants ¶ added in v2.1.0
type Constants struct { // Data represents the generic structure of the constants value // +optional Data ConstantsData `json:",omitempty"` }
Constants Workflow constants are used to define static, and immutable, data which is available to Workflow Expressions.
func (*Constants) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Constants.
func (*Constants) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Constants) UnmarshalJSON ¶ added in v2.1.0
UnmarshalJSON implements json.Unmarshaler
type ConstantsBuilder ¶ added in v2.3.0
type ConstantsBuilder struct {
// contains filtered or unexported fields
}
func NewConstantsBuilder ¶ added in v2.3.0
func NewConstantsBuilder() *ConstantsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConstantsBuilder) Build ¶ added in v2.3.0
func (b *ConstantsBuilder) Build() Constants
func (*ConstantsBuilder) Data ¶ added in v2.3.0
func (b *ConstantsBuilder) Data(input ConstantsData) *ConstantsBuilder
type ConstantsData ¶ added in v2.2.3
type ConstantsData map[string]json.RawMessage
func (ConstantsData) DeepCopy ¶ added in v2.2.3
func (in ConstantsData) DeepCopy() ConstantsData
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConstantsData.
func (ConstantsData) DeepCopyInto ¶ added in v2.2.3
func (in ConstantsData) DeepCopyInto(out *ConstantsData)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConstantsDataBuilder ¶ added in v2.3.0
type ConstantsDataBuilder struct {
// contains filtered or unexported fields
}
func NewConstantsDataBuilder ¶ added in v2.3.0
func NewConstantsDataBuilder() *ConstantsDataBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConstantsDataBuilder) Build ¶ added in v2.3.0
func (b *ConstantsDataBuilder) Build() ConstantsData
type ContinueAs ¶ added in v2.1.0
type ContinueAs struct { // Unique id of the workflow to continue execution as. // +kubebuilder:validation:Required WorkflowID string `json:"workflowId" validate:"required"` // Version of the workflow to continue execution as. // +optional Version string `json:"version,omitempty"` // If string type, an expression which selects parts of the states data output to become the workflow data input of // continued execution. If object type, a custom object to become the workflow data input of the continued execution // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Data Object `json:"data,omitempty"` // WorkflowExecTimeout Workflow execution timeout to be used by the workflow continuing execution. // Overwrites any specific settings set by that workflow // +optional WorkflowExecTimeout WorkflowExecTimeout `json:"workflowExecTimeout,omitempty"` }
ContinueAs can be used to stop the current workflow execution and start another one (of the same or a different type)
func (*ContinueAs) DeepCopy ¶ added in v2.2.0
func (in *ContinueAs) DeepCopy() *ContinueAs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContinueAs.
func (*ContinueAs) DeepCopyInto ¶ added in v2.2.0
func (in *ContinueAs) DeepCopyInto(out *ContinueAs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContinueAs) UnmarshalJSON ¶ added in v2.2.0
func (c *ContinueAs) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type ContinueAsBuilder ¶ added in v2.3.0
type ContinueAsBuilder struct {
// contains filtered or unexported fields
}
func NewContinueAsBuilder ¶ added in v2.3.0
func NewContinueAsBuilder() *ContinueAsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContinueAsBuilder) Build ¶ added in v2.3.0
func (b *ContinueAsBuilder) Build() ContinueAs
func (*ContinueAsBuilder) Data ¶ added in v2.3.0
func (b *ContinueAsBuilder) Data() *ObjectBuilder
func (*ContinueAsBuilder) Version ¶ added in v2.3.0
func (b *ContinueAsBuilder) Version(input string) *ContinueAsBuilder
func (*ContinueAsBuilder) WorkflowExecTimeout ¶ added in v2.3.0
func (b *ContinueAsBuilder) WorkflowExecTimeout() *WorkflowExecTimeoutBuilder
func (*ContinueAsBuilder) WorkflowID ¶ added in v2.3.0
func (b *ContinueAsBuilder) WorkflowID(input string) *ContinueAsBuilder
type Correlation ¶
type Correlation struct { // CloudEvent Extension Context Attribute name // +kubebuilder:validation:Required ContextAttributeName string `json:"contextAttributeName" validate:"required"` // CloudEvent Extension Context Attribute value // +optional ContextAttributeValue string `json:"contextAttributeValue,omitempty"` }
Correlation define event correlation rules for an event. Only used for `consumed` events
func (*Correlation) DeepCopy ¶ added in v2.2.0
func (in *Correlation) DeepCopy() *Correlation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Correlation.
func (*Correlation) DeepCopyInto ¶ added in v2.2.0
func (in *Correlation) DeepCopyInto(out *Correlation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CorrelationBuilder ¶ added in v2.3.0
type CorrelationBuilder struct {
// contains filtered or unexported fields
}
func NewCorrelationBuilder ¶ added in v2.3.0
func NewCorrelationBuilder() *CorrelationBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CorrelationBuilder) Build ¶ added in v2.3.0
func (b *CorrelationBuilder) Build() Correlation
func (*CorrelationBuilder) ContextAttributeName ¶ added in v2.3.0
func (b *CorrelationBuilder) ContextAttributeName(input string) *CorrelationBuilder
func (*CorrelationBuilder) ContextAttributeValue ¶ added in v2.3.0
func (b *CorrelationBuilder) ContextAttributeValue(input string) *CorrelationBuilder
type Cron ¶
type Cron struct { // Cron expression describing when the workflow instance should be created (automatically). // +kubebuilder:validation:Required Expression string `json:"expression" validate:"required"` // Specific date and time (ISO 8601 format) when the cron expression is no longer valid. // +optional ValidUntil string `json:"validUntil,omitempty" validate:"omitempty,iso8601datetime"` }
Cron ...
func (*Cron) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cron.
func (*Cron) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cron) UnmarshalJSON ¶
UnmarshalJSON custom unmarshal function for Cron
type CronBuilder ¶ added in v2.3.0
type CronBuilder struct {
// contains filtered or unexported fields
}
func NewCronBuilder ¶ added in v2.3.0
func NewCronBuilder() *CronBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronBuilder) Build ¶ added in v2.3.0
func (b *CronBuilder) Build() Cron
func (*CronBuilder) Expression ¶ added in v2.3.0
func (b *CronBuilder) Expression(input string) *CronBuilder
func (*CronBuilder) ValidUntil ¶ added in v2.3.0
func (b *CronBuilder) ValidUntil(input string) *CronBuilder
type DataCondition ¶
type DataCondition struct { // Data condition name. // +optional Name string `json:"name,omitempty"` // Workflow expression evaluated against state data. Must evaluate to true or false. // +kubebuilder:validation:Required Condition string `json:"condition" validate:"required"` // Metadata information. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Metadata Metadata `json:"metadata,omitempty"` // TODO End or Transition needs to be exclusive tag, one or another should be set. // Explicit transition to end End *End `json:"end" validate:"omitempty"` // Workflow transition if condition is evaluated to true Transition *Transition `json:"transition,omitempty" validate:"omitempty"` }
DataCondition specify a data-based condition statement which causes a transition to another workflow state if evaluated to true.
func (*DataCondition) DeepCopy ¶ added in v2.2.0
func (in *DataCondition) DeepCopy() *DataCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataCondition.
func (*DataCondition) DeepCopyInto ¶ added in v2.2.0
func (in *DataCondition) DeepCopyInto(out *DataCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DataConditionBuilder ¶ added in v2.3.0
type DataConditionBuilder struct {
// contains filtered or unexported fields
}
func NewDataConditionBuilder ¶ added in v2.3.0
func NewDataConditionBuilder() *DataConditionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DataConditionBuilder) Build ¶ added in v2.3.0
func (b *DataConditionBuilder) Build() DataCondition
func (*DataConditionBuilder) Condition ¶ added in v2.3.0
func (b *DataConditionBuilder) Condition(input string) *DataConditionBuilder
func (*DataConditionBuilder) End ¶ added in v2.3.0
func (b *DataConditionBuilder) End() *EndBuilder
func (*DataConditionBuilder) Metadata ¶ added in v2.3.0
func (b *DataConditionBuilder) Metadata(input Metadata) *DataConditionBuilder
func (*DataConditionBuilder) Name ¶ added in v2.3.0
func (b *DataConditionBuilder) Name(input string) *DataConditionBuilder
func (*DataConditionBuilder) Transition ¶ added in v2.3.0
func (b *DataConditionBuilder) Transition() *TransitionBuilder
type DataInputSchema ¶ added in v2.1.0
type DataInputSchema struct { // +kubebuilder:validation:Required // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Schema *Object `json:"schema" validate:"required"` // +kubebuilder:validation:Required FailOnValidationErrors bool `json:"failOnValidationErrors"` }
DataInputSchema Used to validate the workflow data input against a defined JSON Schema +builder-gen:new-call=ApplyDefault
func (*DataInputSchema) ApplyDefault ¶ added in v2.2.3
func (d *DataInputSchema) ApplyDefault()
ApplyDefault set the default values for Data Input Schema
func (*DataInputSchema) DeepCopy ¶ added in v2.2.0
func (in *DataInputSchema) DeepCopy() *DataInputSchema
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataInputSchema.
func (*DataInputSchema) DeepCopyInto ¶ added in v2.2.0
func (in *DataInputSchema) DeepCopyInto(out *DataInputSchema)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DataInputSchema) UnmarshalJSON ¶ added in v2.1.0
func (d *DataInputSchema) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type DataInputSchemaBuilder ¶ added in v2.3.0
type DataInputSchemaBuilder struct {
// contains filtered or unexported fields
}
func NewDataInputSchemaBuilder ¶ added in v2.3.0
func NewDataInputSchemaBuilder() *DataInputSchemaBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DataInputSchemaBuilder) Build ¶ added in v2.3.0
func (b *DataInputSchemaBuilder) Build() DataInputSchema
func (*DataInputSchemaBuilder) FailOnValidationErrors ¶ added in v2.3.0
func (b *DataInputSchemaBuilder) FailOnValidationErrors(input bool) *DataInputSchemaBuilder
func (*DataInputSchemaBuilder) Schema ¶ added in v2.3.0
func (b *DataInputSchemaBuilder) Schema() *ObjectBuilder
type DefaultCondition ¶ added in v2.1.0
type DefaultCondition struct { // Serverless workflow states can have one or more incoming and outgoing transitions (from/to other states). // Each state can define a transition definition that is used to determine which state to transition to next. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Transition *Transition `json:"transition,omitempty"` // If this state an end state // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional End *End `json:"end,omitempty"` }
DefaultCondition Can be either a transition or end definition
func (*DefaultCondition) DeepCopy ¶ added in v2.2.0
func (in *DefaultCondition) DeepCopy() *DefaultCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DefaultCondition.
func (*DefaultCondition) DeepCopyInto ¶ added in v2.2.0
func (in *DefaultCondition) DeepCopyInto(out *DefaultCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DefaultCondition) UnmarshalJSON ¶ added in v2.2.3
func (e *DefaultCondition) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type DefaultConditionBuilder ¶ added in v2.3.0
type DefaultConditionBuilder struct {
// contains filtered or unexported fields
}
func NewDefaultConditionBuilder ¶ added in v2.3.0
func NewDefaultConditionBuilder() *DefaultConditionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DefaultConditionBuilder) Build ¶ added in v2.3.0
func (b *DefaultConditionBuilder) Build() DefaultCondition
func (*DefaultConditionBuilder) End ¶ added in v2.3.0
func (b *DefaultConditionBuilder) End() *EndBuilder
func (*DefaultConditionBuilder) Transition ¶ added in v2.3.0
func (b *DefaultConditionBuilder) Transition() *TransitionBuilder
type DelayState ¶
type DelayState struct { // Amount of time (ISO 8601 format) to delay // +kubebuilder:validation:Required TimeDelay string `json:"timeDelay" validate:"required,iso8601duration"` }
DelayState Causes the workflow execution to delay for a specified duration
func (*DelayState) DeepCopy ¶ added in v2.2.0
func (in *DelayState) DeepCopy() *DelayState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DelayState.
func (*DelayState) DeepCopyInto ¶ added in v2.2.0
func (in *DelayState) DeepCopyInto(out *DelayState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DelayState) MarshalJSON ¶ added in v2.2.3
func (a *DelayState) MarshalJSON() ([]byte, error)
type DelayStateBuilder ¶ added in v2.3.0
type DelayStateBuilder struct {
// contains filtered or unexported fields
}
func NewDelayStateBuilder ¶ added in v2.3.0
func NewDelayStateBuilder() *DelayStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DelayStateBuilder) Build ¶ added in v2.3.0
func (b *DelayStateBuilder) Build() DelayState
func (*DelayStateBuilder) TimeDelay ¶ added in v2.3.0
func (b *DelayStateBuilder) TimeDelay(input string) *DelayStateBuilder
type End ¶
type End struct { // If true, completes all execution flows in the given workflow instance. // +optional Terminate bool `json:"terminate,omitempty"` // Array of producedEvent definitions. Defines events that should be produced. // +optional ProduceEvents []ProduceEvent `json:"produceEvents,omitempty"` // If set to true, triggers workflow compensation before workflow execution completes. Default is false. // +optional Compensate bool `json:"compensate,omitempty"` // Defines that current workflow execution should stop, and execution should continue as a new workflow // instance of the provided id // +optional ContinueAs *ContinueAs `json:"continueAs,omitempty"` }
End definition
func (*End) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new End.
func (*End) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*End) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
type EndBuilder ¶ added in v2.3.0
type EndBuilder struct {
// contains filtered or unexported fields
}
func NewEndBuilder ¶ added in v2.3.0
func NewEndBuilder() *EndBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EndBuilder) AddProduceEvents ¶ added in v2.3.0
func (b *EndBuilder) AddProduceEvents() *ProduceEventBuilder
func (*EndBuilder) Build ¶ added in v2.3.0
func (b *EndBuilder) Build() End
func (*EndBuilder) Compensate ¶ added in v2.3.0
func (b *EndBuilder) Compensate(input bool) *EndBuilder
func (*EndBuilder) ContinueAs ¶ added in v2.3.0
func (b *EndBuilder) ContinueAs() *ContinueAsBuilder
func (*EndBuilder) RemoveProduceEvents ¶ added in v2.3.0
func (b *EndBuilder) RemoveProduceEvents(remove *ProduceEventBuilder)
func (*EndBuilder) Terminate ¶ added in v2.3.0
func (b *EndBuilder) Terminate(input bool) *EndBuilder
type Error ¶
type Error struct { // Name Domain-specific error name. // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // Code OnError code. Can be used in addition to the name to help runtimes resolve to technical errors/exceptions. // Should not be defined if error is set to '*'. // +optional Code string `json:"code,omitempty" validate:"omitempty,min=1"` // OnError description. // +optional Description string `json:"description,omitempty"` }
Error declaration for workflow definitions
func (*Error) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Error.
func (*Error) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ErrorBuilder ¶ added in v2.3.0
type ErrorBuilder struct {
// contains filtered or unexported fields
}
func NewErrorBuilder ¶ added in v2.3.0
func NewErrorBuilder() *ErrorBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ErrorBuilder) Build ¶ added in v2.3.0
func (b *ErrorBuilder) Build() Error
func (*ErrorBuilder) Code ¶ added in v2.3.0
func (b *ErrorBuilder) Code(input string) *ErrorBuilder
func (*ErrorBuilder) Description ¶ added in v2.3.0
func (b *ErrorBuilder) Description(input string) *ErrorBuilder
func (*ErrorBuilder) Name ¶ added in v2.3.0
func (b *ErrorBuilder) Name(input string) *ErrorBuilder
type Errors ¶ added in v2.2.3
type Errors []Error
func (Errors) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Errors.
func (Errors) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Errors) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type ErrorsBuilder ¶ added in v2.3.0
type ErrorsBuilder struct {
// contains filtered or unexported fields
}
func NewErrorsBuilder ¶ added in v2.3.0
func NewErrorsBuilder() *ErrorsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ErrorsBuilder) Build ¶ added in v2.3.0
func (b *ErrorsBuilder) Build() Errors
type Event ¶
type Event struct { Common `json:",inline"` // Unique event name. // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // CloudEvent source. // +optional Source string `json:"source,omitempty"` // CloudEvent type. // +kubebuilder:validation:Required Type string `json:"type" validate:"required"` // Defines the CloudEvent as either 'consumed' or 'produced' by the workflow. Defaults to `consumed`. // +kubebuilder:validation:Enum=consumed;produced // +kubebuilder:default=consumed Kind EventKind `json:"kind,omitempty" validate:"required,oneofkind"` // If `true`, only the Event payload is accessible to consuming Workflow states. If `false`, both event payload // and context attributes should be accessible. Defaults to true. // +kubebuilder:default=true // +optional DataOnly bool `json:"dataOnly,omitempty"` // Define event correlation rules for this event. Only used for consumed events. // +optional Correlation []Correlation `json:"correlation,omitempty" validate:"dive"` }
Event used to define events and their correlations +builder-gen:new-call=ApplyDefault
func (*Event) ApplyDefault ¶ added in v2.2.3
func (e *Event) ApplyDefault()
ApplyDefault set the default values for Event
func (*Event) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.
func (*Event) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Event) UnmarshalJSON ¶ added in v2.2.0
UnmarshalJSON unmarshal Event object from json bytes
type EventBuilder ¶ added in v2.3.0
type EventBuilder struct { CommonBuilder // contains filtered or unexported fields }
func NewEventBuilder ¶ added in v2.3.0
func NewEventBuilder() *EventBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventBuilder) AddCorrelation ¶ added in v2.3.0
func (b *EventBuilder) AddCorrelation() *CorrelationBuilder
func (*EventBuilder) Build ¶ added in v2.3.0
func (b *EventBuilder) Build() Event
func (*EventBuilder) Common ¶ added in v2.3.0
func (b *EventBuilder) Common() *CommonBuilder
func (*EventBuilder) DataOnly ¶ added in v2.3.0
func (b *EventBuilder) DataOnly(input bool) *EventBuilder
func (*EventBuilder) Kind ¶ added in v2.3.0
func (b *EventBuilder) Kind(input EventKind) *EventBuilder
func (*EventBuilder) Name ¶ added in v2.3.0
func (b *EventBuilder) Name(input string) *EventBuilder
func (*EventBuilder) RemoveCorrelation ¶ added in v2.3.0
func (b *EventBuilder) RemoveCorrelation(remove *CorrelationBuilder)
func (*EventBuilder) Source ¶ added in v2.3.0
func (b *EventBuilder) Source(input string) *EventBuilder
func (*EventBuilder) Type ¶ added in v2.3.0
func (b *EventBuilder) Type(input string) *EventBuilder
type EventCondition ¶
type EventCondition struct { // Event condition name. // +optional Name string `json:"name,omitempty"` // References a unique event name in the defined workflow events. // +kubebuilder:validation:Required EventRef string `json:"eventRef" validate:"required"` // Event data filter definition. // +optional EventDataFilter *EventDataFilter `json:"eventDataFilter,omitempty"` // Metadata information. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Metadata Metadata `json:"metadata,omitempty"` // TODO End or Transition needs to be exclusive tag, one or another should be set. // Explicit transition to end // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional End *End `json:"end" validate:"omitempty"` // Workflow transition if condition is evaluated to true // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Transition *Transition `json:"transition" validate:"omitempty"` }
EventCondition specify events which the switch state must wait for.
func (*EventCondition) DeepCopy ¶ added in v2.2.0
func (in *EventCondition) DeepCopy() *EventCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventCondition.
func (*EventCondition) DeepCopyInto ¶ added in v2.2.0
func (in *EventCondition) DeepCopyInto(out *EventCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventConditionBuilder ¶ added in v2.3.0
type EventConditionBuilder struct {
// contains filtered or unexported fields
}
func NewEventConditionBuilder ¶ added in v2.3.0
func NewEventConditionBuilder() *EventConditionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventConditionBuilder) Build ¶ added in v2.3.0
func (b *EventConditionBuilder) Build() EventCondition
func (*EventConditionBuilder) End ¶ added in v2.3.0
func (b *EventConditionBuilder) End() *EndBuilder
func (*EventConditionBuilder) EventDataFilter ¶ added in v2.3.0
func (b *EventConditionBuilder) EventDataFilter() *EventDataFilterBuilder
func (*EventConditionBuilder) EventRef ¶ added in v2.3.0
func (b *EventConditionBuilder) EventRef(input string) *EventConditionBuilder
func (*EventConditionBuilder) Metadata ¶ added in v2.3.0
func (b *EventConditionBuilder) Metadata(input Metadata) *EventConditionBuilder
func (*EventConditionBuilder) Name ¶ added in v2.3.0
func (b *EventConditionBuilder) Name(input string) *EventConditionBuilder
func (*EventConditionBuilder) Transition ¶ added in v2.3.0
func (b *EventConditionBuilder) Transition() *TransitionBuilder
type EventConditions ¶ added in v2.2.4
type EventConditions []EventCondition
func (EventConditions) DeepCopy ¶ added in v2.2.4
func (in EventConditions) DeepCopy() EventConditions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConditions.
func (EventConditions) DeepCopyInto ¶ added in v2.2.4
func (in EventConditions) DeepCopyInto(out *EventConditions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventConditionsBuilder ¶ added in v2.3.0
type EventConditionsBuilder struct {
// contains filtered or unexported fields
}
func NewEventConditionsBuilder ¶ added in v2.3.0
func NewEventConditionsBuilder() *EventConditionsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventConditionsBuilder) Build ¶ added in v2.3.0
func (b *EventConditionsBuilder) Build() EventConditions
type EventDataFilter ¶
type EventDataFilter struct { // If set to false, event payload is not added/merged to state data. In this case 'data' and 'toStateData' // should be ignored. Default is true. // +optional UseData bool `json:"useData,omitempty"` // Workflow expression that filters of the event data (payload). // +optional Data string `json:"data,omitempty"` // Workflow expression that selects a state data element to which the action results should be added/merged into. // If not specified denotes the top-level state data element // +optional ToStateData string `json:"toStateData,omitempty"` }
EventDataFilter used to filter consumed event payloads. +builder-gen:new-call=ApplyDefault
func (*EventDataFilter) ApplyDefault ¶ added in v2.2.3
func (f *EventDataFilter) ApplyDefault()
ApplyDefault set the default values for Event Data Filter
func (*EventDataFilter) DeepCopy ¶ added in v2.2.0
func (in *EventDataFilter) DeepCopy() *EventDataFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDataFilter.
func (*EventDataFilter) DeepCopyInto ¶ added in v2.2.0
func (in *EventDataFilter) DeepCopyInto(out *EventDataFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventDataFilter) UnmarshalJSON ¶ added in v2.2.0
func (f *EventDataFilter) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type EventDataFilterBuilder ¶ added in v2.3.0
type EventDataFilterBuilder struct {
// contains filtered or unexported fields
}
func NewEventDataFilterBuilder ¶ added in v2.3.0
func NewEventDataFilterBuilder() *EventDataFilterBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventDataFilterBuilder) Build ¶ added in v2.3.0
func (b *EventDataFilterBuilder) Build() EventDataFilter
func (*EventDataFilterBuilder) Data ¶ added in v2.3.0
func (b *EventDataFilterBuilder) Data(input string) *EventDataFilterBuilder
func (*EventDataFilterBuilder) ToStateData ¶ added in v2.3.0
func (b *EventDataFilterBuilder) ToStateData(input string) *EventDataFilterBuilder
func (*EventDataFilterBuilder) UseData ¶ added in v2.3.0
func (b *EventDataFilterBuilder) UseData(input bool) *EventDataFilterBuilder
type EventKind ¶
type EventKind string
EventKind defines this event as either `consumed` or `produced`
func (EventKind) KindValues ¶ added in v2.2.4
type EventRef ¶
type EventRef struct { // Reference to the unique name of a 'produced' event definition, // +kubebuilder:validation:Required TriggerEventRef string `json:"triggerEventRef" validate:"required"` // Reference to the unique name of a 'consumed' event definition // +optional ResultEventRef string `json:"resultEventRef"` // Maximum amount of time (ISO 8601 format) to wait for the result event. If not defined it be set to the // actionExecutionTimeout // +optional ResultEventTimeout string `json:"resultEventTimeout,omitempty" validate:"omitempty,iso8601duration"` // If string type, an expression which selects parts of the states data output to become the data (payload) // of the event referenced by triggerEventRef. If object type, a custom object to become the data (payload) // of the event referenced by triggerEventRef. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Data *Object `json:"data,omitempty"` // Add additional extension context attributes to the produced event. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields ContextAttributes map[string]Object `json:"contextAttributes,omitempty"` // Specifies if the function should be invoked sync or async. Default is sync. // +kubebuilder:validation:Enum=async;sync // +kubebuilder:default=sync Invoke InvokeKind `json:"invoke,omitempty" validate:"required,oneofkind"` }
EventRef defining invocation of a function via event +builder-gen:new-call=ApplyDefault
func (*EventRef) ApplyDefault ¶ added in v2.2.3
func (e *EventRef) ApplyDefault()
ApplyDefault set the default values for Event Ref
func (*EventRef) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventRef.
func (*EventRef) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventRef) UnmarshalJSON ¶ added in v2.2.0
UnmarshalJSON implements json.Unmarshaler
type EventRefBuilder ¶ added in v2.3.0
type EventRefBuilder struct {
// contains filtered or unexported fields
}
func NewEventRefBuilder ¶ added in v2.3.0
func NewEventRefBuilder() *EventRefBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventRefBuilder) Build ¶ added in v2.3.0
func (b *EventRefBuilder) Build() EventRef
func (*EventRefBuilder) ContextAttributes ¶ added in v2.3.0
func (b *EventRefBuilder) ContextAttributes(input map[string]Object) *EventRefBuilder
func (*EventRefBuilder) Data ¶ added in v2.3.0
func (b *EventRefBuilder) Data() *ObjectBuilder
func (*EventRefBuilder) Invoke ¶ added in v2.3.0
func (b *EventRefBuilder) Invoke(input InvokeKind) *EventRefBuilder
func (*EventRefBuilder) ResultEventRef ¶ added in v2.3.0
func (b *EventRefBuilder) ResultEventRef(input string) *EventRefBuilder
func (*EventRefBuilder) ResultEventTimeout ¶ added in v2.3.0
func (b *EventRefBuilder) ResultEventTimeout(input string) *EventRefBuilder
func (*EventRefBuilder) TriggerEventRef ¶ added in v2.3.0
func (b *EventRefBuilder) TriggerEventRef(input string) *EventRefBuilder
type EventState ¶
type EventState struct { // If true consuming one of the defined events causes its associated actions to be performed. If false all // the defined events must be consumed in order for actions to be performed. Defaults to true. // +kubebuilder:default=true // +optional Exclusive bool `json:"exclusive,omitempty"` // Define the events to be consumed and optional actions to be performed. // +kubebuilder:validation:MinItems=1 OnEvents []OnEvents `json:"onEvents" validate:"required,min=1,dive"` // State specific timeouts. // +optional Timeouts *EventStateTimeout `json:"timeouts,omitempty"` }
EventState await one or more events and perform actions when they are received. If defined as the workflow starting state, the event state definition controls when the workflow instances should be created. +builder-gen:new-call=ApplyDefault
func (*EventState) ApplyDefault ¶ added in v2.2.3
func (e *EventState) ApplyDefault()
ApplyDefault set the default values for Event State
func (*EventState) DeepCopy ¶ added in v2.2.0
func (in *EventState) DeepCopy() *EventState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventState.
func (*EventState) DeepCopyInto ¶ added in v2.2.0
func (in *EventState) DeepCopyInto(out *EventState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventState) MarshalJSON ¶ added in v2.2.3
func (e *EventState) MarshalJSON() ([]byte, error)
func (*EventState) UnmarshalJSON ¶
func (e *EventState) UnmarshalJSON(data []byte) error
UnmarshalJSON unmarshal EventState object from json bytes
type EventStateBuilder ¶ added in v2.3.0
type EventStateBuilder struct {
// contains filtered or unexported fields
}
func NewEventStateBuilder ¶ added in v2.3.0
func NewEventStateBuilder() *EventStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStateBuilder) AddOnEvents ¶ added in v2.3.0
func (b *EventStateBuilder) AddOnEvents() *OnEventsBuilder
func (*EventStateBuilder) Build ¶ added in v2.3.0
func (b *EventStateBuilder) Build() EventState
func (*EventStateBuilder) Exclusive ¶ added in v2.3.0
func (b *EventStateBuilder) Exclusive(input bool) *EventStateBuilder
func (*EventStateBuilder) RemoveOnEvents ¶ added in v2.3.0
func (b *EventStateBuilder) RemoveOnEvents(remove *OnEventsBuilder)
func (*EventStateBuilder) Timeouts ¶ added in v2.3.0
func (b *EventStateBuilder) Timeouts() *EventStateTimeoutBuilder
type EventStateTimeout ¶ added in v2.1.0
type EventStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Default single actions definition execution timeout (ISO 8601 duration format) // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,iso8601duration"` // Default timeout for consuming defined events (ISO 8601 duration format) // +optional EventTimeout string `json:"eventTimeout,omitempty" validate:"omitempty,iso8601duration"` }
EventStateTimeout defines timeout settings for event state
func (*EventStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *EventStateTimeout) DeepCopy() *EventStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventStateTimeout.
func (*EventStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *EventStateTimeout) DeepCopyInto(out *EventStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStateTimeoutBuilder ¶ added in v2.3.0
type EventStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewEventStateTimeoutBuilder ¶ added in v2.3.0
func NewEventStateTimeoutBuilder() *EventStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStateTimeoutBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *EventStateTimeoutBuilder) ActionExecTimeout(input string) *EventStateTimeoutBuilder
func (*EventStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *EventStateTimeoutBuilder) Build() EventStateTimeout
func (*EventStateTimeoutBuilder) EventTimeout ¶ added in v2.3.0
func (b *EventStateTimeoutBuilder) EventTimeout(input string) *EventStateTimeoutBuilder
func (*EventStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *EventStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type Events ¶ added in v2.2.3
type Events []Event
func (Events) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Events.
func (Events) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Events) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type EventsBuilder ¶ added in v2.3.0
type EventsBuilder struct {
// contains filtered or unexported fields
}
func NewEventsBuilder ¶ added in v2.3.0
func NewEventsBuilder() *EventsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventsBuilder) Build ¶ added in v2.3.0
func (b *EventsBuilder) Build() Events
type ExpressionLangType ¶ added in v2.2.3
type ExpressionLangType string
const ( //JqExpressionLang ... JqExpressionLang ExpressionLangType = "jq" // JsonPathExpressionLang ... JsonPathExpressionLang ExpressionLangType = "jsonpath" // CELExpressionLang CELExpressionLang ExpressionLangType = "cel" )
func (ExpressionLangType) KindValues ¶ added in v2.2.4
func (i ExpressionLangType) KindValues() []string
func (ExpressionLangType) String ¶ added in v2.2.4
func (i ExpressionLangType) String() string
type ForEachModeType ¶ added in v2.1.0
type ForEachModeType string
ForEachModeType Specifies how iterations are to be performed (sequentially or in parallel)
const ( // ForEachModeTypeSequential specifies iterations should be done sequentially. ForEachModeTypeSequential ForEachModeType = "sequential" // ForEachModeTypeParallel specifies iterations should be done parallel. ForEachModeTypeParallel ForEachModeType = "parallel" )
func (ForEachModeType) KindValues ¶ added in v2.2.3
func (f ForEachModeType) KindValues() []string
func (ForEachModeType) String ¶ added in v2.2.3
func (f ForEachModeType) String() string
type ForEachState ¶
type ForEachState struct { // Workflow expression selecting an array element of the states' data. // +kubebuilder:validation:Required InputCollection string `json:"inputCollection" validate:"required"` // Workflow expression specifying an array element of the states data to add the results of each iteration. // +optional OutputCollection string `json:"outputCollection,omitempty"` // Name of the iteration parameter that can be referenced in actions/workflow. For each parallel iteration, // this param should contain a unique element of the inputCollection array. // +optional IterationParam string `json:"iterationParam,omitempty"` // Specifies how many iterations may run in parallel at the same time. Used if mode property is set to // parallel (default). If not specified, its value should be the size of the inputCollection. // +optional BatchSize *intstr.IntOrString `json:"batchSize,omitempty"` // Actions to be executed for each of the elements of inputCollection. // +kubebuilder:validation:MinItems=0 Actions []Action `json:"actions,omitempty" validate:"required,min=0,dive"` // State specific timeout. // +optional Timeouts *ForEachStateTimeout `json:"timeouts,omitempty"` // Specifies how iterations are to be performed (sequential or in parallel), defaults to parallel. // +kubebuilder:validation:Enum=sequential;parallel // +kubebuilder:default=parallel Mode ForEachModeType `json:"mode,omitempty" validate:"required,oneofkind"` }
ForEachState used to execute actions for each element of a data set. +builder-gen:new-call=ApplyDefault
func (*ForEachState) ApplyDefault ¶ added in v2.2.3
func (f *ForEachState) ApplyDefault()
ApplyDefault set the default values for ForEach State
func (*ForEachState) DeepCopy ¶ added in v2.2.0
func (in *ForEachState) DeepCopy() *ForEachState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ForEachState.
func (*ForEachState) DeepCopyInto ¶ added in v2.2.0
func (in *ForEachState) DeepCopyInto(out *ForEachState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ForEachState) MarshalJSON ¶ added in v2.2.3
func (f *ForEachState) MarshalJSON() ([]byte, error)
func (*ForEachState) UnmarshalJSON ¶ added in v2.2.0
func (f *ForEachState) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type ForEachStateBuilder ¶ added in v2.3.0
type ForEachStateBuilder struct {
// contains filtered or unexported fields
}
func NewForEachStateBuilder ¶ added in v2.3.0
func NewForEachStateBuilder() *ForEachStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ForEachStateBuilder) AddActions ¶ added in v2.3.0
func (b *ForEachStateBuilder) AddActions() *ActionBuilder
func (*ForEachStateBuilder) BatchSize ¶ added in v2.3.0
func (b *ForEachStateBuilder) BatchSize(input *intstr.IntOrString) *ForEachStateBuilder
func (*ForEachStateBuilder) Build ¶ added in v2.3.0
func (b *ForEachStateBuilder) Build() ForEachState
func (*ForEachStateBuilder) InputCollection ¶ added in v2.3.0
func (b *ForEachStateBuilder) InputCollection(input string) *ForEachStateBuilder
func (*ForEachStateBuilder) IterationParam ¶ added in v2.3.0
func (b *ForEachStateBuilder) IterationParam(input string) *ForEachStateBuilder
func (*ForEachStateBuilder) Mode ¶ added in v2.3.0
func (b *ForEachStateBuilder) Mode(input ForEachModeType) *ForEachStateBuilder
func (*ForEachStateBuilder) OutputCollection ¶ added in v2.3.0
func (b *ForEachStateBuilder) OutputCollection(input string) *ForEachStateBuilder
func (*ForEachStateBuilder) RemoveActions ¶ added in v2.3.0
func (b *ForEachStateBuilder) RemoveActions(remove *ActionBuilder)
func (*ForEachStateBuilder) Timeouts ¶ added in v2.3.0
func (b *ForEachStateBuilder) Timeouts() *ForEachStateTimeoutBuilder
type ForEachStateTimeout ¶ added in v2.1.0
type ForEachStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Default single actions definition execution timeout (ISO 8601 duration format) // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,iso8601duration"` }
ForEachStateTimeout defines timeout settings for foreach state
func (*ForEachStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *ForEachStateTimeout) DeepCopy() *ForEachStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ForEachStateTimeout.
func (*ForEachStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *ForEachStateTimeout) DeepCopyInto(out *ForEachStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ForEachStateTimeoutBuilder ¶ added in v2.3.0
type ForEachStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewForEachStateTimeoutBuilder ¶ added in v2.3.0
func NewForEachStateTimeoutBuilder() *ForEachStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ForEachStateTimeoutBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *ForEachStateTimeoutBuilder) ActionExecTimeout(input string) *ForEachStateTimeoutBuilder
func (*ForEachStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *ForEachStateTimeoutBuilder) Build() ForEachStateTimeout
func (*ForEachStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *ForEachStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type Function ¶
type Function struct { Common `json:",inline"` // Unique function name // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // If type is `rest`, <path_to_openapi_definition>#<operation_id>. // If type is `rpc`, <path_to_grpc_proto_file>#<service_name>#<service_method>. // If type is `expression`, defines the workflow expression. If the type is `custom`, // <path_to_custom_script>#<custom_service_method>. // +kubebuilder:validation:Required Operation string `json:"operation" validate:"required"` // Defines the function type. Is either `custom`, `rest`, `rpc`, `expression`, `graphql`, `odata` or `asyncapi`. // Default is `rest`. // +kubebuilder:validation:Enum=rest;rpc;expression;graphql;odata;asyncapi;custom // +kubebuilder:default=rest Type FunctionType `json:"type,omitempty" validate:"required,oneofkind"` // References an auth definition name to be used to access to resource defined in the operation parameter. // +optional AuthRef string `json:"authRef,omitempty"` }
Function ... +builder-gen:new-call=ApplyDefault
func (*Function) ApplyDefault ¶ added in v2.2.4
func (f *Function) ApplyDefault()
ApplyDefault set the default values for Function
func (*Function) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Function.
func (*Function) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Function) UnmarshalJSON ¶ added in v2.2.4
UnmarshalJSON implements json unmarshaler interface
type FunctionBuilder ¶ added in v2.3.0
type FunctionBuilder struct { CommonBuilder // contains filtered or unexported fields }
func NewFunctionBuilder ¶ added in v2.3.0
func NewFunctionBuilder() *FunctionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FunctionBuilder) AuthRef ¶ added in v2.3.0
func (b *FunctionBuilder) AuthRef(input string) *FunctionBuilder
func (*FunctionBuilder) Build ¶ added in v2.3.0
func (b *FunctionBuilder) Build() Function
func (*FunctionBuilder) Common ¶ added in v2.3.0
func (b *FunctionBuilder) Common() *CommonBuilder
func (*FunctionBuilder) Name ¶ added in v2.3.0
func (b *FunctionBuilder) Name(input string) *FunctionBuilder
func (*FunctionBuilder) Operation ¶ added in v2.3.0
func (b *FunctionBuilder) Operation(input string) *FunctionBuilder
func (*FunctionBuilder) Type ¶ added in v2.3.0
func (b *FunctionBuilder) Type(input FunctionType) *FunctionBuilder
type FunctionRef ¶
type FunctionRef struct { // Name of the referenced function. // +kubebuilder:validation:Required RefName string `json:"refName" validate:"required"` // Arguments (inputs) to be passed to the referenced function // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // TODO: validate it as required if function type is graphql Arguments map[string]Object `json:"arguments,omitempty"` // Used if function type is graphql. String containing a valid GraphQL selection set. // TODO: validate it as required if function type is graphql // +optional SelectionSet string `json:"selectionSet,omitempty"` // Specifies if the function should be invoked sync or async. Default is sync. // +kubebuilder:validation:Enum=async;sync // +kubebuilder:default=sync Invoke InvokeKind `json:"invoke,omitempty" validate:"required,oneofkind"` }
FunctionRef defines the reference to a reusable function definition +builder-gen:new-call=ApplyDefault
func (*FunctionRef) ApplyDefault ¶ added in v2.2.3
func (f *FunctionRef) ApplyDefault()
ApplyDefault set the default values for Function Ref
func (*FunctionRef) DeepCopy ¶ added in v2.2.0
func (in *FunctionRef) DeepCopy() *FunctionRef
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionRef.
func (*FunctionRef) DeepCopyInto ¶ added in v2.2.0
func (in *FunctionRef) DeepCopyInto(out *FunctionRef)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FunctionRef) UnmarshalJSON ¶
func (f *FunctionRef) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type FunctionRefBuilder ¶ added in v2.3.0
type FunctionRefBuilder struct {
// contains filtered or unexported fields
}
func NewFunctionRefBuilder ¶ added in v2.3.0
func NewFunctionRefBuilder() *FunctionRefBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FunctionRefBuilder) Arguments ¶ added in v2.3.0
func (b *FunctionRefBuilder) Arguments(input map[string]Object) *FunctionRefBuilder
func (*FunctionRefBuilder) Build ¶ added in v2.3.0
func (b *FunctionRefBuilder) Build() FunctionRef
func (*FunctionRefBuilder) Invoke ¶ added in v2.3.0
func (b *FunctionRefBuilder) Invoke(input InvokeKind) *FunctionRefBuilder
func (*FunctionRefBuilder) RefName ¶ added in v2.3.0
func (b *FunctionRefBuilder) RefName(input string) *FunctionRefBuilder
func (*FunctionRefBuilder) SelectionSet ¶ added in v2.3.0
func (b *FunctionRefBuilder) SelectionSet(input string) *FunctionRefBuilder
type FunctionType ¶
type FunctionType string
FunctionType ...
const ( // FunctionTypeREST a combination of the function/service OpenAPI definition document URI and the particular service // operation that needs to be invoked, separated by a '#'. FunctionTypeREST FunctionType = "rest" // FunctionTypeRPC a combination of the gRPC proto document URI and the particular service name and service method // name that needs to be invoked, separated by a '#'. FunctionTypeRPC FunctionType = "rpc" // FunctionTypeExpression defines the expression syntax. FunctionTypeExpression FunctionType = "expression" // FunctionTypeGraphQL a combination of the GraphQL schema definition URI and the particular service name and // service method name that needs to be invoked, separated by a '#' FunctionTypeGraphQL FunctionType = "graphql" // FunctionTypeAsyncAPI a combination of the AsyncApi definition document URI and the particular service operation // that needs to be invoked, separated by a '#' FunctionTypeAsyncAPI FunctionType = "asyncapi" // FunctionTypeOData a combination of the GraphQL schema definition URI and the particular service name and service // method name that needs to be invoked, separated by a '#' FunctionTypeOData FunctionType = "odata" // FunctionTypeCustom property defines a list of function types that are set by the specification. Some runtime // implementations might support additional function types that extend the ones defined in the specification FunctionTypeCustom FunctionType = "custom" )
func (FunctionType) KindValues ¶ added in v2.2.4
func (i FunctionType) KindValues() []string
func (FunctionType) String ¶ added in v2.2.4
func (i FunctionType) String() string
type Functions ¶ added in v2.2.3
type Functions []Function
func (Functions) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Functions.
func (Functions) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Functions) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type FunctionsBuilder ¶ added in v2.3.0
type FunctionsBuilder struct {
// contains filtered or unexported fields
}
func NewFunctionsBuilder ¶ added in v2.3.0
func NewFunctionsBuilder() *FunctionsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FunctionsBuilder) Build ¶ added in v2.3.0
func (b *FunctionsBuilder) Build() Functions
type GrantType ¶ added in v2.1.0
type GrantType string
GrantType ...
func (GrantType) KindValues ¶ added in v2.2.4
type InjectState ¶
type InjectState struct { // JSON object which can be set as state's data input and can be manipulated via filter // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Data map[string]Object `json:"data" validate:"required,min=1"` // State specific timeouts // +optional Timeouts *InjectStateTimeout `json:"timeouts,omitempty"` }
InjectState used to inject static data into state data input.
func (*InjectState) DeepCopy ¶ added in v2.2.0
func (in *InjectState) DeepCopy() *InjectState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InjectState.
func (*InjectState) DeepCopyInto ¶ added in v2.2.0
func (in *InjectState) DeepCopyInto(out *InjectState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InjectState) MarshalJSON ¶ added in v2.2.3
func (i *InjectState) MarshalJSON() ([]byte, error)
type InjectStateBuilder ¶ added in v2.3.0
type InjectStateBuilder struct {
// contains filtered or unexported fields
}
func NewInjectStateBuilder ¶ added in v2.3.0
func NewInjectStateBuilder() *InjectStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InjectStateBuilder) Build ¶ added in v2.3.0
func (b *InjectStateBuilder) Build() InjectState
func (*InjectStateBuilder) Data ¶ added in v2.3.0
func (b *InjectStateBuilder) Data(input map[string]Object) *InjectStateBuilder
func (*InjectStateBuilder) Timeouts ¶ added in v2.3.0
func (b *InjectStateBuilder) Timeouts() *InjectStateTimeoutBuilder
type InjectStateTimeout ¶ added in v2.1.0
type InjectStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` }
InjectStateTimeout defines timeout settings for inject state
func (*InjectStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *InjectStateTimeout) DeepCopy() *InjectStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InjectStateTimeout.
func (*InjectStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *InjectStateTimeout) DeepCopyInto(out *InjectStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InjectStateTimeoutBuilder ¶ added in v2.3.0
type InjectStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewInjectStateTimeoutBuilder ¶ added in v2.3.0
func NewInjectStateTimeoutBuilder() *InjectStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InjectStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *InjectStateTimeoutBuilder) Build() InjectStateTimeout
func (*InjectStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *InjectStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type InvokeKind ¶ added in v2.2.0
type InvokeKind string
InvokeKind defines how the target is invoked.
const ( // InvokeKindSync meaning that worfklow execution should wait until the target completes. InvokeKindSync InvokeKind = "sync" // InvokeKindAsync meaning that workflow execution should just invoke the target and should not wait until its // completion. InvokeKindAsync InvokeKind = "async" )
func (InvokeKind) KindValues ¶ added in v2.2.3
func (i InvokeKind) KindValues() []string
func (InvokeKind) String ¶ added in v2.2.3
func (i InvokeKind) String() string
type Metadata ¶
Metadata information +kubebuilder:pruning:PreserveUnknownFields +kubebuilder:validation:Schemaless
func (Metadata) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.
func (Metadata) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetadataBuilder ¶ added in v2.3.0
type MetadataBuilder struct {
// contains filtered or unexported fields
}
func NewMetadataBuilder ¶ added in v2.3.0
func NewMetadataBuilder() *MetadataBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MetadataBuilder) Build ¶ added in v2.3.0
func (b *MetadataBuilder) Build() Metadata
type OAuth2AuthProperties ¶ added in v2.1.0
type OAuth2AuthProperties struct { Common `json:",inline"` // Expression referencing a workflow secret that contains all needed auth info. // +optional Secret string `json:"secret,omitempty"` // String or a workflow expression. Contains the authority information. // +optional Authority string `json:"authority,omitempty" validate:"omitempty,min=1"` // Defines the grant type. Can be "password", "clientCredentials", or "tokenExchange" // +kubebuilder:validation:Enum=password;clientCredentials;tokenExchange // +kubebuilder:validation:Required GrantType GrantType `json:"grantType" validate:"required,oneofkind"` // String or a workflow expression. Contains the client identifier. // +kubebuilder:validation:Required ClientID string `json:"clientId" validate:"required"` // Workflow secret or a workflow expression. Contains the client secret. // +optional ClientSecret string `json:"clientSecret,omitempty" validate:"omitempty,min=1"` // Array containing strings or workflow expressions. Contains the OAuth2 scopes. // +optional Scopes []string `json:"scopes,omitempty" validate:"omitempty,min=1"` // String or a workflow expression. Contains the username. Used only if grantType is 'resourceOwner'. // +optional Username string `json:"username,omitempty" validate:"omitempty,min=1"` // String or a workflow expression. Contains the user password. Used only if grantType is 'resourceOwner'. // +optional Password string `json:"password,omitempty" validate:"omitempty,min=1"` // Array containing strings or workflow expressions. Contains the OAuth2 audiences. // +optional Audiences []string `json:"audiences,omitempty" validate:"omitempty,min=1"` // String or a workflow expression. Contains the subject token. // +optional SubjectToken string `json:"subjectToken,omitempty" validate:"omitempty,min=1"` // String or a workflow expression. Contains the requested subject. // +optional RequestedSubject string `json:"requestedSubject,omitempty" validate:"omitempty,min=1"` // String or a workflow expression. Contains the requested issuer. // +optional RequestedIssuer string `json:"requestedIssuer,omitempty" validate:"omitempty,min=1"` }
OAuth2AuthProperties OAuth2 information
func (*OAuth2AuthProperties) DeepCopy ¶ added in v2.2.0
func (in *OAuth2AuthProperties) DeepCopy() *OAuth2AuthProperties
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OAuth2AuthProperties.
func (*OAuth2AuthProperties) DeepCopyInto ¶ added in v2.2.0
func (in *OAuth2AuthProperties) DeepCopyInto(out *OAuth2AuthProperties)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OAuth2AuthPropertiesBuilder ¶ added in v2.3.0
type OAuth2AuthPropertiesBuilder struct { CommonBuilder // contains filtered or unexported fields }
func NewOAuth2AuthPropertiesBuilder ¶ added in v2.3.0
func NewOAuth2AuthPropertiesBuilder() *OAuth2AuthPropertiesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OAuth2AuthPropertiesBuilder) Audiences ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Audiences(input []string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Authority ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Authority(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Build ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Build() OAuth2AuthProperties
func (*OAuth2AuthPropertiesBuilder) ClientID ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) ClientID(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) ClientSecret ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) ClientSecret(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Common ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Common() *CommonBuilder
func (*OAuth2AuthPropertiesBuilder) GrantType ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) GrantType(input GrantType) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Password ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Password(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) RequestedIssuer ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) RequestedIssuer(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) RequestedSubject ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) RequestedSubject(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Scopes ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Scopes(input []string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Secret ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Secret(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) SubjectToken ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) SubjectToken(input string) *OAuth2AuthPropertiesBuilder
func (*OAuth2AuthPropertiesBuilder) Username ¶ added in v2.3.0
func (b *OAuth2AuthPropertiesBuilder) Username(input string) *OAuth2AuthPropertiesBuilder
type Object ¶ added in v2.2.0
type Object struct { Type Type `json:"type,inline"` StringValue string `json:"strVal,inline"` IntValue int32 `json:"intVal,inline"` FloatValue float64 `json:"floatVal,inline"` MapValue map[string]Object `json:"mapVal,inline"` SliceValue []Object `json:"sliceVal,inline"` BoolValue bool `json:"boolValue,inline"` }
Object is used to allow integration with DeepCopy tool by replacing 'interface' generic type. The DeepCopy tool allow us to easily import the Workflow types into a Kubernetes operator, which requires the DeepCopy method.
It can marshal and unmarshal any type. This object type can be three types:
- String - holds string values
- Integer - holds int32 values, JSON marshal any number to float64 by default, during the marshaling process it is parsed to int32
+kubebuilder:pruning:PreserveUnknownFields +kubebuilder:validation:Schemaless
func FromInterface ¶ added in v2.2.5
func FromString ¶ added in v2.2.0
func (*Object) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Object.
func (*Object) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (Object) MarshalJSON ¶ added in v2.2.0
MarshalJSON marshal the given json object into the respective Object subtype.
func (*Object) UnmarshalJSON ¶ added in v2.2.0
UnmarshalJSON implements json.Unmarshaler
type ObjectBuilder ¶ added in v2.3.0
type ObjectBuilder struct {
// contains filtered or unexported fields
}
func NewObjectBuilder ¶ added in v2.3.0
func NewObjectBuilder() *ObjectBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ObjectBuilder) AddSliceValue ¶ added in v2.3.0
func (b *ObjectBuilder) AddSliceValue() *ObjectBuilder
func (*ObjectBuilder) BoolValue ¶ added in v2.3.0
func (b *ObjectBuilder) BoolValue(input bool) *ObjectBuilder
func (*ObjectBuilder) Build ¶ added in v2.3.0
func (b *ObjectBuilder) Build() Object
func (*ObjectBuilder) FloatValue ¶ added in v2.3.0
func (b *ObjectBuilder) FloatValue(input float64) *ObjectBuilder
func (*ObjectBuilder) IntValue ¶ added in v2.3.0
func (b *ObjectBuilder) IntValue(input int32) *ObjectBuilder
func (*ObjectBuilder) MapValue ¶ added in v2.3.0
func (b *ObjectBuilder) MapValue(input map[string]Object) *ObjectBuilder
func (*ObjectBuilder) RemoveSliceValue ¶ added in v2.3.0
func (b *ObjectBuilder) RemoveSliceValue(remove *ObjectBuilder)
func (*ObjectBuilder) StringValue ¶ added in v2.3.0
func (b *ObjectBuilder) StringValue(input string) *ObjectBuilder
func (*ObjectBuilder) Type ¶ added in v2.3.0
func (b *ObjectBuilder) Type(input Type) *ObjectBuilder
type OnError ¶ added in v2.1.0
type OnError struct { // ErrorRef Reference to a unique workflow error definition. Used of errorRefs is not used ErrorRef string `json:"errorRef,omitempty"` // ErrorRefs References one or more workflow error definitions. Used if errorRef is not used ErrorRefs []string `json:"errorRefs,omitempty" validate:"omitempty,unique"` // Transition to next state to handle the error. If retryRef is defined, this transition is taken only if // retries were unsuccessful. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional Transition *Transition `json:"transition,omitempty"` // End workflow execution in case of this error. If retryRef is defined, this ends workflow only if // retries were unsuccessful. // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields // +optional End *End `json:"end,omitempty"` }
OnError ...
func (*OnError) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OnError.
func (*OnError) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OnErrorBuilder ¶ added in v2.3.0
type OnErrorBuilder struct {
// contains filtered or unexported fields
}
func NewOnErrorBuilder ¶ added in v2.3.0
func NewOnErrorBuilder() *OnErrorBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OnErrorBuilder) Build ¶ added in v2.3.0
func (b *OnErrorBuilder) Build() OnError
func (*OnErrorBuilder) End ¶ added in v2.3.0
func (b *OnErrorBuilder) End() *EndBuilder
func (*OnErrorBuilder) ErrorRef ¶ added in v2.3.0
func (b *OnErrorBuilder) ErrorRef(input string) *OnErrorBuilder
func (*OnErrorBuilder) ErrorRefs ¶ added in v2.3.0
func (b *OnErrorBuilder) ErrorRefs(input []string) *OnErrorBuilder
func (*OnErrorBuilder) Transition ¶ added in v2.3.0
func (b *OnErrorBuilder) Transition() *TransitionBuilder
type OnEvents ¶
type OnEvents struct { // References one or more unique event names in the defined workflow events. // +kubebuilder:validation:MinItems=1 EventRefs []string `json:"eventRefs" validate:"required,min=1"` // Should actions be performed sequentially or in parallel. Default is sequential. // +kubebuilder:validation:Enum=sequential;parallel // +kubebuilder:default=sequential ActionMode ActionMode `json:"actionMode,omitempty" validate:"required,oneofkind"` // Actions to be performed if expression matches // +optional Actions []Action `json:"actions,omitempty" validate:"dive"` // eventDataFilter defines the callback event data filter definition // +optional EventDataFilter EventDataFilter `json:"eventDataFilter,omitempty"` }
OnEvents define which actions are be performed for the one or more events. +builder-gen:new-call=ApplyDefault
func (*OnEvents) ApplyDefault ¶ added in v2.2.3
func (o *OnEvents) ApplyDefault()
ApplyDefault set the default values for On Events
func (*OnEvents) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OnEvents.
func (*OnEvents) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OnEvents) UnmarshalJSON ¶ added in v2.2.0
UnmarshalJSON unmarshal OnEvents object from json bytes
type OnEventsBuilder ¶ added in v2.3.0
type OnEventsBuilder struct {
// contains filtered or unexported fields
}
func NewOnEventsBuilder ¶ added in v2.3.0
func NewOnEventsBuilder() *OnEventsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OnEventsBuilder) ActionMode ¶ added in v2.3.0
func (b *OnEventsBuilder) ActionMode(input ActionMode) *OnEventsBuilder
func (*OnEventsBuilder) AddActions ¶ added in v2.3.0
func (b *OnEventsBuilder) AddActions() *ActionBuilder
func (*OnEventsBuilder) Build ¶ added in v2.3.0
func (b *OnEventsBuilder) Build() OnEvents
func (*OnEventsBuilder) EventDataFilter ¶ added in v2.3.0
func (b *OnEventsBuilder) EventDataFilter() *EventDataFilterBuilder
func (*OnEventsBuilder) EventRefs ¶ added in v2.3.0
func (b *OnEventsBuilder) EventRefs(input []string) *OnEventsBuilder
func (*OnEventsBuilder) RemoveActions ¶ added in v2.3.0
func (b *OnEventsBuilder) RemoveActions(remove *ActionBuilder)
type OnParentCompleteType ¶ added in v2.2.4
type OnParentCompleteType string
CompletionType define on how to complete branch execution.
const ( OnParentCompleteTypeTerminate OnParentCompleteType = "terminate" OnParentCompleteTypeContinue OnParentCompleteType = "continue" )
func (OnParentCompleteType) KindValues ¶ added in v2.2.4
func (i OnParentCompleteType) KindValues() []string
func (OnParentCompleteType) String ¶ added in v2.2.4
func (i OnParentCompleteType) String() string
type OperationState ¶
type OperationState struct { // Specifies whether actions are performed in sequence or in parallel, defaults to sequential. // +kubebuilder:validation:Enum=sequential;parallel // +kubebuilder:default=sequential ActionMode ActionMode `json:"actionMode,omitempty" validate:"required,oneofkind"` // Actions to be performed // +kubebuilder:validation:MinItems=0 Actions []Action `json:"actions" validate:"min=0,dive"` // State specific timeouts // +optional Timeouts *OperationStateTimeout `json:"timeouts,omitempty"` }
OperationState defines a set of actions to be performed in sequence or in parallel. +builder-gen:new-call=ApplyDefault
func (*OperationState) ApplyDefault ¶ added in v2.2.3
func (o *OperationState) ApplyDefault()
ApplyDefault set the default values for Operation State
func (*OperationState) DeepCopy ¶ added in v2.2.0
func (in *OperationState) DeepCopy() *OperationState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OperationState.
func (*OperationState) DeepCopyInto ¶ added in v2.2.0
func (in *OperationState) DeepCopyInto(out *OperationState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OperationState) MarshalJSON ¶ added in v2.2.3
func (a *OperationState) MarshalJSON() ([]byte, error)
func (*OperationState) UnmarshalJSON ¶ added in v2.2.0
func (o *OperationState) UnmarshalJSON(data []byte) error
UnmarshalJSON unmarshal OperationState object from json bytes
type OperationStateBuilder ¶ added in v2.3.0
type OperationStateBuilder struct {
// contains filtered or unexported fields
}
func NewOperationStateBuilder ¶ added in v2.3.0
func NewOperationStateBuilder() *OperationStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OperationStateBuilder) ActionMode ¶ added in v2.3.0
func (b *OperationStateBuilder) ActionMode(input ActionMode) *OperationStateBuilder
func (*OperationStateBuilder) AddActions ¶ added in v2.3.0
func (b *OperationStateBuilder) AddActions() *ActionBuilder
func (*OperationStateBuilder) Build ¶ added in v2.3.0
func (b *OperationStateBuilder) Build() OperationState
func (*OperationStateBuilder) RemoveActions ¶ added in v2.3.0
func (b *OperationStateBuilder) RemoveActions(remove *ActionBuilder)
func (*OperationStateBuilder) Timeouts ¶ added in v2.3.0
func (b *OperationStateBuilder) Timeouts() *OperationStateTimeoutBuilder
type OperationStateTimeout ¶ added in v2.1.0
type OperationStateTimeout struct { // Defines workflow state execution timeout. // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Default single actions definition execution timeout (ISO 8601 duration format) // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,iso8601duration"` }
OperationStateTimeout defines the specific timeout settings for operation state
func (*OperationStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *OperationStateTimeout) DeepCopy() *OperationStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OperationStateTimeout.
func (*OperationStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *OperationStateTimeout) DeepCopyInto(out *OperationStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OperationStateTimeoutBuilder ¶ added in v2.3.0
type OperationStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewOperationStateTimeoutBuilder ¶ added in v2.3.0
func NewOperationStateTimeoutBuilder() *OperationStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OperationStateTimeoutBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *OperationStateTimeoutBuilder) ActionExecTimeout(input string) *OperationStateTimeoutBuilder
func (*OperationStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *OperationStateTimeoutBuilder) Build() OperationStateTimeout
func (*OperationStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *OperationStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type ParallelState ¶
type ParallelState struct { // List of branches for this parallel state. // +kubebuilder:validation:MinItems=1 Branches []Branch `json:"branches" validate:"required,min=1,dive"` // Option types on how to complete branch execution. Defaults to `allOf`. // +kubebuilder:validation:Enum=allOf;atLeast // +kubebuilder:default=allOf CompletionType CompletionType `json:"completionType,omitempty" validate:"required,oneofkind"` // Used when branchCompletionType is set to atLeast to specify the least number of branches that must complete // in order for the state to transition/end. // +optional // TODO: change this field to unmarshal result as int NumCompleted intstr.IntOrString `json:"numCompleted,omitempty"` // State specific timeouts // +optional Timeouts *ParallelStateTimeout `json:"timeouts,omitempty"` }
ParallelState Consists of a number of states that are executed in parallel +builder-gen:new-call=ApplyDefault
func (*ParallelState) ApplyDefault ¶ added in v2.2.3
func (ps *ParallelState) ApplyDefault()
ApplyDefault set the default values for Parallel State
func (*ParallelState) DeepCopy ¶ added in v2.2.0
func (in *ParallelState) DeepCopy() *ParallelState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParallelState.
func (*ParallelState) DeepCopyInto ¶ added in v2.2.0
func (in *ParallelState) DeepCopyInto(out *ParallelState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ParallelState) MarshalJSON ¶ added in v2.2.3
func (p *ParallelState) MarshalJSON() ([]byte, error)
func (*ParallelState) UnmarshalJSON ¶ added in v2.2.0
func (ps *ParallelState) UnmarshalJSON(data []byte) error
UnmarshalJSON unmarshal ParallelState object from json bytes
type ParallelStateBuilder ¶ added in v2.3.0
type ParallelStateBuilder struct {
// contains filtered or unexported fields
}
func NewParallelStateBuilder ¶ added in v2.3.0
func NewParallelStateBuilder() *ParallelStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ParallelStateBuilder) AddBranches ¶ added in v2.3.0
func (b *ParallelStateBuilder) AddBranches() *BranchBuilder
func (*ParallelStateBuilder) Build ¶ added in v2.3.0
func (b *ParallelStateBuilder) Build() ParallelState
func (*ParallelStateBuilder) CompletionType ¶ added in v2.3.0
func (b *ParallelStateBuilder) CompletionType(input CompletionType) *ParallelStateBuilder
func (*ParallelStateBuilder) NumCompleted ¶ added in v2.3.0
func (b *ParallelStateBuilder) NumCompleted(input intstr.IntOrString) *ParallelStateBuilder
func (*ParallelStateBuilder) RemoveBranches ¶ added in v2.3.0
func (b *ParallelStateBuilder) RemoveBranches(remove *BranchBuilder)
func (*ParallelStateBuilder) Timeouts ¶ added in v2.3.0
func (b *ParallelStateBuilder) Timeouts() *ParallelStateTimeoutBuilder
type ParallelStateTimeout ¶ added in v2.1.0
type ParallelStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Default single branch execution timeout (ISO 8601 duration format) // +optional BranchExecTimeout string `json:"branchExecTimeout,omitempty" validate:"omitempty,iso8601duration"` }
ParallelStateTimeout defines the specific timeout settings for parallel state
func (*ParallelStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *ParallelStateTimeout) DeepCopy() *ParallelStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParallelStateTimeout.
func (*ParallelStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *ParallelStateTimeout) DeepCopyInto(out *ParallelStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ParallelStateTimeoutBuilder ¶ added in v2.3.0
type ParallelStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewParallelStateTimeoutBuilder ¶ added in v2.3.0
func NewParallelStateTimeoutBuilder() *ParallelStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ParallelStateTimeoutBuilder) BranchExecTimeout ¶ added in v2.3.0
func (b *ParallelStateTimeoutBuilder) BranchExecTimeout(input string) *ParallelStateTimeoutBuilder
func (*ParallelStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *ParallelStateTimeoutBuilder) Build() ParallelStateTimeout
func (*ParallelStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *ParallelStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type ProduceEvent ¶
type ProduceEvent struct { // Reference to a defined unique event name in the events definition // +kubebuilder:validation:Required EventRef string `json:"eventRef" validate:"required"` // If String, expression which selects parts of the states data output to become the data of the produced event. // If object a custom object to become the data of produced event. // +optional // +kubebuilder:validation:Schemaless // +kubebuilder:pruning:PreserveUnknownFields Data Object `json:"data,omitempty"` // Add additional event extension context attributes. // +optional ContextAttributes map[string]string `json:"contextAttributes,omitempty"` }
ProduceEvent Defines the event (CloudEvent format) to be produced when workflow execution completes or during a workflow transitions. The eventRef property must match the name of one of the defined produced events in the events definition.
func (*ProduceEvent) DeepCopy ¶ added in v2.2.0
func (in *ProduceEvent) DeepCopy() *ProduceEvent
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProduceEvent.
func (*ProduceEvent) DeepCopyInto ¶ added in v2.2.0
func (in *ProduceEvent) DeepCopyInto(out *ProduceEvent)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProduceEventBuilder ¶ added in v2.3.0
type ProduceEventBuilder struct {
// contains filtered or unexported fields
}
func NewProduceEventBuilder ¶ added in v2.3.0
func NewProduceEventBuilder() *ProduceEventBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ProduceEventBuilder) Build ¶ added in v2.3.0
func (b *ProduceEventBuilder) Build() ProduceEvent
func (*ProduceEventBuilder) ContextAttributes ¶ added in v2.3.0
func (b *ProduceEventBuilder) ContextAttributes(input map[string]string) *ProduceEventBuilder
func (*ProduceEventBuilder) Data ¶ added in v2.3.0
func (b *ProduceEventBuilder) Data() *ObjectBuilder
func (*ProduceEventBuilder) EventRef ¶ added in v2.3.0
func (b *ProduceEventBuilder) EventRef(input string) *ProduceEventBuilder
type Retries ¶ added in v2.2.3
type Retries []Retry
func (Retries) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Retries.
func (Retries) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Retries) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type RetriesBuilder ¶ added in v2.3.0
type RetriesBuilder struct {
// contains filtered or unexported fields
}
func NewRetriesBuilder ¶ added in v2.3.0
func NewRetriesBuilder() *RetriesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RetriesBuilder) Build ¶ added in v2.3.0
func (b *RetriesBuilder) Build() Retries
type Retry ¶
type Retry struct { // Unique retry strategy name // +kubebuilder:validation:Required Name string `json:"name" validate:"required"` // Time delay between retry attempts (ISO 8601 duration format) Delay string `json:"delay,omitempty" validate:"omitempty,iso8601duration"` // Maximum time delay between retry attempts (ISO 8601 duration format) MaxDelay string `json:"maxDelay,omitempty" validate:"omitempty,iso8601duration"` // Static value by which the delay increases during each attempt (ISO 8601 time format) Increment string `json:"increment,omitempty" validate:"omitempty,iso8601duration"` // Numeric value, if specified the delay between retries is multiplied by this value. // +optional Multiplier *floatstr.Float32OrString `json:"multiplier,omitempty" validate:"omitempty,min=1"` // Maximum number of retry attempts. // +kubebuilder:validation:Required MaxAttempts intstr.IntOrString `json:"maxAttempts" validate:"required"` // If float type, maximum amount of random time added or subtracted from the delay between each retry relative to total delay (between 0 and 1). If string type, absolute maximum amount of random time added or subtracted from the delay between each retry (ISO 8601 duration format) // TODO: make iso8601duration compatible this type Jitter floatstr.Float32OrString `json:"jitter,omitempty" validate:"omitempty,min=0,max=1"` }
Retry ... +builder-gen:new-call=ApplyDefault
func (*Retry) ApplyDefault ¶ added in v2.2.4
func (r *Retry) ApplyDefault()
func (*Retry) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Retry.
func (*Retry) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Retry) UnmarshalJSON ¶ added in v2.2.4
UnmarshalJSON implements json.Unmarshaler
type RetryBuilder ¶ added in v2.3.0
type RetryBuilder struct {
// contains filtered or unexported fields
}
func NewRetryBuilder ¶ added in v2.3.0
func NewRetryBuilder() *RetryBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RetryBuilder) Build ¶ added in v2.3.0
func (b *RetryBuilder) Build() Retry
func (*RetryBuilder) Delay ¶ added in v2.3.0
func (b *RetryBuilder) Delay(input string) *RetryBuilder
func (*RetryBuilder) Increment ¶ added in v2.3.0
func (b *RetryBuilder) Increment(input string) *RetryBuilder
func (*RetryBuilder) Jitter ¶ added in v2.3.0
func (b *RetryBuilder) Jitter(input floatstr.Float32OrString) *RetryBuilder
func (*RetryBuilder) MaxAttempts ¶ added in v2.3.0
func (b *RetryBuilder) MaxAttempts(input intstr.IntOrString) *RetryBuilder
func (*RetryBuilder) MaxDelay ¶ added in v2.3.0
func (b *RetryBuilder) MaxDelay(input string) *RetryBuilder
func (*RetryBuilder) Multiplier ¶ added in v2.3.0
func (b *RetryBuilder) Multiplier(input *floatstr.Float32OrString) *RetryBuilder
func (*RetryBuilder) Name ¶ added in v2.3.0
func (b *RetryBuilder) Name(input string) *RetryBuilder
type Schedule ¶
type Schedule struct { // TODO Interval is required if Cron is not set and vice-versa, make a exclusive validation // A recurring time interval expressed in the derivative of ISO 8601 format specified below. Declares that // workflow instances should be automatically created at the start of each time interval in the series. // +optional Interval string `json:"interval,omitempty"` // Cron expression defining when workflow instances should be automatically created. // optional Cron *Cron `json:"cron,omitempty"` // Timezone name used to evaluate the interval & cron-expression. If the interval specifies a date-time // w/ timezone then proper timezone conversion will be applied. (default: UTC). // +optional Timezone string `json:"timezone,omitempty"` }
Schedule ...
func (*Schedule) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Schedule.
func (*Schedule) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Schedule) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
type ScheduleBuilder ¶ added in v2.3.0
type ScheduleBuilder struct {
// contains filtered or unexported fields
}
func NewScheduleBuilder ¶ added in v2.3.0
func NewScheduleBuilder() *ScheduleBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScheduleBuilder) Build ¶ added in v2.3.0
func (b *ScheduleBuilder) Build() Schedule
func (*ScheduleBuilder) Cron ¶ added in v2.3.0
func (b *ScheduleBuilder) Cron() *CronBuilder
func (*ScheduleBuilder) Interval ¶ added in v2.3.0
func (b *ScheduleBuilder) Interval(input string) *ScheduleBuilder
func (*ScheduleBuilder) Timezone ¶ added in v2.3.0
func (b *ScheduleBuilder) Timezone(input string) *ScheduleBuilder
type Secrets ¶ added in v2.1.0
type Secrets []string
Secrets allow you to access sensitive information, such as passwords, OAuth tokens, ssh keys, etc inside your Workflow Expressions.
func (Secrets) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Secrets.
func (Secrets) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Secrets) UnmarshalJSON ¶ added in v2.1.0
UnmarshalJSON implements json.Unmarshaler
type SecretsBuilder ¶ added in v2.3.0
type SecretsBuilder struct {
// contains filtered or unexported fields
}
func NewSecretsBuilder ¶ added in v2.3.0
func NewSecretsBuilder() *SecretsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SecretsBuilder) Build ¶ added in v2.3.0
func (b *SecretsBuilder) Build() Secrets
type Sleep ¶ added in v2.1.0
type Sleep struct { // Defines amount of time (ISO 8601 duration format) to sleep before function/subflow invocation. // Does not apply if 'eventRef' is defined. // +optional Before string `json:"before,omitempty" validate:"omitempty,iso8601duration"` // Defines amount of time (ISO 8601 duration format) to sleep after function/subflow invocation. // Does not apply if 'eventRef' is defined. // +optional After string `json:"after,omitempty" validate:"omitempty,iso8601duration"` }
Sleep defines time periods workflow execution should sleep before & after function execution
func (*Sleep) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sleep.
func (*Sleep) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Sleep) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type SleepBuilder ¶ added in v2.3.0
type SleepBuilder struct {
// contains filtered or unexported fields
}
func NewSleepBuilder ¶ added in v2.3.0
func NewSleepBuilder() *SleepBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SleepBuilder) After ¶ added in v2.3.0
func (b *SleepBuilder) After(input string) *SleepBuilder
func (*SleepBuilder) Before ¶ added in v2.3.0
func (b *SleepBuilder) Before(input string) *SleepBuilder
func (*SleepBuilder) Build ¶ added in v2.3.0
func (b *SleepBuilder) Build() Sleep
type SleepState ¶ added in v2.1.0
type SleepState struct { // Duration (ISO 8601 duration format) to sleep // +kubebuilder:validation:Required Duration string `json:"duration" validate:"required,iso8601duration"` // Timeouts State specific timeouts // +optional Timeouts *SleepStateTimeout `json:"timeouts,omitempty"` }
SleepState suspends workflow execution for a given time duration.
func (*SleepState) DeepCopy ¶ added in v2.2.0
func (in *SleepState) DeepCopy() *SleepState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SleepState.
func (*SleepState) DeepCopyInto ¶ added in v2.2.0
func (in *SleepState) DeepCopyInto(out *SleepState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SleepState) MarshalJSON ¶ added in v2.2.3
func (s *SleepState) MarshalJSON() ([]byte, error)
type SleepStateBuilder ¶ added in v2.3.0
type SleepStateBuilder struct {
// contains filtered or unexported fields
}
func NewSleepStateBuilder ¶ added in v2.3.0
func NewSleepStateBuilder() *SleepStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SleepStateBuilder) Build ¶ added in v2.3.0
func (b *SleepStateBuilder) Build() SleepState
func (*SleepStateBuilder) Duration ¶ added in v2.3.0
func (b *SleepStateBuilder) Duration(input string) *SleepStateBuilder
func (*SleepStateBuilder) Timeouts ¶ added in v2.3.0
func (b *SleepStateBuilder) Timeouts() *SleepStateTimeoutBuilder
type SleepStateTimeout ¶ added in v2.1.0
type SleepStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` }
SleepStateTimeout defines timeout settings for sleep state
func (*SleepStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *SleepStateTimeout) DeepCopy() *SleepStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SleepStateTimeout.
func (*SleepStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *SleepStateTimeout) DeepCopyInto(out *SleepStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SleepStateTimeoutBuilder ¶ added in v2.3.0
type SleepStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewSleepStateTimeoutBuilder ¶ added in v2.3.0
func NewSleepStateTimeoutBuilder() *SleepStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SleepStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *SleepStateTimeoutBuilder) Build() SleepStateTimeout
func (*SleepStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *SleepStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type Start ¶
type Start struct { // Name of the starting workflow state // +kubebuilder:validation:Required StateName string `json:"stateName" validate:"required"` // Define the recurring time intervals or cron expressions at which workflow instances should be automatically // started. // +optional Schedule *Schedule `json:"schedule,omitempty" validate:"omitempty"` }
Start definition
func (*Start) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Start.
func (*Start) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Start) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
type StartBuilder ¶ added in v2.3.0
type StartBuilder struct {
// contains filtered or unexported fields
}
func NewStartBuilder ¶ added in v2.3.0
func NewStartBuilder() *StartBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StartBuilder) Build ¶ added in v2.3.0
func (b *StartBuilder) Build() Start
func (*StartBuilder) Schedule ¶ added in v2.3.0
func (b *StartBuilder) Schedule() *ScheduleBuilder
func (*StartBuilder) StateName ¶ added in v2.3.0
func (b *StartBuilder) StateName(input string) *StartBuilder
type State ¶
type State struct { BaseState `json:",inline"` // delayState Causes the workflow execution to delay for a specified duration. // +optional *DelayState `json:"delayState,omitempty"` // event states await one or more events and perform actions when they are received. If defined as the // workflow starting state, the event state definition controls when the workflow instances should be created. // +optional *EventState `json:"eventState,omitempty"` // operationState defines a set of actions to be performed in sequence or in parallel. // +optional *OperationState `json:"operationState,omitempty"` // parallelState Consists of a number of states that are executed in parallel. // +optional *ParallelState `json:"parallelState,omitempty"` // switchState is workflow's gateways: direct transitions onf a workflow based on certain conditions. // +optional *SwitchState `json:"switchState,omitempty"` // forEachState used to execute actions for each element of a data set. // +optional *ForEachState `json:"forEachState,omitempty"` // injectState used to inject static data into state data input. // +optional *InjectState `json:"injectState,omitempty"` // callbackState executes a function and waits for callback event that indicates completion of the task. // +optional *CallbackState `json:"callbackState,omitempty"` // sleepState suspends workflow execution for a given time duration. // +optional *SleepState `json:"sleepState,omitempty"` }
+builder-gen:embedded-ignore-method=BaseState
func (*State) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new State.
func (*State) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*State) MarshalJSON ¶ added in v2.2.3
func (*State) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type StateBuilder ¶ added in v2.3.0
type StateBuilder struct { BaseStateBuilder *DelayStateBuilder *EventStateBuilder *OperationStateBuilder *ParallelStateBuilder *SwitchStateBuilder *ForEachStateBuilder *InjectStateBuilder *CallbackStateBuilder *SleepStateBuilder // contains filtered or unexported fields }
func NewStateBuilder ¶ added in v2.3.0
func NewStateBuilder() *StateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StateBuilder) ActionMode ¶ added in v2.3.0
func (b *StateBuilder) ActionMode(input ActionMode) *StateBuilder
func (*StateBuilder) Build ¶ added in v2.3.0
func (b *StateBuilder) Build() State
func (*StateBuilder) CallbackState ¶ added in v2.3.0
func (b *StateBuilder) CallbackState() *CallbackStateBuilder
func (*StateBuilder) CompensatedBy ¶ added in v2.3.0
func (b *StateBuilder) CompensatedBy(input string) *StateBuilder
func (*StateBuilder) CompletionType ¶ added in v2.3.0
func (b *StateBuilder) CompletionType(input CompletionType) *StateBuilder
func (*StateBuilder) DelayState ¶ added in v2.3.0
func (b *StateBuilder) DelayState() *DelayStateBuilder
func (*StateBuilder) Duration ¶ added in v2.3.0
func (b *StateBuilder) Duration(input string) *StateBuilder
func (*StateBuilder) EventRef ¶ added in v2.3.0
func (b *StateBuilder) EventRef(input string) *StateBuilder
func (*StateBuilder) EventState ¶ added in v2.3.0
func (b *StateBuilder) EventState() *EventStateBuilder
func (*StateBuilder) Exclusive ¶ added in v2.3.0
func (b *StateBuilder) Exclusive(input bool) *StateBuilder
func (*StateBuilder) ForEachState ¶ added in v2.3.0
func (b *StateBuilder) ForEachState() *ForEachStateBuilder
func (*StateBuilder) ID ¶ added in v2.3.0
func (b *StateBuilder) ID(input string) *StateBuilder
func (*StateBuilder) InjectState ¶ added in v2.3.0
func (b *StateBuilder) InjectState() *InjectStateBuilder
func (*StateBuilder) InputCollection ¶ added in v2.3.0
func (b *StateBuilder) InputCollection(input string) *StateBuilder
func (*StateBuilder) IterationParam ¶ added in v2.3.0
func (b *StateBuilder) IterationParam(input string) *StateBuilder
func (*StateBuilder) Mode ¶ added in v2.3.0
func (b *StateBuilder) Mode(input ForEachModeType) *StateBuilder
func (*StateBuilder) Name ¶ added in v2.3.0
func (b *StateBuilder) Name(input string) *StateBuilder
func (*StateBuilder) OperationState ¶ added in v2.3.0
func (b *StateBuilder) OperationState() *OperationStateBuilder
func (*StateBuilder) OutputCollection ¶ added in v2.3.0
func (b *StateBuilder) OutputCollection(input string) *StateBuilder
func (*StateBuilder) ParallelState ¶ added in v2.3.0
func (b *StateBuilder) ParallelState() *ParallelStateBuilder
func (*StateBuilder) SleepState ¶ added in v2.3.0
func (b *StateBuilder) SleepState() *SleepStateBuilder
func (*StateBuilder) SwitchState ¶ added in v2.3.0
func (b *StateBuilder) SwitchState() *SwitchStateBuilder
func (*StateBuilder) TimeDelay ¶ added in v2.3.0
func (b *StateBuilder) TimeDelay(input string) *StateBuilder
func (*StateBuilder) Type ¶ added in v2.3.0
func (b *StateBuilder) Type(input StateType) *StateBuilder
func (*StateBuilder) UsedForCompensation ¶ added in v2.3.0
func (b *StateBuilder) UsedForCompensation(input bool) *StateBuilder
type StateDataFilter ¶
type StateDataFilter struct { // Workflow expression to filter the state data input Input string `json:"input,omitempty"` // Workflow expression that filters the state data output Output string `json:"output,omitempty"` }
StateDataFilter ...
func (*StateDataFilter) DeepCopy ¶ added in v2.2.0
func (in *StateDataFilter) DeepCopy() *StateDataFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateDataFilter.
func (*StateDataFilter) DeepCopyInto ¶ added in v2.2.0
func (in *StateDataFilter) DeepCopyInto(out *StateDataFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StateDataFilterBuilder ¶ added in v2.3.0
type StateDataFilterBuilder struct {
// contains filtered or unexported fields
}
func NewStateDataFilterBuilder ¶ added in v2.3.0
func NewStateDataFilterBuilder() *StateDataFilterBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StateDataFilterBuilder) Build ¶ added in v2.3.0
func (b *StateDataFilterBuilder) Build() StateDataFilter
func (*StateDataFilterBuilder) Input ¶ added in v2.3.0
func (b *StateDataFilterBuilder) Input(input string) *StateDataFilterBuilder
func (*StateDataFilterBuilder) Output ¶ added in v2.3.0
func (b *StateDataFilterBuilder) Output(input string) *StateDataFilterBuilder
type StateExecTimeout ¶ added in v2.1.0
type StateExecTimeout struct { // Single state execution timeout, not including retries (ISO 8601 duration format) // +optional Single string `json:"single,omitempty" validate:"omitempty,iso8601duration"` // Total state execution timeout, including retries (ISO 8601 duration format) // +kubebuilder:validation:Required Total string `json:"total" validate:"required,iso8601duration"` }
StateExecTimeout defines workflow state execution timeout
func (*StateExecTimeout) DeepCopy ¶ added in v2.2.0
func (in *StateExecTimeout) DeepCopy() *StateExecTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateExecTimeout.
func (*StateExecTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *StateExecTimeout) DeepCopyInto(out *StateExecTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StateExecTimeout) UnmarshalJSON ¶ added in v2.1.0
func (s *StateExecTimeout) UnmarshalJSON(data []byte) error
UnmarshalJSON unmarshal StateExecTimeout object from json bytes
type StateExecTimeoutBuilder ¶ added in v2.3.0
type StateExecTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewStateExecTimeoutBuilder ¶ added in v2.3.0
func NewStateExecTimeoutBuilder() *StateExecTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StateExecTimeoutBuilder) Build ¶ added in v2.3.0
func (b *StateExecTimeoutBuilder) Build() StateExecTimeout
func (*StateExecTimeoutBuilder) Single ¶ added in v2.3.0
func (b *StateExecTimeoutBuilder) Single(input string) *StateExecTimeoutBuilder
func (*StateExecTimeoutBuilder) Total ¶ added in v2.3.0
func (b *StateExecTimeoutBuilder) Total(input string) *StateExecTimeoutBuilder
type StateType ¶
type StateType string
StateType ...
const ( // StateTypeDelay ... StateTypeDelay StateType = "delay" // StateTypeEvent ... StateTypeEvent StateType = "event" // StateTypeOperation ... StateTypeOperation StateType = "operation" // StateTypeParallel ... StateTypeParallel StateType = "parallel" // StateTypeSwitch ... StateTypeSwitch StateType = "switch" // StateTypeForEach ... StateTypeForEach StateType = "foreach" // StateTypeInject ... StateTypeInject StateType = "inject" // StateTypeCallback ... StateTypeCallback StateType = "callback" // StateTypeSleep ... StateTypeSleep StateType = "sleep" )
func (StateType) KindValues ¶ added in v2.2.3
type States ¶ added in v2.2.3
type States []State
States ... +kubebuilder:validation:MinItems=1
func (States) DeepCopy ¶ added in v2.2.3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new States.
func (States) DeepCopyInto ¶ added in v2.2.3
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*States) UnmarshalJSON ¶ added in v2.2.3
UnmarshalJSON implements json.Unmarshaler
type StatesBuilder ¶ added in v2.3.0
type StatesBuilder struct {
// contains filtered or unexported fields
}
func NewStatesBuilder ¶ added in v2.3.0
func NewStatesBuilder() *StatesBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StatesBuilder) Build ¶ added in v2.3.0
func (b *StatesBuilder) Build() States
type SwitchState ¶ added in v2.2.0
type SwitchState struct { // Default transition of the workflow if there is no matching data conditions. Can include a transition or // end definition. DefaultCondition DefaultCondition `json:"defaultCondition"` // Defines conditions evaluated against events. // +optional EventConditions EventConditions `json:"eventConditions" validate:"dive"` // Defines conditions evaluated against data // +optional DataConditions []DataCondition `json:"dataConditions" validate:"dive"` // SwitchState specific timeouts // +optional Timeouts *SwitchStateTimeout `json:"timeouts,omitempty"` }
SwitchState is workflow's gateways: direct transitions onf a workflow based on certain conditions.
func (*SwitchState) DeepCopy ¶ added in v2.2.0
func (in *SwitchState) DeepCopy() *SwitchState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SwitchState.
func (*SwitchState) DeepCopyInto ¶ added in v2.2.0
func (in *SwitchState) DeepCopyInto(out *SwitchState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SwitchState) MarshalJSON ¶ added in v2.2.3
func (s *SwitchState) MarshalJSON() ([]byte, error)
type SwitchStateBuilder ¶ added in v2.3.0
type SwitchStateBuilder struct {
// contains filtered or unexported fields
}
func NewSwitchStateBuilder ¶ added in v2.3.0
func NewSwitchStateBuilder() *SwitchStateBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SwitchStateBuilder) AddDataConditions ¶ added in v2.3.0
func (b *SwitchStateBuilder) AddDataConditions() *DataConditionBuilder
func (*SwitchStateBuilder) AddEventConditions ¶ added in v2.3.0
func (b *SwitchStateBuilder) AddEventConditions() *EventConditionBuilder
func (*SwitchStateBuilder) Build ¶ added in v2.3.0
func (b *SwitchStateBuilder) Build() SwitchState
func (*SwitchStateBuilder) DefaultCondition ¶ added in v2.3.0
func (b *SwitchStateBuilder) DefaultCondition() *DefaultConditionBuilder
func (*SwitchStateBuilder) RemoveDataConditions ¶ added in v2.3.0
func (b *SwitchStateBuilder) RemoveDataConditions(remove *DataConditionBuilder)
func (*SwitchStateBuilder) RemoveEventConditions ¶ added in v2.3.0
func (b *SwitchStateBuilder) RemoveEventConditions(remove *EventConditionBuilder)
func (*SwitchStateBuilder) Timeouts ¶ added in v2.3.0
func (b *SwitchStateBuilder) Timeouts() *SwitchStateTimeoutBuilder
type SwitchStateTimeout ¶ added in v2.2.0
type SwitchStateTimeout struct { // Default workflow state execution timeout (ISO 8601 duration format) // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // Specify the expire value to transitions to defaultCondition. When event-based conditions do not arrive. // NOTE: this is only available for EventConditions // +optional EventTimeout string `json:"eventTimeout,omitempty" validate:"omitempty,iso8601duration"` }
SwitchStateTimeout defines the specific timeout settings for switch state
func (*SwitchStateTimeout) DeepCopy ¶ added in v2.2.0
func (in *SwitchStateTimeout) DeepCopy() *SwitchStateTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SwitchStateTimeout.
func (*SwitchStateTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *SwitchStateTimeout) DeepCopyInto(out *SwitchStateTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SwitchStateTimeoutBuilder ¶ added in v2.3.0
type SwitchStateTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewSwitchStateTimeoutBuilder ¶ added in v2.3.0
func NewSwitchStateTimeoutBuilder() *SwitchStateTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SwitchStateTimeoutBuilder) Build ¶ added in v2.3.0
func (b *SwitchStateTimeoutBuilder) Build() SwitchStateTimeout
func (*SwitchStateTimeoutBuilder) EventTimeout ¶ added in v2.3.0
func (b *SwitchStateTimeoutBuilder) EventTimeout(input string) *SwitchStateTimeoutBuilder
func (*SwitchStateTimeoutBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *SwitchStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder
type Timeouts ¶ added in v2.1.0
type Timeouts struct { // WorkflowExecTimeout Workflow execution timeout duration (ISO 8601 duration format). If not specified should // be 'unlimited'. // +optional WorkflowExecTimeout *WorkflowExecTimeout `json:"workflowExecTimeout,omitempty"` // StateExecTimeout Total state execution timeout (including retries) (ISO 8601 duration format). // +optional StateExecTimeout *StateExecTimeout `json:"stateExecTimeout,omitempty"` // ActionExecTimeout Single actions definition execution timeout duration (ISO 8601 duration format). // +optional ActionExecTimeout string `json:"actionExecTimeout,omitempty" validate:"omitempty,min=1"` // BranchExecTimeout Single branch execution timeout duration (ISO 8601 duration format). // +optional BranchExecTimeout string `json:"branchExecTimeout,omitempty" validate:"omitempty,min=1"` // EventTimeout Timeout duration to wait for consuming defined events (ISO 8601 duration format). // +optional EventTimeout string `json:"eventTimeout,omitempty" validate:"omitempty,min=1"` }
Timeouts ...
func (*Timeouts) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Timeouts.
func (*Timeouts) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Timeouts) UnmarshalJSON ¶ added in v2.1.0
UnmarshalJSON implements json.Unmarshaler
type TimeoutsBuilder ¶ added in v2.3.0
type TimeoutsBuilder struct {
// contains filtered or unexported fields
}
func NewTimeoutsBuilder ¶ added in v2.3.0
func NewTimeoutsBuilder() *TimeoutsBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TimeoutsBuilder) ActionExecTimeout ¶ added in v2.3.0
func (b *TimeoutsBuilder) ActionExecTimeout(input string) *TimeoutsBuilder
func (*TimeoutsBuilder) BranchExecTimeout ¶ added in v2.3.0
func (b *TimeoutsBuilder) BranchExecTimeout(input string) *TimeoutsBuilder
func (*TimeoutsBuilder) Build ¶ added in v2.3.0
func (b *TimeoutsBuilder) Build() Timeouts
func (*TimeoutsBuilder) EventTimeout ¶ added in v2.3.0
func (b *TimeoutsBuilder) EventTimeout(input string) *TimeoutsBuilder
func (*TimeoutsBuilder) StateExecTimeout ¶ added in v2.3.0
func (b *TimeoutsBuilder) StateExecTimeout() *StateExecTimeoutBuilder
func (*TimeoutsBuilder) WorkflowExecTimeout ¶ added in v2.3.0
func (b *TimeoutsBuilder) WorkflowExecTimeout() *WorkflowExecTimeoutBuilder
type Transition ¶
type Transition struct { // Name of the state to transition to next. // +kubebuilder:validation:Required NextState string `json:"nextState" validate:"required,min=1"` // Array of producedEvent definitions. Events to be produced before the transition takes place. // +optional ProduceEvents []ProduceEvent `json:"produceEvents,omitempty" validate:"omitempty,dive"` // If set to true, triggers workflow compensation before this transition is taken. Default is false. // +kubebuilder:default=false // +optional Compensate bool `json:"compensate,omitempty"` // contains filtered or unexported fields }
Transition Serverless workflow states can have one or more incoming and outgoing transitions (from/to other states). Each state can define a transition definition that is used to determine which state to transition to next.
func (*Transition) DeepCopy ¶ added in v2.2.0
func (in *Transition) DeepCopy() *Transition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transition.
func (*Transition) DeepCopyInto ¶ added in v2.2.0
func (in *Transition) DeepCopyInto(out *Transition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Transition) UnmarshalJSON ¶
func (t *Transition) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type TransitionBuilder ¶ added in v2.3.0
type TransitionBuilder struct {
// contains filtered or unexported fields
}
func NewTransitionBuilder ¶ added in v2.3.0
func NewTransitionBuilder() *TransitionBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TransitionBuilder) AddProduceEvents ¶ added in v2.3.0
func (b *TransitionBuilder) AddProduceEvents() *ProduceEventBuilder
func (*TransitionBuilder) Build ¶ added in v2.3.0
func (b *TransitionBuilder) Build() Transition
func (*TransitionBuilder) Compensate ¶ added in v2.3.0
func (b *TransitionBuilder) Compensate(input bool) *TransitionBuilder
func (*TransitionBuilder) NextState ¶ added in v2.3.0
func (b *TransitionBuilder) NextState(input string) *TransitionBuilder
func (*TransitionBuilder) RemoveProduceEvents ¶ added in v2.3.0
func (b *TransitionBuilder) RemoveProduceEvents(remove *ProduceEventBuilder)
type ValidatorContext ¶ added in v2.2.4
type ValidatorContext struct { States map[string]State Functions map[string]Function Events map[string]Event Retries map[string]Retry Errors map[string]Error }
+builder-gen:ignore=true
func (*ValidatorContext) DeepCopy ¶ added in v2.2.4
func (in *ValidatorContext) DeepCopy() *ValidatorContext
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValidatorContext.
func (*ValidatorContext) DeepCopyInto ¶ added in v2.2.4
func (in *ValidatorContext) DeepCopyInto(out *ValidatorContext)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ValidatorContext) ExistError ¶ added in v2.2.4
func (c *ValidatorContext) ExistError(name string) bool
func (*ValidatorContext) ExistEvent ¶ added in v2.2.4
func (c *ValidatorContext) ExistEvent(name string) bool
func (*ValidatorContext) ExistFunction ¶ added in v2.2.4
func (c *ValidatorContext) ExistFunction(name string) bool
func (*ValidatorContext) ExistRetry ¶ added in v2.2.4
func (c *ValidatorContext) ExistRetry(name string) bool
func (*ValidatorContext) ExistState ¶ added in v2.2.4
func (c *ValidatorContext) ExistState(name string) bool
type Workflow ¶
type Workflow struct { BaseWorkflow `json:",inline"` // +kubebuilder:pruning:PreserveUnknownFields States States `json:"states" validate:"min=1,unique=Name,dive"` // +optional Events Events `json:"events,omitempty" validate:"unique=Name,dive"` // +optional Functions Functions `json:"functions,omitempty" validate:"unique=Name,dive"` // +optional Retries Retries `json:"retries,omitempty" validate:"unique=Name,dive"` }
Workflow base definition +builder-gen:embedded-ignore-method=BaseWorkflow
func (*Workflow) DeepCopy ¶ added in v2.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflow.
func (*Workflow) DeepCopyInto ¶ added in v2.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Workflow) UnmarshalJSON ¶
UnmarshalJSON implementation for json Unmarshal function for the Workflow type
type WorkflowBuilder ¶ added in v2.3.0
type WorkflowBuilder struct { BaseWorkflowBuilder // contains filtered or unexported fields }
func NewWorkflowBuilder ¶ added in v2.3.0
func NewWorkflowBuilder() *WorkflowBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowBuilder) AddEvents ¶ added in v2.3.0
func (b *WorkflowBuilder) AddEvents() *EventBuilder
func (*WorkflowBuilder) AddFunctions ¶ added in v2.3.0
func (b *WorkflowBuilder) AddFunctions() *FunctionBuilder
func (*WorkflowBuilder) AddRetries ¶ added in v2.3.0
func (b *WorkflowBuilder) AddRetries() *RetryBuilder
func (*WorkflowBuilder) AddStates ¶ added in v2.3.0
func (b *WorkflowBuilder) AddStates() *StateBuilder
func (*WorkflowBuilder) AutoRetries ¶ added in v2.3.0
func (b *WorkflowBuilder) AutoRetries(input bool) *WorkflowBuilder
func (*WorkflowBuilder) Build ¶ added in v2.3.0
func (b *WorkflowBuilder) Build() Workflow
func (*WorkflowBuilder) Description ¶ added in v2.3.0
func (b *WorkflowBuilder) Description(input string) *WorkflowBuilder
func (*WorkflowBuilder) ExpressionLang ¶ added in v2.3.0
func (b *WorkflowBuilder) ExpressionLang(input ExpressionLangType) *WorkflowBuilder
func (*WorkflowBuilder) ID ¶ added in v2.3.0
func (b *WorkflowBuilder) ID(input string) *WorkflowBuilder
func (*WorkflowBuilder) KeepActive ¶ added in v2.3.0
func (b *WorkflowBuilder) KeepActive(input bool) *WorkflowBuilder
func (*WorkflowBuilder) Key ¶ added in v2.3.0
func (b *WorkflowBuilder) Key(input string) *WorkflowBuilder
func (*WorkflowBuilder) Name ¶ added in v2.3.0
func (b *WorkflowBuilder) Name(input string) *WorkflowBuilder
func (*WorkflowBuilder) RemoveEvents ¶ added in v2.3.0
func (b *WorkflowBuilder) RemoveEvents(remove *EventBuilder)
func (*WorkflowBuilder) RemoveFunctions ¶ added in v2.3.0
func (b *WorkflowBuilder) RemoveFunctions(remove *FunctionBuilder)
func (*WorkflowBuilder) RemoveRetries ¶ added in v2.3.0
func (b *WorkflowBuilder) RemoveRetries(remove *RetryBuilder)
func (*WorkflowBuilder) RemoveStates ¶ added in v2.3.0
func (b *WorkflowBuilder) RemoveStates(remove *StateBuilder)
func (*WorkflowBuilder) SpecVersion ¶ added in v2.3.0
func (b *WorkflowBuilder) SpecVersion(input string) *WorkflowBuilder
func (*WorkflowBuilder) Version ¶ added in v2.3.0
func (b *WorkflowBuilder) Version(input string) *WorkflowBuilder
type WorkflowExecTimeout ¶ added in v2.1.0
type WorkflowExecTimeout struct { // Workflow execution timeout duration (ISO 8601 duration format). If not specified should be 'unlimited'. // +kubebuilder:default=unlimited Duration string `json:"duration" validate:"required,min=1,iso8601duration"` // If false, workflow instance is allowed to finish current execution. If true, current workflow execution // is stopped immediately. Default is false. // +optional Interrupt bool `json:"interrupt,omitempty"` // Name of a workflow state to be executed before workflow instance is terminated. // +optional RunBefore string `json:"runBefore,omitempty" validate:"omitempty,min=1"` }
WorkflowExecTimeout property defines the workflow execution timeout. It is defined using the ISO 8601 duration format. If not defined, the workflow execution should be given "unlimited" amount of time to complete. +builder-gen:new-call=ApplyDefault
func (*WorkflowExecTimeout) ApplyDefault ¶ added in v2.2.3
func (w *WorkflowExecTimeout) ApplyDefault()
ApplyDefault set the default values for Workflow Exec Timeout
func (*WorkflowExecTimeout) DeepCopy ¶ added in v2.2.0
func (in *WorkflowExecTimeout) DeepCopy() *WorkflowExecTimeout
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowExecTimeout.
func (*WorkflowExecTimeout) DeepCopyInto ¶ added in v2.2.0
func (in *WorkflowExecTimeout) DeepCopyInto(out *WorkflowExecTimeout)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowExecTimeout) UnmarshalJSON ¶ added in v2.1.0
func (w *WorkflowExecTimeout) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type WorkflowExecTimeoutBuilder ¶ added in v2.3.0
type WorkflowExecTimeoutBuilder struct {
// contains filtered or unexported fields
}
func NewWorkflowExecTimeoutBuilder ¶ added in v2.3.0
func NewWorkflowExecTimeoutBuilder() *WorkflowExecTimeoutBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowExecTimeoutBuilder) Build ¶ added in v2.3.0
func (b *WorkflowExecTimeoutBuilder) Build() WorkflowExecTimeout
func (*WorkflowExecTimeoutBuilder) Duration ¶ added in v2.3.0
func (b *WorkflowExecTimeoutBuilder) Duration(input string) *WorkflowExecTimeoutBuilder
func (*WorkflowExecTimeoutBuilder) Interrupt ¶ added in v2.3.0
func (b *WorkflowExecTimeoutBuilder) Interrupt(input bool) *WorkflowExecTimeoutBuilder
func (*WorkflowExecTimeoutBuilder) RunBefore ¶ added in v2.3.0
func (b *WorkflowExecTimeoutBuilder) RunBefore(input string) *WorkflowExecTimeoutBuilder
type WorkflowRef ¶ added in v2.1.0
type WorkflowRef struct { // Sub-workflow unique id // +kubebuilder:validation:Required WorkflowID string `json:"workflowId" validate:"required"` // Sub-workflow version // +optional Version string `json:"version,omitempty"` // Specifies if the subflow should be invoked sync or async. // Defaults to sync. // +kubebuilder:validation:Enum=async;sync // +kubebuilder:default=sync // +optional Invoke InvokeKind `json:"invoke,omitempty" validate:"required,oneofkind"` // onParentComplete specifies how subflow execution should behave when parent workflow completes if invoke // is 'async'. Defaults to terminate. // +kubebuilder:validation:Enum=terminate;continue // +kubebuilder:default=terminate OnParentComplete OnParentCompleteType `json:"onParentComplete,omitempty" validate:"required,oneofkind"` }
WorkflowRef holds a reference for a workflow definition +builder-gen:new-call=ApplyDefault
func (*WorkflowRef) ApplyDefault ¶ added in v2.2.3
func (s *WorkflowRef) ApplyDefault()
ApplyDefault set the default values for Workflow Ref
func (*WorkflowRef) DeepCopy ¶ added in v2.2.0
func (in *WorkflowRef) DeepCopy() *WorkflowRef
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowRef.
func (*WorkflowRef) DeepCopyInto ¶ added in v2.2.0
func (in *WorkflowRef) DeepCopyInto(out *WorkflowRef)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowRef) UnmarshalJSON ¶ added in v2.1.0
func (s *WorkflowRef) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler
type WorkflowRefBuilder ¶ added in v2.3.0
type WorkflowRefBuilder struct {
// contains filtered or unexported fields
}
func NewWorkflowRefBuilder ¶ added in v2.3.0
func NewWorkflowRefBuilder() *WorkflowRefBuilder
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowRefBuilder) Build ¶ added in v2.3.0
func (b *WorkflowRefBuilder) Build() WorkflowRef
func (*WorkflowRefBuilder) Invoke ¶ added in v2.3.0
func (b *WorkflowRefBuilder) Invoke(input InvokeKind) *WorkflowRefBuilder
func (*WorkflowRefBuilder) OnParentComplete ¶ added in v2.3.0
func (b *WorkflowRefBuilder) OnParentComplete(input OnParentCompleteType) *WorkflowRefBuilder
func (*WorkflowRefBuilder) Version ¶ added in v2.3.0
func (b *WorkflowRefBuilder) Version(input string) *WorkflowRefBuilder
func (*WorkflowRefBuilder) WorkflowID ¶ added in v2.3.0
func (b *WorkflowRefBuilder) WorkflowID(input string) *WorkflowRefBuilder
type WorkflowValidator ¶ added in v2.2.4
type WorkflowValidator func(mapValues ValidatorContext, sl validator.StructLevel)
Source Files
¶
- action.go
- action_data_filter.go
- action_validator.go
- auth.go
- callback_state.go
- common.go
- delay_state.go
- doc.go
- event.go
- event_data_filter.go
- event_state.go
- event_state_validator.go
- event_validator.go
- foreach_state.go
- foreach_state_validator.go
- function.go
- inject_state.go
- object.go
- operation_state.go
- parallel_state.go
- parallel_state_validator.go
- retry.go
- retry_validator.go
- sleep_state.go
- state_exec_timeout.go
- states.go
- states_validator.go
- switch_state.go
- switch_state_validator.go
- workflow.go
- workflow_ref.go
- workflow_validator.go
- zz_generated.buildergen.go
- zz_generated.deepcopy.go