model

package

Go to main page

Versions in this module

v3

v3.2.0

Dec 2, 2025

Changes in this version

+ func ListRegisteredTaskTypes() []string

+ func RegisterTask(taskType string, constructor TaskConstructor) error

type Container

+ Arguments []string

+ Input string

+ Lifetime *ContainerLifetime

+ Name string

+ type ContainerLifetime struct

+ After *Duration

+ Cleanup string

+ type RunArguments struct

+ Value any

+ func (a *RunArguments) AsMap() map[string]interface{}

+ func (a *RunArguments) AsSlice() []string

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

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

type Script

+ Input string

+ type TaskConstructor func() Task

+ func GetTaskConstructor(taskType string) (TaskConstructor, bool)

+ type TaskRegistry struct

+ func NewTaskRegistry() *TaskRegistry

+ func (r *TaskRegistry) GetConstructor(taskType string) (TaskConstructor, bool)

+ func (r *TaskRegistry) ListRegisteredTypes() []string

+ func (r *TaskRegistry) RegisterTask(taskType string, constructor TaskConstructor) error

+ func (r *TaskRegistry) UnregisterTask(taskType string)

v3.1.2

Nov 20, 2025

v3.1.1

Oct 20, 2025

Changes in this version

type HTTPArguments

+ Redirect bool

type OpenAPIArguments

+ Redirect bool

v3.1.0

May 2, 2025

Changes in this version

+ const ErrorTypeAuthentication

+ const ErrorTypeAuthorization

+ const ErrorTypeCommunication

+ const ErrorTypeConfiguration

+ const ErrorTypeExpression

+ const ErrorTypeRuntime

+ const ErrorTypeTimeout

+ const ErrorTypeValidation

+ func ErrorToJSON(err *Error) (string, error)

+ func IsErrAuthentication(err error) bool

+ func IsErrAuthorization(err error) bool

+ func IsErrCommunication(err error) bool

+ func IsErrConfiguration(err error) bool

+ func IsErrExpression(err error) bool

+ func IsErrRuntime(err error) bool

+ func IsErrTimeout(err error) bool

+ func IsErrValidation(err error) bool

+ func IsStrictExpr(expression string) bool

+ func IsValidExpr(expression string) bool

+ func NormalizeExpr(expr string) string

+ func SanitizeExpr(expression string) string

type CallAsyncAPI

+ func (c *CallAsyncAPI) GetBase() *TaskBase

type CallFunction

+ func (c *CallFunction) GetBase() *TaskBase

type CallGRPC

+ func (c *CallGRPC) GetBase() *TaskBase

type CallHTTP

+ func (c *CallHTTP) GetBase() *TaskBase

type CallOpenAPI

+ func (c *CallOpenAPI) GetBase() *TaskBase

type DoTask

+ func (d *DoTask) GetBase() *TaskBase

type EmitTask

+ func (e *EmitTask) GetBase() *TaskBase

type EndpointConfiguration

+ RuntimeExpression *RuntimeExpression

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

type Error

+ func AsError(err error) *Error

+ func ErrorFromJSON(jsonStr string) (*Error, error)

+ func NewErrAuthentication(detail error, instance string) *Error

+ func NewErrAuthorization(detail error, instance string) *Error

+ func NewErrCommunication(detail error, instance string) *Error

+ func NewErrConfiguration(detail error, instance string) *Error

+ func NewErrExpression(detail error, instance string) *Error

+ func NewErrRuntime(detail error, instance string) *Error

+ func NewErrTimeout(detail error, instance string) *Error

+ func NewErrValidation(detail error, instance string) *Error

+ func (e *Error) Error() string

+ func (e *Error) WithInstanceRef(workflow *Workflow, taskName string) *Error

type FlowDirective

+ func (f *FlowDirective) IsTermination() bool

type ForTask

+ func (f *ForTask) GetBase() *TaskBase

type ForkTask

+ func (f *ForkTask) GetBase() *TaskBase

