model

package

Go to main page

Versions in this module

v2

v2.5.0

Apr 29, 2025

v2.4.3

Jan 20, 2025

v2.4.2

Nov 6, 2024

v2.4.1

Oct 11, 2024

v2.4.0

Oct 9, 2024

v2.3.0

May 22, 2024

Changes in this version

+ type ActionBuilder struct

+ func NewActionBuilder() *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 ActionDataFilterBuilder struct

+ func NewActionDataFilterBuilder() *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 AuthBuilder struct

+ func NewAuthBuilder() *AuthBuilder

+ func (b *AuthBuilder) Build() Auth

+ func (b *AuthBuilder) Name(input string) *AuthBuilder

+ func (b *AuthBuilder) Properties() *AuthPropertiesBuilder

+ func (b *AuthBuilder) Scheme(input AuthType) *AuthBuilder

+ type AuthPropertiesBuilder struct

+ func NewAuthPropertiesBuilder() *AuthPropertiesBuilder

+ func (b *AuthPropertiesBuilder) Basic() *BasicAuthPropertiesBuilder

+ func (b *AuthPropertiesBuilder) Bearer() *BearerAuthPropertiesBuilder

+ func (b *AuthPropertiesBuilder) Build() AuthProperties

+ func (b *AuthPropertiesBuilder) OAuth2() *OAuth2AuthPropertiesBuilder

+ type AuthsBuilder struct

+ func NewAuthsBuilder() *AuthsBuilder

+ func (b *AuthsBuilder) Build() Auths

+ type BaseStateBuilder struct

+ func NewBaseStateBuilder() *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

+ func (w *BaseWorkflow) ApplyDefault()

+ type BaseWorkflowBuilder struct

+ func NewBaseWorkflowBuilder() *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 BasicAuthPropertiesBuilder struct

+ func NewBasicAuthPropertiesBuilder() *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 BearerAuthPropertiesBuilder struct

+ func NewBearerAuthPropertiesBuilder() *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 BranchBuilder struct

+ func NewBranchBuilder() *BranchBuilder

+ func (b *BranchBuilder) AddActions() *ActionBuilder

+ func (b *BranchBuilder) Build() Branch

+ func (b *BranchBuilder) Name(input string) *BranchBuilder

+ func (b *BranchBuilder) RemoveActions(remove *ActionBuilder)

+ func (b *BranchBuilder) Timeouts() *BranchTimeoutsBuilder

+ type BranchTimeoutsBuilder struct

+ func NewBranchTimeoutsBuilder() *BranchTimeoutsBuilder

+ func (b *BranchTimeoutsBuilder) ActionExecTimeout(input string) *BranchTimeoutsBuilder

+ func (b *BranchTimeoutsBuilder) BranchExecTimeout(input string) *BranchTimeoutsBuilder

+ func (b *BranchTimeoutsBuilder) Build() BranchTimeouts

+ type CallbackStateBuilder struct

+ func NewCallbackStateBuilder() *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 CallbackStateTimeoutBuilder struct

+ func NewCallbackStateTimeoutBuilder() *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 CommonBuilder struct

+ func NewCommonBuilder() *CommonBuilder

+ func (b *CommonBuilder) Build() Common

+ func (b *CommonBuilder) Metadata(input Metadata) *CommonBuilder

+ type ConstantsBuilder struct

+ func NewConstantsBuilder() *ConstantsBuilder

+ func (b *ConstantsBuilder) Build() Constants

+ func (b *ConstantsBuilder) Data(input ConstantsData) *ConstantsBuilder

+ type ConstantsDataBuilder struct

+ func NewConstantsDataBuilder() *ConstantsDataBuilder

+ func (b *ConstantsDataBuilder) Build() ConstantsData

+ type ContinueAsBuilder struct

+ func NewContinueAsBuilder() *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 CorrelationBuilder struct

+ func NewCorrelationBuilder() *CorrelationBuilder

+ func (b *CorrelationBuilder) Build() Correlation

+ func (b *CorrelationBuilder) ContextAttributeName(input string) *CorrelationBuilder

+ func (b *CorrelationBuilder) ContextAttributeValue(input string) *CorrelationBuilder

+ type CronBuilder struct

+ func NewCronBuilder() *CronBuilder

+ func (b *CronBuilder) Build() Cron

+ func (b *CronBuilder) Expression(input string) *CronBuilder

+ func (b *CronBuilder) ValidUntil(input string) *CronBuilder

+ type DataConditionBuilder struct

+ func NewDataConditionBuilder() *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 DataInputSchemaBuilder struct

+ func NewDataInputSchemaBuilder() *DataInputSchemaBuilder

+ func (b *DataInputSchemaBuilder) Build() DataInputSchema

+ func (b *DataInputSchemaBuilder) FailOnValidationErrors(input bool) *DataInputSchemaBuilder

+ func (b *DataInputSchemaBuilder) Schema() *ObjectBuilder

+ type DefaultConditionBuilder struct

+ func NewDefaultConditionBuilder() *DefaultConditionBuilder

+ func (b *DefaultConditionBuilder) Build() DefaultCondition

+ func (b *DefaultConditionBuilder) End() *EndBuilder

+ func (b *DefaultConditionBuilder) Transition() *TransitionBuilder

+ type DelayStateBuilder struct

+ func NewDelayStateBuilder() *DelayStateBuilder

+ func (b *DelayStateBuilder) Build() DelayState

+ func (b *DelayStateBuilder) TimeDelay(input string) *DelayStateBuilder

+ type EndBuilder struct

+ func NewEndBuilder() *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 ErrorBuilder struct

+ func NewErrorBuilder() *ErrorBuilder

+ func (b *ErrorBuilder) Build() Error

+ func (b *ErrorBuilder) Code(input string) *ErrorBuilder

+ func (b *ErrorBuilder) Description(input string) *ErrorBuilder

+ func (b *ErrorBuilder) Name(input string) *ErrorBuilder

+ type ErrorsBuilder struct

+ func NewErrorsBuilder() *ErrorsBuilder

+ func (b *ErrorsBuilder) Build() Errors

+ type EventBuilder struct

+ func NewEventBuilder() *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 EventConditionBuilder struct

+ func NewEventConditionBuilder() *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 EventConditionsBuilder struct

+ func NewEventConditionsBuilder() *EventConditionsBuilder

+ func (b *EventConditionsBuilder) Build() EventConditions