type JsonPointerOrRuntimeExpression

+ func (j *JsonPointerOrRuntimeExpression) GetValue() interface{}

+ func (j *JsonPointerOrRuntimeExpression) IsValid() bool

+ func (j *JsonPointerOrRuntimeExpression) String() string

type ListenTask

+ func (lt *ListenTask) GetBase() *TaskBase

type LiteralUri

+ func (u *LiteralUri) GetValue() interface{}

type LiteralUriTemplate

+ func (t *LiteralUriTemplate) GetValue() interface{}

+ type Object interface

+ GetValue func() interface{}

+ String func() string

type ObjectOrRuntimeExpr

+ func NewObjectOrRuntimeExpr(value interface{}) *ObjectOrRuntimeExpr

+ func (o *ObjectOrRuntimeExpr) AsStringOrMap() interface{}

+ func (o *ObjectOrRuntimeExpr) GetValue() interface{}

+ func (o *ObjectOrRuntimeExpr) String() string

type ObjectOrString

+ func (o *ObjectOrString) GetValue() interface{}

+ func (o *ObjectOrString) String() string

type RaiseTask

+ func (r *RaiseTask) GetBase() *TaskBase

type RunTask

+ func (r *RunTask) GetBase() *TaskBase

type RuntimeExpression

+ func (r *RuntimeExpression) GetValue() interface{}

type SetTask

+ func (st *SetTask) GetBase() *TaskBase

type StringOrRuntimeExpr

+ func NewStringOrRuntimeExpr(value string) *StringOrRuntimeExpr

+ func (s *StringOrRuntimeExpr) AsObjectOrRuntimeExpr() *ObjectOrRuntimeExpr

+ func (s *StringOrRuntimeExpr) GetValue() interface{}

type SwitchTask

+ func (st *SwitchTask) GetBase() *TaskBase

type Task

+ GetBase func() *TaskBase

type TaskItem

+ func (ti *TaskItem) GetBase() *TaskBase

type TaskList

+ func (tl *TaskList) KeyAndIndex(key string) (int, *TaskItem)

+ func (tl *TaskList) Next(currentIdx int) (int, *TaskItem)

type TryTask

+ func (t *TryTask) GetBase() *TaskBase

type URITemplate

+ GetValue func() interface{}

type URITemplateOrRuntimeExpr

+ func (u *URITemplateOrRuntimeExpr) GetValue() interface{}

type WaitTask

+ func (wt *WaitTask) GetBase() *TaskBase

type Workflow

+ func (w *Workflow) AsMap() (map[string]interface{}, error)

v3.0.0

Jan 22, 2025

Changes in this version

+ const DefaultSchema

+ const OAuth2DefaultIntrospectionURI

+ const OAuth2DefaultRevokeURI

+ const OAuth2DefaultTokenURI

+ var JSONPointerPattern = regexp.MustCompile(`^(/([^/~]|~[01])*)*$`)

+ var LiteralUriPattern = regexp.MustCompile(`^[A-Za-z][A-Za-z0-9+\-.]*://[^{}\s]+$`)

+ var LiteralUriTemplatePattern = regexp.MustCompile(`^[A-Za-z][A-Za-z0-9+\-.]*://.*\{.*}.*$`)

+ var NewRuntimeExpression = NewExpr

+ func GetValidator() *validator.Validate

+ func ResolveRetryPolicies(tasks []TryTaskCatch, retries map[string]*RetryPolicy) error

+ type AsyncAPIArguments struct

+ Authentication *ReferenceableAuthenticationPolicy

+ Channel string

+ Document *ExternalResource

+ Message *AsyncAPIOutboundMessage

+ Operation string

+ Protocol string

+ Server *AsyncAPIServer

+ Subscription *AsyncAPISubscription

+ type AsyncAPIMessageConsumptionPolicy struct

+ Amount int

+ For *Duration

+ Until *RuntimeExpression

+ While *RuntimeExpression

+ type AsyncAPIOutboundMessage struct

+ Headers map[string]interface{}

+ Payload map[string]interface{}

+ type AsyncAPIServer struct

+ Name string

+ Variables map[string]interface{}

+ type AsyncAPISubscription struct

+ Consume *AsyncAPIMessageConsumptionPolicy

+ Filter *RuntimeExpression

+ type AuthenticationPolicy struct

+ Basic *BasicAuthenticationPolicy

+ Bearer *BearerAuthenticationPolicy

+ Digest *DigestAuthenticationPolicy

+ OAuth2 *OAuth2AuthenticationPolicy

+ OIDC *OpenIdConnectAuthenticationPolicy

+ func NewBasicAuth(username, password string) *AuthenticationPolicy

+ func (ap *AuthenticationPolicy) MarshalJSON() ([]byte, error)

+ func (ap *AuthenticationPolicy) UnmarshalJSON(data []byte) error

+ type BackoffDefinition struct

+ Definition map[string]interface{}

+ type BasicAuthenticationPolicy struct

+ Password string

+ Use string

+ Username string

+ type BearerAuthenticationPolicy struct

+ Token string

+ Use string

+ type CallAsyncAPI struct

+ Call string

+ With AsyncAPIArguments

+ type CallFunction struct

+ Call string

+ With map[string]interface{}

+ type CallGRPC struct

+ Call string

+ With GRPCArguments

+ type CallHTTP struct

+ Call string

+ With HTTPArguments

+ type CallOpenAPI struct

+ Call string

+ With OpenAPIArguments

+ type Catalog struct

+ Endpoint *Endpoint

+ type Container struct

+ Command string

+ Environment map[string]string

+ Image string

+ Ports map[string]interface{}

+ Volumes map[string]interface{}

+ type Correlation struct

+ Expect string

+ From string

+ type DigestAuthenticationPolicy struct

+ Password string

+ Use string

+ Username string

+ type DoTask struct

+ Do *TaskList

+ type Document struct

+ DSL string

+ Metadata map[string]interface{}

+ Name string

+ Namespace string

+ Summary string

+ Tags map[string]string

+ Title string

+ Version string

+ type Duration struct

+ Value interface{}

+ func NewDurationExpr(durationExpression string) *Duration

+ func (d *Duration) AsExpression() string

+ func (d *Duration) AsInline() *DurationInline

+ func (d *Duration) MarshalJSON() ([]byte, error)

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

+ type DurationExpression struct

+ Expression string

+ func (d *DurationExpression) MarshalJSON() ([]byte, error)

+ func (d *DurationExpression) String() string

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

+ type DurationInline struct

+ Days int32

+ Hours int32

+ Milliseconds int32

+ Minutes int32

+ Seconds int32

+ func (d *DurationInline) MarshalJSON() ([]byte, error)

+ type EmitEventDefinition struct

+ With *EventProperties

+ type EmitTask struct

+ Emit EmitTaskConfiguration

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

+ type EmitTaskConfiguration struct

+ Event EmitEventDefinition

+ type Endpoint struct

+ EndpointConfig *EndpointConfiguration

+ RuntimeExpression *RuntimeExpression

+ URITemplate URITemplate

+ func NewEndpoint(uri string) *Endpoint

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

+ func (e *Endpoint) String() string

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

+ type EndpointConfiguration struct

+ Authentication *ReferenceableAuthenticationPolicy

+ URI URITemplate

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

+ type Error struct

+ Detail string

+ Instance *JsonPointerOrRuntimeExpression

+ Status int

+ Title string

+ Type *URITemplateOrRuntimeExpr

+ type ErrorFilter struct

+ Details string

+ Instance string

+ Status int

+ Title string

+ Type string

+ type EventConsumptionStrategy struct

+ All []*EventFilter

+ Any []*EventFilter

+ One *EventFilter

+ Until *EventConsumptionUntil