+ type EventDataFilterBuilder struct

+ func NewEventDataFilterBuilder() *EventDataFilterBuilder

+ func (b *EventDataFilterBuilder) Build() EventDataFilter

+ func (b *EventDataFilterBuilder) Data(input string) *EventDataFilterBuilder

+ func (b *EventDataFilterBuilder) ToStateData(input string) *EventDataFilterBuilder

+ func (b *EventDataFilterBuilder) UseData(input bool) *EventDataFilterBuilder

+ type EventRefBuilder struct

+ func NewEventRefBuilder() *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 EventStateBuilder struct

+ func NewEventStateBuilder() *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 EventStateTimeoutBuilder struct

+ func NewEventStateTimeoutBuilder() *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 EventsBuilder struct

+ func NewEventsBuilder() *EventsBuilder

+ func (b *EventsBuilder) Build() Events

+ type ForEachStateBuilder struct

+ func NewForEachStateBuilder() *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 ForEachStateTimeoutBuilder struct

+ func NewForEachStateTimeoutBuilder() *ForEachStateTimeoutBuilder

+ func (b *ForEachStateTimeoutBuilder) ActionExecTimeout(input string) *ForEachStateTimeoutBuilder

+ func (b *ForEachStateTimeoutBuilder) Build() ForEachStateTimeout