+ func (ecs *EventConsumptionStrategy) MarshalJSON() ([]byte, error)

+ func (ecs *EventConsumptionStrategy) UnmarshalJSON(data []byte) error

+ type EventConsumptionUntil struct

+ Condition *RuntimeExpression

+ IsDisabled bool

+ Strategy *EventConsumptionStrategy

+ func (ecu *EventConsumptionUntil) MarshalJSON() ([]byte, error)

+ func (ecu *EventConsumptionUntil) UnmarshalJSON(data []byte) error

+ type EventFilter struct

+ Correlate map[string]Correlation

+ With *EventProperties

+ type EventProperties struct

+ Additional map[string]interface{}

+ DataContentType string

+ DataSchema *URITemplateOrRuntimeExpr

+ ID string

+ Source *URITemplateOrRuntimeExpr

+ Subject string

+ Time *StringOrRuntimeExpr

+ Type string

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

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

+ type Export struct

+ As *ObjectOrRuntimeExpr

+ Schema *Schema

+ type Extension struct

+ After *TaskList

+ Before *TaskList

+ Extend string

+ When *RuntimeExpression

+ type ExtensionItem struct

+ Extension *Extension

+ Key string

+ func (ei *ExtensionItem) MarshalJSON() ([]byte, error)

+ func (ei *ExtensionItem) UnmarshalJSON(data []byte) error

+ type ExtensionList []*ExtensionItem

+ func (el *ExtensionList) Key(key string) *Extension

+ func (el *ExtensionList) MarshalJSON() ([]byte, error)

+ func (el *ExtensionList) UnmarshalJSON(data []byte) error

+ type ExternalResource struct

+ Endpoint *Endpoint

+ Name string

+ type FlowDirective struct

+ Value string

+ func (f *FlowDirective) IsEnum() bool

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

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

+ type FlowDirectiveType string

+ const FlowDirectiveContinue

+ const FlowDirectiveEnd

+ const FlowDirectiveExit

+ type ForTask struct

+ Do *TaskList

+ For ForTaskConfiguration

+ While string

+ type ForTaskConfiguration struct

+ At string

+ Each string

+ In string

+ type ForkTask struct

+ Fork ForkTaskConfiguration

+ type ForkTaskConfiguration struct

+ Branches *TaskList

+ Compete bool

+ type GRPCArguments struct

+ Arguments map[string]interface{}

+ Authentication *ReferenceableAuthenticationPolicy

+ Method string

+ Proto *ExternalResource

+ Service GRPCService

+ type GRPCService struct

+ Authentication *ReferenceableAuthenticationPolicy

+ Host string

+ Name string

+ Port int

+ type HTTPArguments struct

+ Body json.RawMessage

+ Endpoint *Endpoint

+ Headers map[string]string

+ Method string

+ Output string

+ Query map[string]interface{}

+ type Input struct

+ From *ObjectOrRuntimeExpr

+ Schema *Schema

+ type JsonPointerOrRuntimeExpression struct

+ Value interface{}

+ func (j *JsonPointerOrRuntimeExpression) MarshalJSON() ([]byte, error)

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

+ type ListenTask struct

+ Listen ListenTaskConfiguration

+ func (lt *ListenTask) MarshalJSON() ([]byte, error)

+ func (lt *ListenTask) UnmarshalJSON(data []byte) error

+ type ListenTaskConfiguration struct

+ To *EventConsumptionStrategy

+ type LiteralUri struct

+ Value string

+ func (u *LiteralUri) IsURITemplate() bool

+ func (u *LiteralUri) MarshalJSON() ([]byte, error)

+ func (u *LiteralUri) String() string

+ type LiteralUriTemplate struct

+ Value string

+ func (t *LiteralUriTemplate) IsURITemplate() bool

+ func (t *LiteralUriTemplate) MarshalJSON() ([]byte, error)

+ func (t *LiteralUriTemplate) String() string

+ type NamedTaskMap map[string]Task

+ func (ntm *NamedTaskMap) UnmarshalJSON(data []byte) error

+ type OAuth2AutenthicationDataClient struct

+ Assertion string

+ Authentication OAuthClientAuthenticationType

+ ID string

+ Secret string

+ type OAuth2AuthenticationDataGrant string

+ const AuthorizationCodeGrant

+ const ClientCredentialsGrant

+ const PasswordGrant

+ const RefreshTokenGrant

+ const TokenExchangeGrant

+ type OAuth2AuthenticationPolicy struct

+ Endpoints *OAuth2Endpoints

+ Properties *OAuth2AuthenticationProperties

+ Use string

+ func (o *OAuth2AuthenticationPolicy) ApplyDefaults()

+ func (o *OAuth2AuthenticationPolicy) MarshalJSON() ([]byte, error)

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

+ type OAuth2AuthenticationProperties struct

+ Actor *OAuth2Token

+ Audiences []string

+ Authority URITemplate

+ Client *OAuth2AutenthicationDataClient

+ Grant OAuth2AuthenticationDataGrant

+ Issuers []string

+ Password string

+ Request *OAuth2TokenRequest

+ Scopes []string

+ Subject *OAuth2Token

+ Username string

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

+ type OAuth2Endpoints struct

+ Introspection string

+ Revocation string

+ Token string

+ type OAuth2Token struct

+ Token string

+ Type string

+ type OAuth2TokenRequest struct

+ Encoding OAuth2TokenRequestEncodingType

+ type OAuth2TokenRequestEncodingType string

+ const EncodingTypeApplicationJson

+ const EncodingTypeFormUrlEncoded

+ type OAuthClientAuthenticationType string

+ const OAuthClientAuthClientSecretBasic

+ const OAuthClientAuthClientSecretJWT

+ const OAuthClientAuthClientSecretPost

+ const OAuthClientAuthNone

+ const OAuthClientAuthPrivateKeyJWT

+ type ObjectOrRuntimeExpr struct

+ Value interface{}

+ func (o *ObjectOrRuntimeExpr) MarshalJSON() ([]byte, error)

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

+ func (o *ObjectOrRuntimeExpr) Validate() error

+ type ObjectOrString struct

+ Value interface{}

+ func (o *ObjectOrString) MarshalJSON() ([]byte, error)

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

+ type OpenAPIArguments struct

+ Authentication *ReferenceableAuthenticationPolicy

+ Document *ExternalResource

+ OperationID string

+ Output string

+ Parameters map[string]interface{}

+ type OpenIdConnectAuthenticationPolicy struct

+ Properties *OAuth2AuthenticationProperties

+ Use string

+ type Output struct

+ As *ObjectOrRuntimeExpr

+ Schema *Schema

+ type RaiseTask struct

+ Raise RaiseTaskConfiguration

+ type RaiseTaskConfiguration struct

+ Error RaiseTaskError

+ type RaiseTaskError struct

+ Definition *Error

+ Ref *string

+ func (rte *RaiseTaskError) MarshalJSON() ([]byte, error)

+ func (rte *RaiseTaskError) UnmarshalJSON(data []byte) error

+ type ReferenceableAuthenticationPolicy struct

+ AuthenticationPolicy *AuthenticationPolicy

+ Use *string

+ func (rap *ReferenceableAuthenticationPolicy) MarshalJSON() ([]byte, error)

+ func (rap *ReferenceableAuthenticationPolicy) UnmarshalJSON(data []byte) error

+ type RetryBackoff struct

+ Constant *BackoffDefinition

+ Exponential *BackoffDefinition

+ Linear *BackoffDefinition

+ func (rb *RetryBackoff) MarshalJSON() ([]byte, error)

+ func (rb *RetryBackoff) UnmarshalJSON(data []byte) error

+ type RetryLimit struct

+ Attempt *RetryLimitAttempt

+ Duration *Duration

+ type RetryLimitAttempt struct

+ Count int