+ func (b *ForEachStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type FunctionBuilder struct

+ func NewFunctionBuilder() *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 FunctionRefBuilder struct

+ func NewFunctionRefBuilder() *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 FunctionsBuilder struct

+ func NewFunctionsBuilder() *FunctionsBuilder

+ func (b *FunctionsBuilder) Build() Functions

+ type InjectStateBuilder struct

+ func NewInjectStateBuilder() *InjectStateBuilder

+ func (b *InjectStateBuilder) Build() InjectState

+ func (b *InjectStateBuilder) Data(input map[string]Object) *InjectStateBuilder

+ func (b *InjectStateBuilder) Timeouts() *InjectStateTimeoutBuilder

+ type InjectStateTimeoutBuilder struct

+ func NewInjectStateTimeoutBuilder() *InjectStateTimeoutBuilder

+ func (b *InjectStateTimeoutBuilder) Build() InjectStateTimeout

+ func (b *InjectStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type MetadataBuilder struct

+ func NewMetadataBuilder() *MetadataBuilder

+ func (b *MetadataBuilder) Build() Metadata

+ type OAuth2AuthPropertiesBuilder struct

+ func NewOAuth2AuthPropertiesBuilder() *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 ObjectBuilder struct

+ func NewObjectBuilder() *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 OnErrorBuilder struct

+ func NewOnErrorBuilder() *OnErrorBuilder

+ func (b *OnErrorBuilder) Build() OnError

+ func (b *OnErrorBuilder) End() *EndBuilder

+ func (b *OnErrorBuilder) ErrorRef(input string) *OnErrorBuilder

+ func (b *OnErrorBuilder) ErrorRefs(input []string) *OnErrorBuilder

+ func (b *OnErrorBuilder) Transition() *TransitionBuilder

+ type OnEventsBuilder struct

+ func NewOnEventsBuilder() *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 OperationStateBuilder struct

+ func NewOperationStateBuilder() *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 OperationStateTimeoutBuilder struct

+ func NewOperationStateTimeoutBuilder() *OperationStateTimeoutBuilder

+ func (b *OperationStateTimeoutBuilder) ActionExecTimeout(input string) *OperationStateTimeoutBuilder

+ func (b *OperationStateTimeoutBuilder) Build() OperationStateTimeout

+ func (b *OperationStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type ParallelStateBuilder struct

+ func NewParallelStateBuilder() *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 ParallelStateTimeoutBuilder struct

+ func NewParallelStateTimeoutBuilder() *ParallelStateTimeoutBuilder

+ func (b *ParallelStateTimeoutBuilder) BranchExecTimeout(input string) *ParallelStateTimeoutBuilder

+ func (b *ParallelStateTimeoutBuilder) Build() ParallelStateTimeout

+ func (b *ParallelStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type ProduceEventBuilder struct

+ func NewProduceEventBuilder() *ProduceEventBuilder

+ func (b *ProduceEventBuilder) Build() ProduceEvent

+ func (b *ProduceEventBuilder) ContextAttributes(input map[string]string) *ProduceEventBuilder

+ func (b *ProduceEventBuilder) Data() *ObjectBuilder

+ func (b *ProduceEventBuilder) EventRef(input string) *ProduceEventBuilder

+ type RetriesBuilder struct

+ func NewRetriesBuilder() *RetriesBuilder

+ func (b *RetriesBuilder) Build() Retries

+ type RetryBuilder struct

+ func NewRetryBuilder() *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 ScheduleBuilder struct

+ func NewScheduleBuilder() *ScheduleBuilder

+ func (b *ScheduleBuilder) Build() Schedule

+ func (b *ScheduleBuilder) Cron() *CronBuilder

+ func (b *ScheduleBuilder) Interval(input string) *ScheduleBuilder

+ func (b *ScheduleBuilder) Timezone(input string) *ScheduleBuilder

+ type SecretsBuilder struct

+ func NewSecretsBuilder() *SecretsBuilder

+ func (b *SecretsBuilder) Build() Secrets

+ type SleepBuilder struct

+ func NewSleepBuilder() *SleepBuilder

+ func (b *SleepBuilder) After(input string) *SleepBuilder

+ func (b *SleepBuilder) Before(input string) *SleepBuilder

+ func (b *SleepBuilder) Build() Sleep

+ type SleepStateBuilder struct

+ func NewSleepStateBuilder() *SleepStateBuilder

+ func (b *SleepStateBuilder) Build() SleepState

+ func (b *SleepStateBuilder) Duration(input string) *SleepStateBuilder

+ func (b *SleepStateBuilder) Timeouts() *SleepStateTimeoutBuilder

+ type SleepStateTimeoutBuilder struct

+ func NewSleepStateTimeoutBuilder() *SleepStateTimeoutBuilder

+ func (b *SleepStateTimeoutBuilder) Build() SleepStateTimeout

+ func (b *SleepStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type StartBuilder struct

+ func NewStartBuilder() *StartBuilder

+ func (b *StartBuilder) Build() Start

+ func (b *StartBuilder) Schedule() *ScheduleBuilder

+ func (b *StartBuilder) StateName(input string) *StartBuilder

+ type StateBuilder struct

+ func NewStateBuilder() *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 StateDataFilterBuilder struct

+ func NewStateDataFilterBuilder() *StateDataFilterBuilder

+ func (b *StateDataFilterBuilder) Build() StateDataFilter

+ func (b *StateDataFilterBuilder) Input(input string) *StateDataFilterBuilder

+ func (b *StateDataFilterBuilder) Output(input string) *StateDataFilterBuilder

+ type StateExecTimeoutBuilder struct

+ func NewStateExecTimeoutBuilder() *StateExecTimeoutBuilder

+ func (b *StateExecTimeoutBuilder) Build() StateExecTimeout

+ func (b *StateExecTimeoutBuilder) Single(input string) *StateExecTimeoutBuilder

+ func (b *StateExecTimeoutBuilder) Total(input string) *StateExecTimeoutBuilder

+ type StatesBuilder struct

+ func NewStatesBuilder() *StatesBuilder

+ func (b *StatesBuilder) Build() States

+ type SwitchStateBuilder struct

+ func NewSwitchStateBuilder() *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 SwitchStateTimeoutBuilder struct

+ func NewSwitchStateTimeoutBuilder() *SwitchStateTimeoutBuilder

+ func (b *SwitchStateTimeoutBuilder) Build() SwitchStateTimeout

+ func (b *SwitchStateTimeoutBuilder) EventTimeout(input string) *SwitchStateTimeoutBuilder

+ func (b *SwitchStateTimeoutBuilder) StateExecTimeout() *StateExecTimeoutBuilder

+ type TimeoutsBuilder struct

+ func NewTimeoutsBuilder() *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 TransitionBuilder struct

+ func NewTransitionBuilder() *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 WorkflowBuilder struct

+ func NewWorkflowBuilder() *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 WorkflowExecTimeoutBuilder struct

+ func NewWorkflowExecTimeoutBuilder() *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 WorkflowRefBuilder struct

+ func NewWorkflowRefBuilder() *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

v2.2.5

Oct 10, 2023

Changes in this version

+ func ToInterface(object Object) any

type ExpressionLangType

+ const CELExpressionLang

type Object

+ FloatValue float64

+ IntValue int32

+ MapValue map[string]Object

+ SliceValue []Object

+ StringValue string

+ func FromFloat(val float64) Object

+ func FromInterface(value any) Object

+ func FromMap(mapValue map[string]any) Object

+ func FromNull() Object

+ func FromSlice(sliceValue []any) Object

type Type

+ const Bool

+ const Float

+ const Int

+ const Map

+ const Null

+ const Slice

v2.2.4

Aug 25, 2023

Changes in this version

+ const ValidatorContextValue

+ func NewValidatorContext(workflow *Workflow) context.Context

+ func ValidationWrap(fnCtx WorkflowValidator) validator.StructLevelFuncCtx

type ActionMode

+ func (i ActionMode) KindValues() []string

+ func (i ActionMode) String() string

type AuthType

+ func (i AuthType) KindValues() []string

+ func (i AuthType) String() string

type CompletionType

+ func (i CompletionType) KindValues() []string

+ func (i CompletionType) String() string

+ type EventConditions []EventCondition

+ func (in EventConditions) DeepCopy() EventConditions

+ func (in EventConditions) DeepCopyInto(out *EventConditions)

type EventKind

+ func (i EventKind) KindValues() []string

+ func (i EventKind) String() string

type ExpressionLangType

+ func (i ExpressionLangType) KindValues() []string

+ func (i ExpressionLangType) String() string

type Function

+ func (f *Function) ApplyDefault()

+ func (f *Function) UnmarshalJSON(data []byte) error

type FunctionType

+ func (i FunctionType) KindValues() []string

+ func (i FunctionType) String() string

type GrantType

+ func (i GrantType) KindValues() []string

+ func (i GrantType) String() string

type Object

+ BoolValue bool

+ func FromBool(val bool) Object

+ type OnParentCompleteType string

+ const OnParentCompleteTypeContinue

+ const OnParentCompleteTypeTerminate

+ func (i OnParentCompleteType) KindValues() []string

+ func (i OnParentCompleteType) String() string

type Retry

+ func (r *Retry) ApplyDefault()

+ func (r *Retry) UnmarshalJSON(data []byte) error

type Type

+ const Boolean

+ type ValidatorContext struct

+ Errors map[string]Error

+ Events map[string]Event

+ Functions map[string]Function

+ Retries map[string]Retry

+ States map[string]State

+ 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

+ func (in *ValidatorContext) DeepCopy() *ValidatorContext

+ func (in *ValidatorContext) DeepCopyInto(out *ValidatorContext)

+ type WorkflowValidator func(mapValues ValidatorContext, sl validator.StructLevel)

v2.2.3

May 4, 2023

Changes in this version

type Action

+ func (a *Action) ApplyDefault()

type ActionDataFilter

+ func (a *ActionDataFilter) ApplyDefault()

type Auth

+ func (a *Auth) MarshalJSON() ([]byte, error)

type AuthProperties

+ Basic *BasicAuthProperties

+ Bearer *BearerAuthProperties

+ OAuth2 *OAuth2AuthProperties

+ func (in *AuthProperties) DeepCopy() *AuthProperties

+ func (in *AuthProperties) DeepCopyInto(out *AuthProperties)

+ type Auths []Auth

+ func (in Auths) DeepCopy() Auths

+ func (in Auths) DeepCopyInto(out *Auths)

+ func (r *Auths) UnmarshalJSON(data []byte) error

type BaseState

+ func (b *BaseState) MarshalJSON() ([]byte, error)

type BasicAuthProperties

+ Secret string

type BearerAuthProperties

+ Secret string

type CallbackState

+ func (c *CallbackState) MarshalJSON() ([]byte, error)

+ type ConstantsData map[string]json.RawMessage

+ func (in ConstantsData) DeepCopy() ConstantsData

+ func (in ConstantsData) DeepCopyInto(out *ConstantsData)

type DataInputSchema

+ func (d *DataInputSchema) ApplyDefault()

type DefaultCondition

+ func (e *DefaultCondition) UnmarshalJSON(data []byte) error

type DelayState

+ func (a *DelayState) MarshalJSON() ([]byte, error)

+ type Errors []Error

+ func (e *Errors) UnmarshalJSON(data []byte) error

+ func (in Errors) DeepCopy() Errors

+ func (in Errors) DeepCopyInto(out *Errors)

type Event

+ func (e *Event) ApplyDefault()

type EventDataFilter

+ func (f *EventDataFilter) ApplyDefault()

type EventRef

+ func (e *EventRef) ApplyDefault()

type EventState

+ func (e *EventState) ApplyDefault()

+ func (e *EventState) MarshalJSON() ([]byte, error)

+ type Events []Event

+ func (e *Events) UnmarshalJSON(data []byte) error

+ func (in Events) DeepCopy() Events

+ func (in Events) DeepCopyInto(out *Events)

+ type ExpressionLangType string

+ const JqExpressionLang

+ const JsonPathExpressionLang

type ForEachModeType

+ func (f ForEachModeType) KindValues() []string

+ func (f ForEachModeType) String() string

type ForEachState

+ func (f *ForEachState) ApplyDefault()

+ func (f *ForEachState) MarshalJSON() ([]byte, error)

type FunctionRef

+ func (f *FunctionRef) ApplyDefault()

+ type Functions []Function

+ func (f *Functions) UnmarshalJSON(data []byte) error

+ func (in Functions) DeepCopy() Functions

+ func (in Functions) DeepCopyInto(out *Functions)

type InjectState

+ func (i *InjectState) MarshalJSON() ([]byte, error)

type InvokeKind

+ func (i InvokeKind) KindValues() []string

+ func (i InvokeKind) String() string

+ type Kind interface

+ KindValues func() []string

+ String func() string

type OAuth2AuthProperties

+ Secret string

type Object

+ IntVal int32

+ RawValue json.RawMessage

+ StrVal string

+ Type Type

type OnEvents

+ func (o *OnEvents) ApplyDefault()

type OperationState

+ func (a *OperationState) MarshalJSON() ([]byte, error)

+ func (o *OperationState) ApplyDefault()

type ParallelState

+ func (p *ParallelState) MarshalJSON() ([]byte, error)

+ func (ps *ParallelState) ApplyDefault()

+ type Retries []Retry

+ func (in Retries) DeepCopy() Retries

+ func (in Retries) DeepCopyInto(out *Retries)

+ func (r *Retries) UnmarshalJSON(data []byte) error

type Sleep

+ func (s *Sleep) UnmarshalJSON(data []byte) error

type SleepState

+ func (s *SleepState) MarshalJSON() ([]byte, error)

type State

+ func (in *State) DeepCopy() *State

+ func (in *State) DeepCopyInto(out *State)

+ func (s *State) MarshalJSON() ([]byte, error)

+ func (s *State) UnmarshalJSON(data []byte) error

type StateType

+ func (s StateType) KindValues() []string

+ func (s StateType) String() string

+ type States []State

+ func (in States) DeepCopy() States

+ func (in States) DeepCopyInto(out *States)

+ func (s *States) UnmarshalJSON(data []byte) error

type SwitchState

+ func (s *SwitchState) MarshalJSON() ([]byte, error)

+ type Type int64

+ const Raw

+ type UnmarshalError struct

+ func (e *UnmarshalError) Error() string

type Workflow

+ func (w *Workflow) ApplyDefault()

type WorkflowExecTimeout

+ func (w *WorkflowExecTimeout) ApplyDefault()

type WorkflowRef

+ func (s *WorkflowRef) ApplyDefault()

v2.2.2

Jan 18, 2023

v2.2.1

Dec 20, 2022

v2.2.0

Dec 20, 2022

Changes in this version

+ func BaseWorkflowStructLevelValidation(structLevel validator.StructLevel)

+ func DataConditionStructLevelValidation(ctx context.Context, structLevel validator.StructLevel)

+ func DefaultConditionStructLevelValidation(ctx context.Context, structLevel validator.StructLevel)

+ func EventConditionStructLevelValidation(ctx context.Context, structLevel validator.StructLevel)

+ func ForEachStateStructLevelValidation(_ context.Context, structLevel validator.StructLevel)

+ func IncludePaths() []string

+ func ParallelStateStructLevelValidation(_ context.Context, structLevel validator.StructLevel)

+ func RetryStructLevelValidation(structLevel validator.StructLevel)

+ func SetIncludePaths(paths []string)

+ func SwitchStateStructLevelValidation(ctx context.Context, structLevel validator.StructLevel)

type Action

+ Condition string

+ ID string

+ func (a *Action) UnmarshalJSON(data []byte) error

+ func (in *Action) DeepCopy() *Action

+ func (in *Action) DeepCopyInto(out *Action)

type ActionDataFilter

+ UseResults bool

+ func (f *ActionDataFilter) UnmarshalJSON(data []byte) error

+ func (in *ActionDataFilter) DeepCopy() *ActionDataFilter

+ func (in *ActionDataFilter) DeepCopyInto(out *ActionDataFilter)

type Auth

+ func (in *Auth) DeepCopy() *Auth

+ func (in *Auth) DeepCopyInto(out *Auth)

+ type AuthArray []Auth

+ func (in AuthArray) DeepCopy() AuthArray

+ func (in AuthArray) DeepCopyInto(out *AuthArray)

+ func (r *AuthArray) UnmarshalJSON(data []byte) error

type AuthProperties

+ DeepCopyAuthProperties func() AuthProperties

type BaseAuthProperties

+ func (in *BaseAuthProperties) DeepCopy() *BaseAuthProperties

+ func (in *BaseAuthProperties) DeepCopyInto(out *BaseAuthProperties)

type BaseState

+ func (in *BaseState) DeepCopy() *BaseState

+ func (in *BaseState) DeepCopyInto(out *BaseState)

type BaseWorkflow

+ func (in *BaseWorkflow) DeepCopy() *BaseWorkflow

+ func (in *BaseWorkflow) DeepCopyInto(out *BaseWorkflow)

type BasicAuthProperties

+ func (b *BasicAuthProperties) DeepCopyAuthProperties() AuthProperties

+ func (in *BasicAuthProperties) DeepCopy() *BasicAuthProperties

+ func (in *BasicAuthProperties) DeepCopyInto(out *BasicAuthProperties)

type BearerAuthProperties

+ func (b *BearerAuthProperties) DeepCopyAuthProperties() AuthProperties

+ func (in *BearerAuthProperties) DeepCopy() *BearerAuthProperties

+ func (in *BearerAuthProperties) DeepCopyInto(out *BearerAuthProperties)

type Branch

+ func (in *Branch) DeepCopy() *Branch

+ func (in *Branch) DeepCopyInto(out *Branch)

type BranchTimeouts

+ func (in *BranchTimeouts) DeepCopy() *BranchTimeouts

+ func (in *BranchTimeouts) DeepCopyInto(out *BranchTimeouts)

type CallbackState

+ func (in *CallbackState) DeepCopy() *CallbackState

+ func (in *CallbackState) DeepCopyInto(out *CallbackState)

+ func (in *CallbackState) DeepCopyState() State

type CallbackStateTimeout

+ func (in *CallbackStateTimeout) DeepCopy() *CallbackStateTimeout

+ func (in *CallbackStateTimeout) DeepCopyInto(out *CallbackStateTimeout)

type Common

+ func (in *Common) DeepCopy() *Common

+ func (in *Common) DeepCopyInto(out *Common)

type Constants

+ func (in *Constants) DeepCopy() *Constants

+ func (in *Constants) DeepCopyInto(out *Constants)

type ContinueAs

+ Version string

+ WorkflowID string

+ func (c *ContinueAs) UnmarshalJSON(data []byte) error

+ func (in *ContinueAs) DeepCopy() *ContinueAs

+ func (in *ContinueAs) DeepCopyInto(out *ContinueAs)

type Correlation

+ func (in *Correlation) DeepCopy() *Correlation

+ func (in *Correlation) DeepCopyInto(out *Correlation)

type Cron

+ func (in *Cron) DeepCopy() *Cron

+ func (in *Cron) DeepCopyInto(out *Cron)

type DataCondition

+ Condition string

+ End *End

+ Metadata Metadata

+ Name string

+ Transition *Transition

+ func (in *DataCondition) DeepCopy() *DataCondition

+ func (in *DataCondition) DeepCopyInto(out *DataCondition)

type DataInputSchema

+ func (in *DataInputSchema) DeepCopy() *DataInputSchema

+ func (in *DataInputSchema) DeepCopyInto(out *DataInputSchema)

type DefaultCondition

+ func (in *DefaultCondition) DeepCopy() *DefaultCondition

+ func (in *DefaultCondition) DeepCopyInto(out *DefaultCondition)

type DelayState

+ func (in *DelayState) DeepCopy() *DelayState

+ func (in *DelayState) DeepCopyInto(out *DelayState)

+ func (in *DelayState) DeepCopyState() State

type End

+ func (in *End) DeepCopy() *End

+ func (in *End) DeepCopyInto(out *End)

type Error

+ func (in *Error) DeepCopy() *Error

+ func (in *Error) DeepCopyInto(out *Error)

type Event

+ func (e *Event) UnmarshalJSON(data []byte) error

+ func (in *Event) DeepCopy() *Event

+ func (in *Event) DeepCopyInto(out *Event)

type EventCondition

+ End *End

+ EventDataFilter EventDataFilter

+ EventRef string

+ Metadata Metadata

+ Name string

+ Transition *Transition

+ func (in *EventCondition) DeepCopy() *EventCondition

+ func (in *EventCondition) DeepCopyInto(out *EventCondition)

type EventDataFilter

+ UseData bool

+ func (f *EventDataFilter) UnmarshalJSON(data []byte) error

+ func (in *EventDataFilter) DeepCopy() *EventDataFilter

+ func (in *EventDataFilter) DeepCopyInto(out *EventDataFilter)

type EventRef

+ Invoke InvokeKind

+ ResultEventTimeout string

+ func (e *EventRef) UnmarshalJSON(data []byte) error

+ func (in *EventRef) DeepCopy() *EventRef

+ func (in *EventRef) DeepCopyInto(out *EventRef)

type EventState

+ Timeouts *EventStateTimeout

+ func (e *EventState) DeepCopyState() State

+ func (in *EventState) DeepCopy() *EventState

+ func (in *EventState) DeepCopyInto(out *EventState)

type EventStateTimeout

+ func (in *EventStateTimeout) DeepCopy() *EventStateTimeout

+ func (in *EventStateTimeout) DeepCopyInto(out *EventStateTimeout)

type ForEachState

+ func (f *ForEachState) DeepCopyState() State

+ func (f *ForEachState) UnmarshalJSON(data []byte) error

+ func (in *ForEachState) DeepCopy() *ForEachState

+ func (in *ForEachState) DeepCopyInto(out *ForEachState)

type ForEachStateTimeout

+ func (in *ForEachStateTimeout) DeepCopy() *ForEachStateTimeout

+ func (in *ForEachStateTimeout) DeepCopyInto(out *ForEachStateTimeout)

type Function

+ func (in *Function) DeepCopy() *Function

+ func (in *Function) DeepCopyInto(out *Function)

type FunctionRef

+ Invoke InvokeKind

+ func (in *FunctionRef) DeepCopy() *FunctionRef

+ func (in *FunctionRef) DeepCopyInto(out *FunctionRef)

type FunctionType

+ const FunctionTypeCustom

+ type IObject interface

+ DeepCopyIObject func() IObject

type InjectState

+ func (in *InjectState) DeepCopy() *InjectState

+ func (in *InjectState) DeepCopyInto(out *InjectState)

+ func (in *InjectState) DeepCopyState() State

type InjectStateTimeout

+ func (in *InjectStateTimeout) DeepCopy() *InjectStateTimeout

+ func (in *InjectStateTimeout) DeepCopyInto(out *InjectStateTimeout)

+ type Integer int

+ func (m Integer) DeepCopyIObject() IObject

+ type InvokeKind string

+ const InvokeKindAsync

+ const InvokeKindSync

type Metadata

+ func (in Metadata) DeepCopy() Metadata

+ func (in Metadata) DeepCopyInto(out *Metadata)

type OAuth2AuthProperties

+ func (b *OAuth2AuthProperties) DeepCopyAuthProperties() AuthProperties

+ func (in *OAuth2AuthProperties) DeepCopy() *OAuth2AuthProperties

+ func (in *OAuth2AuthProperties) DeepCopyInto(out *OAuth2AuthProperties)

+ type Object struct

+ func FromInt(val int) Object

+ func FromRaw(val interface{}) Object

+ func FromString(val string) Object

+ func (in *Object) DeepCopy() *Object

+ func (in *Object) DeepCopyInto(out *Object)

+ func (obj *Object) UnmarshalJSON(data []byte) error

+ func (obj Object) MarshalJSON() ([]byte, error)

type OnError

+ func (in *OnError) DeepCopy() *OnError

+ func (in *OnError) DeepCopyInto(out *OnError)

type OnEvents

+ func (in *OnEvents) DeepCopy() *OnEvents

+ func (in *OnEvents) DeepCopyInto(out *OnEvents)

+ func (o *OnEvents) UnmarshalJSON(data []byte) error

type OperationState

+ func (in *OperationState) DeepCopy() *OperationState

+ func (in *OperationState) DeepCopyInto(out *OperationState)

+ func (o *OperationState) DeepCopyState() State

+ func (o *OperationState) UnmarshalJSON(data []byte) error

type OperationStateTimeout

+ func (in *OperationStateTimeout) DeepCopy() *OperationStateTimeout

+ func (in *OperationStateTimeout) DeepCopyInto(out *OperationStateTimeout)

type ParallelState

+ func (in *ParallelState) DeepCopy() *ParallelState

+ func (in *ParallelState) DeepCopyInto(out *ParallelState)

+ func (s *ParallelState) DeepCopyState() State

+ func (s *ParallelState) UnmarshalJSON(b []byte) error

type ParallelStateTimeout

+ func (in *ParallelStateTimeout) DeepCopy() *ParallelStateTimeout

+ func (in *ParallelStateTimeout) DeepCopyInto(out *ParallelStateTimeout)

type ProduceEvent

+ func (in *ProduceEvent) DeepCopy() *ProduceEvent

+ func (in *ProduceEvent) DeepCopyInto(out *ProduceEvent)

type Retry

+ func (in *Retry) DeepCopy() *Retry

+ func (in *Retry) DeepCopyInto(out *Retry)

type Schedule

+ func (in *Schedule) DeepCopy() *Schedule

+ func (in *Schedule) DeepCopyInto(out *Schedule)

type Secrets

+ func (in Secrets) DeepCopy() Secrets

+ func (in Secrets) DeepCopyInto(out *Secrets)

type Sleep

+ func (in *Sleep) DeepCopy() *Sleep

+ func (in *Sleep) DeepCopyInto(out *Sleep)

type SleepState

+ func (in *SleepState) DeepCopy() *SleepState

+ func (in *SleepState) DeepCopyInto(out *SleepState)

+ func (in *SleepState) DeepCopyState() State

type SleepStateTimeout

+ func (in *SleepStateTimeout) DeepCopy() *SleepStateTimeout

+ func (in *SleepStateTimeout) DeepCopyInto(out *SleepStateTimeout)

type Start

+ func (in *Start) DeepCopy() *Start

+ func (in *Start) DeepCopyInto(out *Start)

type State

+ DeepCopyState func() State

type StateDataFilter

+ func (in *StateDataFilter) DeepCopy() *StateDataFilter

+ func (in *StateDataFilter) DeepCopyInto(out *StateDataFilter)

type StateExecTimeout

+ func (in *StateExecTimeout) DeepCopy() *StateExecTimeout

+ func (in *StateExecTimeout) DeepCopyInto(out *StateExecTimeout)

+ type String string

+ func (m String) DeepCopyIObject() IObject

+ type SwitchState struct

+ DataConditions []DataCondition

+ DefaultCondition DefaultCondition

+ EventConditions []EventCondition

+ Timeouts *SwitchStateTimeout

+ func (in *SwitchState) DeepCopy() *SwitchState

+ func (in *SwitchState) DeepCopyInto(out *SwitchState)

+ func (in *SwitchState) DeepCopyState() State

+ type SwitchStateTimeout struct

+ EventTimeout string

+ StateExecTimeout *StateExecTimeout

+ func (in *SwitchStateTimeout) DeepCopy() *SwitchStateTimeout

+ func (in *SwitchStateTimeout) DeepCopyInto(out *SwitchStateTimeout)

type Timeouts

+ func (in *Timeouts) DeepCopy() *Timeouts

+ func (in *Timeouts) DeepCopyInto(out *Timeouts)

type Transition

+ func (in *Transition) DeepCopy() *Transition

+ func (in *Transition) DeepCopyInto(out *Transition)

type Workflow

+ func (in *Workflow) DeepCopy() *Workflow

+ func (in *Workflow) DeepCopyInto(out *Workflow)

type WorkflowExecTimeout

+ func (in *WorkflowExecTimeout) DeepCopy() *WorkflowExecTimeout

+ func (in *WorkflowExecTimeout) DeepCopyInto(out *WorkflowExecTimeout)

type WorkflowRef

+ Invoke InvokeKind

+ OnParentComplete string

+ func (in *WorkflowRef) DeepCopy() *WorkflowRef

+ func (in *WorkflowRef) DeepCopyInto(out *WorkflowRef)

v2.1.2

Aug 29, 2022

Changes in this version

+ func AuthDefinitionsStructLevelValidation(structLevel validator.StructLevel)

+ type AuthDefinitions struct

+ Defs []Auth

+ func (a *AuthDefinitions) UnmarshalJSON(b []byte) error

v2.1.1

Mar 16, 2022

v2.1.0

Oct 1, 2021

Changes in this version

+ const CompletionTypeAllOf

+ const CompletionTypeAtLeast

+ const ForEachModeTypeParallel

+ const ForEachModeTypeSequential

+ const StateTypeSleep

+ const UnlimitedTimeout

+ var FALSE = false

+ var TRUE = true

type Action

+ NonRetryableErrors []string

+ RetryRef string

+ RetryableErrors []string

+ Sleep Sleep

+ type Auth struct

+ Name string

+ Properties AuthProperties

+ Scheme AuthType

+ func (a *Auth) UnmarshalJSON(data []byte) error

+ type AuthProperties interface

+ GetMetadata func() *Metadata

+ GetSecret func() string

+ type AuthType string

+ const AuthTypeBasic

+ const AuthTypeBearer

+ const AuthTypeOAuth2

+ type BaseAuthProperties struct

+ Secret string

+ func (b *BaseAuthProperties) GetMetadata() *Metadata

+ func (b *BaseAuthProperties) GetSecret() string

+ func (b *BaseAuthProperties) UnmarshalJSON(data []byte) error

type BaseSwitchState

+ DefaultCondition DefaultCondition

type BaseWorkflow

+ Annotations []string

+ Auth *Auth

+ AutoRetries bool

+ Constants *Constants

+ DataInputSchema *DataInputSchema

+ Errors []Error

+ Key string

+ Secrets Secrets

+ SpecVersion string

+ Timeouts *Timeouts

+ type BasicAuthProperties struct

+ Password string

+ Username string

+ func (b *BasicAuthProperties) UnmarshalJSON(data []byte) error

+ type BearerAuthProperties struct

+ Token string

+ func (b *BearerAuthProperties) UnmarshalJSON(data []byte) error

type Branch

+ Timeouts BranchTimeouts

+ type BranchTimeouts struct

+ ActionExecTimeout string

+ BranchExecTimeout string

type CallbackState

+ Timeouts CallbackStateTimeout

+ type CallbackStateTimeout struct

+ ActionExecTimeout string

+ EventTimeout string

+ StateExecTimeout StateExecTimeout

+ type Constants struct

+ Data map[string]json.RawMessage

+ func (c *Constants) UnmarshalJSON(data []byte) error

+ type ContinueAs struct

+ Data interface{}

+ WorkflowExecTimeout WorkflowExecTimeout

type DataBasedSwitchState

+ Timeouts DataBasedSwitchStateTimeout

+ type DataBasedSwitchStateTimeout struct

+ StateExecTimeout StateExecTimeout

+ type DataInputSchema struct

+ FailOnValidationErrors *bool

+ Schema string

+ func (d *DataInputSchema) UnmarshalJSON(data []byte) error

+ type DefaultCondition struct

+ End End

+ Transition Transition

type End

+ ContinueAs ContinueAs

type Error

+ Description string

+ Name string

type Event

+ DataOnly bool

type EventBasedSwitchState

+ Timeouts EventBasedSwitchStateTimeout

+ type EventBasedSwitchStateTimeout struct

+ EventTimeout string

+ StateExecTimeout StateExecTimeout

+ type EventStateTimeout struct

+ ActionExecTimeout string

+ EventTimeout string

+ StateExecTimeout StateExecTimeout

+ type ForEachModeType string

type ForEachState

+ BatchSize intstr.IntOrString

+ Mode ForEachModeType

+ Timeouts ForEachStateTimeout

+ type ForEachStateTimeout struct

+ ActionExecTimeout string

+ StateExecTimeout StateExecTimeout

type Function

+ AuthRef string

type FunctionType

+ const FunctionTypeAsyncAPI

+ const FunctionTypeOData

+ type GrantType string

+ const GrantTypeClientCredentials

+ const GrantTypePassword

+ const GrantTypeTokenExchange

type InjectState

+ Timeouts InjectStateTimeout

+ type InjectStateTimeout struct

+ StateExecTimeout StateExecTimeout

+ type OAuth2AuthProperties struct

+ Audiences []string

+ Authority string

+ ClientID string

+ ClientSecret string

+ GrantType GrantType

+ Password string

+ RequestedIssuer string

+ RequestedSubject string

+ Scopes []string

+ SubjectToken string

+ Username string

+ func (b *OAuth2AuthProperties) UnmarshalJSON(data []byte) error

+ type OnError struct

+ End End

+ ErrorRef string

+ ErrorRefs []string

+ Transition Transition

type OperationState

+ Timeouts OperationStateTimeout

+ type OperationStateTimeout struct

+ ActionExecTimeout string

+ StateExecTimeout StateExecTimeout

type ParallelState

+ NumCompleted intstr.IntOrString

+ Timeouts ParallelStateTimeout

+ type ParallelStateTimeout struct

+ BranchExecTimeout string

+ StateExecTimeout StateExecTimeout

+ type Secrets []string

+ func (s *Secrets) UnmarshalJSON(data []byte) error

+ type Sleep struct

+ After string

+ Before string

+ type SleepState struct

+ Duration string

+ Timeouts SleepStateTimeout

+ type SleepStateTimeout struct

+ StateExecTimeout StateExecTimeout

+ type StateExecTimeout struct

+ Single string

+ Total string

+ func (s *StateExecTimeout) UnmarshalJSON(data []byte) error

+ type Timeouts struct

+ ActionExecTimeout string

+ BranchExecTimeout string

+ EventTimeout string

+ StateExecTimeout *StateExecTimeout

+ WorkflowExecTimeout *WorkflowExecTimeout

+ func (t *Timeouts) UnmarshalJSON(data []byte) error

+ type WorkflowExecTimeout struct

+ Duration string

+ Interrupt bool

+ RunBefore string

+ func (w *WorkflowExecTimeout) UnmarshalJSON(data []byte) error

+ type WorkflowRef struct

+ Version string

+ WorkflowID string

+ func (s *WorkflowRef) UnmarshalJSON(data []byte) error

v2.0.1

Sep 29, 2021

Changes in this version

+ const CompletionTypeAnd

+ const CompletionTypeNOfM

+ const CompletionTypeXor

+ const StateTypeCallback

+ const StateTypeDelay

+ const StateTypeEvent

+ const StateTypeForEach

+ const StateTypeInject

+ const StateTypeOperation

+ const StateTypeParallel

+ const StateTypeSwitch

+ func EventStructLevelValidation(v *validator.Validate, structLevel *validator.StructLevel)

+ type Action struct

+ ActionDataFilter ActionDataFilter

+ EventRef EventRef

+ FunctionRef FunctionRef

+ Name string

+ SubFlowRef SubFlowRef

+ Timeout string

+ type ActionDataFilter struct

+ FromStateData string

+ Results string

+ ToStateData string

+ type ActionMode string

+ const ActionModeParallel

+ const ActionModeSequential

+ const DefaultExpressionLang

+ type BaseDataCondition struct

+ Condition string

+ Metadata Metadata

+ Name string

+ func (b *BaseDataCondition) GetCondition() string

+ func (b *BaseDataCondition) GetMetadata() Metadata

+ func (b *BaseDataCondition) GetName() string

+ type BaseEventCondition struct

+ EventDataFilter EventDataFilter

+ EventRef string

+ Metadata Metadata

+ Name string

+ func (e *BaseEventCondition) GetEventDataFilter() EventDataFilter

+ func (e *BaseEventCondition) GetEventRef() string

+ func (e *BaseEventCondition) GetMetadata() Metadata

+ func (e *BaseEventCondition) GetName() string

+ type BaseState struct

+ CompensatedBy string

+ End *End

+ ID string

+ Metadata *Metadata

+ Name string

+ OnErrors []Error

+ StateDataFilter *StateDataFilter

+ Transition *Transition

+ Type StateType

+ UsedForCompensation bool

+ func (s *BaseState) GetCompensatedBy() string

+ func (s *BaseState) GetEnd() *End

+ func (s *BaseState) GetID() string

+ func (s *BaseState) GetMetadata() *Metadata

+ func (s *BaseState) GetName() string

+ func (s *BaseState) GetOnErrors() []Error

+ func (s *BaseState) GetStateDataFilter() *StateDataFilter

+ func (s *BaseState) GetTransition() *Transition

+ func (s *BaseState) GetType() StateType

+ func (s *BaseState) GetUsedForCompensation() bool

+ type BaseSwitchState struct

+ Default DefaultDef

+ type BaseWorkflow struct

+ Description string

+ ExecTimeout *ExecTimeout

+ ExpressionLang string

+ ID string

+ KeepActive bool

+ Metadata Metadata

+ Name string

+ SchemaVersion string

+ Start *Start

+ Version string

+ type Branch struct

+ Actions []Action

+ Name string

+ type CallbackState struct

+ Action Action

+ EventDataFilter EventDataFilter

+ EventRef string

+ Timeout string

+ type Common struct

+ Metadata Metadata

+ type CompletionType string

+ type Correlation struct

+ ContextAttributeName string

+ ContextAttributeValue string

+ type Cron struct

+ Expression string

+ ValidUntil string

+ func (c *Cron) UnmarshalJSON(data []byte) error

+ type DataBasedSwitchState struct

+ DataConditions []DataCondition

+ func (j *DataBasedSwitchState) UnmarshalJSON(data []byte) error

+ type DataCondition interface

+ GetCondition func() string

+ GetMetadata func() Metadata

+ GetName func() string

+ type DefaultDef struct

+ End End

+ Transition Transition

+ type DelayState struct

+ TimeDelay string

+ type End struct

+ Compensate bool

+ ProduceEvents []ProduceEvent

+ Terminate bool

+ func (e *End) UnmarshalJSON(data []byte) error

+ type EndDataCondition struct

+ End End

+ type EndEventCondition struct

+ End End

+ type Error struct

+ Code string

+ End End

+ Error string

+ RetryRef string

+ Transition Transition

+ type Event struct

+ Correlation []Correlation

+ Kind EventKind

+ Name string

+ Source string

+ Type string

+ type EventBasedSwitchState struct

+ EventConditions []EventCondition

+ func (j *EventBasedSwitchState) UnmarshalJSON(data []byte) error

+ type EventCondition interface

+ GetEventDataFilter func() EventDataFilter

+ GetEventRef func() string

+ GetMetadata func() Metadata

+ GetName func() string

+ type EventDataFilter struct

+ Data string

+ ToStateData string

+ type EventKind string

+ const EventKindConsumed

+ const EventKindProduced

+ type EventRef struct

+ ContextAttributes map[string]interface{}

+ Data interface{}

+ ResultEventRef string

+ TriggerEventRef string

+ type EventState struct

+ Exclusive bool

+ OnEvents []OnEvents

+ Timeout string

+ func (e *EventState) UnmarshalJSON(data []byte) error

+ type ExecTimeout struct

+ Duration string

+ Interrupt bool

+ RunBefore string

+ type ForEachState struct

+ Actions []Action

+ InputCollection string

+ IterationParam string

+ Max intstr.IntOrString

+ OutputCollection string

+ type Function struct

+ Name string

+ Operation string

+ Type FunctionType

+ type FunctionRef struct

+ Arguments map[string]interface{}

+ RefName string

+ SelectionSet string

+ func (f *FunctionRef) UnmarshalJSON(data []byte) error

+ type FunctionType string

+ const FunctionTypeExpression

+ const FunctionTypeGraphQL

+ const FunctionTypeREST

+ const FunctionTypeRPC

+ type InjectState struct

+ Data map[string]interface{}

+ type Metadata map[string]interface

+ type OnEvents struct

+ ActionMode ActionMode

+ Actions []Action

+ EventDataFilter EventDataFilter

+ EventRefs []string

+ type OperationState struct

+ ActionMode ActionMode

+ Actions []Action

+ type ParallelState struct

+ Branches []Branch

+ CompletionType CompletionType

+ N intstr.IntOrString

+ type ProduceEvent struct

+ ContextAttributes map[string]interface{}

+ Data interface{}

+ EventRef string

+ type Repeat struct

+ CheckBefore bool

+ ContinueOnError bool

+ Expression string

+ Max int

+ StopOnEvents []string

+ type Retry struct

+ Delay string

+ Increment string

+ Jitter floatstr.Float32OrString

+ MaxAttempts intstr.IntOrString

+ MaxDelay string

+ Multiplier floatstr.Float32OrString

+ Name string

+ type Schedule struct

+ Cron *Cron

+ Interval string

+ Timezone string

+ func (s *Schedule) UnmarshalJSON(data []byte) error

+ type Start struct

+ Schedule *Schedule

+ StateName string

+ func (s *Start) UnmarshalJSON(data []byte) error

+ type State interface

+ GetCompensatedBy func() string

+ GetEnd func() *End

+ GetID func() string

+ GetMetadata func() *Metadata

+ GetName func() string

+ GetOnErrors func() []Error

+ GetStateDataFilter func() *StateDataFilter

+ GetTransition func() *Transition

+ GetType func() StateType

+ GetUsedForCompensation func() bool

+ type StateDataFilter struct

+ Input string

+ Output string

+ type StateType string

+ type SubFlowRef struct

+ Version string

+ WorkflowID string

+ type Transition struct

+ Compensate bool

+ NextState string

+ ProduceEvents []ProduceEvent

+ func (t *Transition) UnmarshalJSON(data []byte) error

+ type TransitionDataCondition struct

+ Transition Transition

+ type TransitionEventCondition struct

+ Transition Transition

+ type Workflow struct

+ Events []Event

+ Functions []Function

+ Retries []Retry

+ States []State

+ func (w *Workflow) UnmarshalJSON(data []byte) error

Other modules containing this package

github.com/serverlessworkflow/sdk-go

github.com/serverlessworkflow/sdk-go/v3

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