+ Duration *Duration

+ type RetryPolicy struct

+ Backoff *RetryBackoff

+ Delay *Duration

+ ExceptWhen *RuntimeExpression

+ Jitter *RetryPolicyJitter

+ Limit RetryLimit

+ Ref string

+ When *RuntimeExpression

+ func (rp *RetryPolicy) MarshalJSON() ([]byte, error)

+ func (rp *RetryPolicy) ResolveReference(retries map[string]*RetryPolicy) error

+ func (rp *RetryPolicy) UnmarshalJSON(data []byte) error

+ type RetryPolicyJitter struct

+ From *Duration

+ To *Duration

+ type RunTask struct

+ Run RunTaskConfiguration

+ type RunTaskConfiguration struct

+ Await *bool

+ Container *Container

+ Script *Script

+ Shell *Shell

+ Workflow *RunWorkflow

+ func (rtc *RunTaskConfiguration) MarshalJSON() ([]byte, error)

+ func (rtc *RunTaskConfiguration) UnmarshalJSON(data []byte) error

+ type RunWorkflow struct

+ Input map[string]interface{}

+ Name string

+ Namespace string

+ Version string

+ type RuntimeExpression struct

+ Value string

+ func NewExpr(runtimeExpression string) *RuntimeExpression

+ func (r *RuntimeExpression) IsValid() bool

+ func (r *RuntimeExpression) MarshalJSON() ([]byte, error)

+ func (r *RuntimeExpression) String() string

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

+ type Schedule struct

+ After *Duration

+ Cron string

+ Every *Duration

+ On *EventConsumptionStrategy

+ type Schema struct

+ Document interface{}

+ Format string

+ Resource *ExternalResource

+ func (s *Schema) ApplyDefaults()

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

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

+ type Script struct

+ Arguments map[string]interface{}

+ Environment map[string]string

+ External *ExternalResource

+ InlineCode *string

+ Language string

+ type SetTask struct

+ Set map[string]interface{}

+ func (st *SetTask) MarshalJSON() ([]byte, error)

+ func (st *SetTask) UnmarshalJSON(data []byte) error

+ type Shell struct

+ Arguments map[string]interface{}

+ Command string

+ Environment map[string]string

+ type StringOrRuntimeExpr struct

+ Value interface{}

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

+ func (s *StringOrRuntimeExpr) String() string

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

+ type SwitchCase struct

+ Then *FlowDirective

+ When *RuntimeExpression

+ type SwitchItem map[string]SwitchCase

+ type SwitchTask struct

+ Switch []SwitchItem

+ func (st *SwitchTask) MarshalJSON() ([]byte, error)

+ func (st *SwitchTask) UnmarshalJSON(data []byte) error

+ type Task interface

+ type TaskBase struct

+ Export *Export

+ If *RuntimeExpression

+ Input *Input

+ Metadata map[string]interface{}

+ Output *Output

+ Then *FlowDirective

+ Timeout *TimeoutOrReference

+ type TaskItem struct

+ Key string

+ Task Task

+ func (ti *TaskItem) AsCallAsyncAPITask() *CallAsyncAPI

+ func (ti *TaskItem) AsCallFunctionTask() *CallFunction

+ func (ti *TaskItem) AsCallGRPCTask() *CallGRPC

+ func (ti *TaskItem) AsCallHTTPTask() *CallHTTP

+ func (ti *TaskItem) AsCallOpenAPITask() *CallOpenAPI

+ func (ti *TaskItem) AsDoTask() *DoTask

+ func (ti *TaskItem) AsEmitTask() *EmitTask

+ func (ti *TaskItem) AsForTask() *ForTask

+ func (ti *TaskItem) AsForkTask() *ForkTask

+ func (ti *TaskItem) AsListenTask() *ListenTask

+ func (ti *TaskItem) AsRaiseTask() *RaiseTask

+ func (ti *TaskItem) AsRunTask() *RunTask

+ func (ti *TaskItem) AsSetTask() *SetTask

+ func (ti *TaskItem) AsSwitchTask() *SwitchTask

+ func (ti *TaskItem) AsTask() *TaskBase

+ func (ti *TaskItem) AsTryTask() *TryTask

+ func (ti *TaskItem) AsWaitTask() *WaitTask

+ func (ti *TaskItem) MarshalJSON() ([]byte, error)

+ type TaskList []*TaskItem

+ func (tl *TaskList) Key(key string) *TaskItem

+ func (tl *TaskList) MarshalJSON() ([]byte, error)

+ func (tl *TaskList) UnmarshalJSON(data []byte) error

+ type Timeout struct

+ After *Duration

+ func (t *Timeout) MarshalJSON() ([]byte, error)

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

+ type TimeoutOrReference struct

+ Reference *string

+ Timeout *Timeout

+ func (tr *TimeoutOrReference) MarshalJSON() ([]byte, error)

+ func (tr *TimeoutOrReference) UnmarshalJSON(data []byte) error

+ type TryTask struct

+ Catch *TryTaskCatch

+ Try *TaskList

+ type TryTaskCatch struct

+ As string

+ Do *TaskList

+ Errors struct{ ... }

+ ExceptWhen *RuntimeExpression

+ Retry *RetryPolicy

+ When *RuntimeExpression

+ type URITemplate interface

+ IsURITemplate func() bool

+ String func() string

+ func UnmarshalURITemplate(data []byte) (URITemplate, error)

+ type URITemplateOrRuntimeExpr struct

+ Value interface{}

+ func NewUriTemplate(uriTemplate string) *URITemplateOrRuntimeExpr

+ func (u *URITemplateOrRuntimeExpr) MarshalJSON() ([]byte, error)

+ func (u *URITemplateOrRuntimeExpr) String() string

+ func (u *URITemplateOrRuntimeExpr) UnmarshalJSON(data []byte) error

+ type Use struct

+ Authentications map[string]*AuthenticationPolicy

+ Catalogs map[string]*Catalog

+ Errors map[string]*Error

+ Extensions ExtensionList

+ Functions NamedTaskMap

+ Retries map[string]*RetryPolicy

+ Secrets []string

+ Timeouts map[string]*Timeout

+ type WaitTask struct

+ Wait *Duration

+ func (wt *WaitTask) MarshalJSON() ([]byte, error)

+ func (wt *WaitTask) UnmarshalJSON(data []byte) error

+ type Workflow struct

+ Do *TaskList

+ Document Document

+ Input *Input

+ Output *Output

+ Schedule *Schedule

+ Timeout *TimeoutOrReference

+ Use *Use

+ func (w *Workflow) MarshalYAML() (interface{}, error)

+ type WorkflowBuilder struct

+ func NewWorkflowBuilder() *WorkflowBuilder

+ func (wb *WorkflowBuilder) AddTask(key string, task Task) *WorkflowBuilder

+ func (wb *WorkflowBuilder) Build() *Workflow

+ func (wb *WorkflowBuilder) SetDocument(dsl, namespace, name, version string) *WorkflowBuilder

+ func (wb *WorkflowBuilder) SetInput(input *Input) *WorkflowBuilder

+ func (wb *WorkflowBuilder) SetOutput(output *Output) *WorkflowBuilder

+ func (wb *WorkflowBuilder) SetSchedule(schedule *Schedule) *WorkflowBuilder

+ func (wb *WorkflowBuilder) SetTimeout(timeout *TimeoutOrReference) *WorkflowBuilder

+ func (wb *WorkflowBuilder) SetUse(use *Use) *WorkflowBuilder

+ func (wb *WorkflowBuilder) ToJSON() ([]byte, error)

+ func (wb *WorkflowBuilder) ToYAML() ([]byte, error)

Other modules containing this package

github.com/serverlessworkflow/sdk-go

github.com/serverlessworkflow/sdk-go/v2

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