core

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 28, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CodeFrameworkDefaults = map[CodeFramework]CodeFrameworkProps{
	CodeFrameworkNode: {
		Files: map[string]string{
			"index.ts": "" +
				"import { Context } from '@wakflo/flow';\n" +
				"\n" +
				"export function execute(context: FlowContext) {\n" +
				"\n" +
				"     return {};\n" +
				"}\n",
			"package.json": "{\n" +
				"  \"name\": \"node-code\",\n" +
				"  \"dependencies\": {\n" +
				"    \"@wakflo/flow\": \"^0.0.1\"\n" +
				"  }\n" +
				"}\n",
		},
		SourcePath: "src",
		EntryPath:  "index.ts",
		Framework:  CodeFrameworkNode,
		InternalFiles: []string{
			"package.json",
			"index.ts",
		},
	},
	CodeFrameworkDeno: {
		Files: map[string]string{
			"index.ts": "" +
				"import { Context } from '@wakflo/flow';\n" +
				"\n" +
				"export function execute(context: FlowContext) {\n" +
				"\n" +
				"return true;\n" +
				"}\n",
			"deno.json": "{\n" +
				"  \"imports\": {\n" +
				"  }\n" +
				"}\n",
		},
		SourcePath: "src",
		EntryPath:  "index.ts",
		Framework:  CodeFrameworkDeno,
		InternalFiles: []string{
			"deno.json",
			"index.ts",
		},
	},
	CodeFrameworkGoLang: {
		Files: map[string]string{
			"lib.go": "" +
				"package main\n" +
				"\n" +
				"func Execute() any {\n" +
				"\n" +
				"  return true\n" +
				"}\n",
			"go.mod": "" +
				"module main\n" +
				"\n" +
				"go 1.23.4\n",
		},
		SourcePath: "src",
		EntryPath:  "lib.go",
		Framework:  CodeFrameworkGoLang,
		InternalFiles: []string{
			"go.mod",
			"lib.go",
		},
	},
}
View Source 
var ErrNoValidEnum = errors.New("not a valid enum")
View Source 
var ErrorStepNotFound = errors.New("step not found")

ErrorStepNotFound definition for a case where a step is not found

Functions

func PrettyPrint added in v0.9.0 

func PrettyPrint(data interface{})

Types

type Action added in v0.9.0 

type Action struct {
	// Key holds the value of the "key" field.
	Name string `json:"key,omitempty"`
	Icon string `json:"icon,omitempty"`
	// Name holds the value of the "name" field.
	DisplayName string `json:"name,omitempty"`
	// Description holds the value of the "description" field.
	Description string `json:"description,omitempty"`
	// HelpText holds the value of the "helpText" field.
	HelpText *string `json:"helpText,omitempty"`
	// Input holds the value of the "input" field.
	Input *AutoFormSchema `json:"input,omitempty"`
	// Auth holds the value of the "auth" field.
	Auth *OperationAuth `json:"auth,omitempty"`
	// Output holds the value of the "output" field.
	Output map[string]any `json:"output,omitempty"`
	// SampleOutput holds the value of the "sample_output" field.
	SampleOutput JSON `json:"sampleOutput,omitempty"`

	Settings ActionSettings `json:"settings,omitempty"`

	// Documentation represents the field used to store the connector's documentation in markdown.
	Documentation *string `json:"documentation,omitempty"`

	Type ActionType `json:"type" validate:"required,oneof=ACTION"`
}

Action .

type ActionSettings added in v0.9.0 

type ActionSettings struct {
	Branch *BranchSettings `json:"branch,omitempty"`
}

type ActionType added in v0.9.0 

type ActionType string
const (
	ActionTypeBranch  ActionType = "BRANCH"
	ActionTypeBoolean ActionType = "BOOLEAN"
	ActionTypeNormal  ActionType = "STEP"
	ActionTypeLoop    ActionType = "LOOP"
)

func ActionTypeFromString added in v0.9.0 

func ActionTypeFromString(raw string) (ActionType, bool)

ActionTypeFromString determines the enum value with an exact case match.

func ActionTypeFromStringIgnoreCase added in v0.9.0 

func ActionTypeFromStringIgnoreCase(raw string) (ActionType, bool)

ActionTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (ActionType) IsValid added in v0.9.0 

func (_j ActionType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ActionType) MarshalBinary added in v0.9.0 

func (_j ActionType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for ActionType.

func (ActionType) MarshalGQL added in v0.9.0 

func (_j ActionType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for ActionType.

func (ActionType) MarshalJSON added in v0.9.0 

func (_j ActionType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ActionType.

func (ActionType) MarshalText added in v0.9.0 

func (_j ActionType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ActionType.

func (ActionType) MarshalYAML added in v0.9.0 

func (_j ActionType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for ActionType.

func (ActionType) SQLTypeName added in v0.9.0 

func (ActionType) SQLTypeName() string

func (*ActionType) Scan added in v0.9.0 

func (_j *ActionType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for ActionType.

func (ActionType) String added in v0.9.0 

func (_j ActionType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern ActionType(%d) instead.

func (*ActionType) UnmarshalBinary added in v0.9.0 

func (_j *ActionType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ActionType.

func (*ActionType) UnmarshalGQL added in v0.9.0 

func (_j *ActionType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for ActionType.

func (*ActionType) UnmarshalJSON added in v0.9.0 

func (_j *ActionType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ActionType.

func (*ActionType) UnmarshalText added in v0.9.0 

func (_j *ActionType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ActionType.

func (*ActionType) UnmarshalYAML added in v0.9.0 

func (_j *ActionType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for ActionType.

func (ActionType) Validate added in v0.9.0 

func (_j ActionType) Validate() error

Validate whether the value is within the range of enum values.

func (ActionType) Values added in v0.9.0 

func (ActionType) Values() []string

Values returns a slice of all String values of the enum.

type ActionsList added in v0.9.0 

type ActionsList = []*Action

type ActionsMap added in v0.9.0 

type ActionsMap = map[string]*Action

type AuthContext 

type AuthContext struct {
	AccessToken string              `json:"accessToken,omitempty"`
	Token       *oauth2.Token       `json:"token,omitempty"`
	TokenSource *oauth2.TokenSource `json:"tokenSource,omitempty"`
	TokenType   string              `json:"tokenType,omitempty"`
	Username    string              `json:"username,omitempty"`
	Password    string              `json:"password,omitempty"`
	Secret      string              `json:"secret,omitempty"`
	Scopes      []string            `json:"scopes,omitempty"`
	Key         string              `json:"key,omitempty"`
	Extra       map[string]string   `json:"extra,omitempty"`
}

func (*AuthContext) GetCustomAuth added in v0.4.2 

func (c *AuthContext) GetCustomAuth() (map[string]string, error)

func (*AuthContext) GetExtra added in v0.4.2 

func (c *AuthContext) GetExtra() (map[string]string, error)

type AuthEndpoint 

type AuthEndpoint struct {
	AuthURL          string `json:"auth_url,omitempty"`
	TokenURL         string `json:"token_url,omitempty"`
	RevocationURL    string `json:"revocation_url,omitempty"`
	IntrospectionURL string `json:"introspection_url,omitempty"`
	JWKSetURL        string `json:"jwk_set_url,omitempty"`
}

type AuthOperation 

type AuthOperation struct {
	Type   authenums.AuthType `json:"type"`
	Config map[string]any     `json:"config"`
}

AuthOperation is an auth operation struct.

type AuthSchemaProps added in v0.8.0 

type AuthSchemaProps struct {
	Scope    []string `json:"scope,omitempty"`
	TokenURL *string  `json:"tokenUrl,omitempty"`
	AuthURL  *string  `json:"authUrl,omitempty"`

	Username         *string           `json:"username,omitempty"`
	Password         *string           `json:"password,omitempty"`
	Secret           *string           `json:"secret,omitempty"`
	ExcludedParams   []string          `json:"excludedParams,omitempty"`
	RedirectParamKey string            `json:"redirectParamKey,omitempty"`
	ExtraParams      map[string]string `json:"extraParams,omitempty"`
}

type AuthState 

type AuthState struct {
	ClientID     *string           `json:"clientId,omitempty"`
	Code         *string           `json:"code,omitempty"`
	ClientSecret *string           `json:"clientSecret,omitempty"`
	AuthURL      *string           `json:"authUrl,omitempty"`
	TokenURL     *string           `json:"tokenUrl,omitempty"`
	Username     *string           `json:"username,omitempty"`
	Password     *string           `json:"password,omitempty"`
	Secret       *string           `json:"secret,omitempty"`
	Key          *string           `json:"key,omitempty"`
	RedirectURL  *string           `json:"redirectURL,omitempty"`
	GrantType    *string           `json:"grantType,omitempty"`
	AccessToken  *string           `json:"accessToken,omitempty"`
	RefreshToken *string           `json:"refreshToken,omitempty"`
	Scopes       []string          `json:"scopes,omitempty"`
	TokenType    *string           `json:"tokenType,omitempty"`
	Endpoint     *oauth2.Endpoint  `json:"endpoint,omitempty"`
	Expiry       *time.Time        `json:"expiry,omitempty"`
	Extra        map[string]string `json:"extra,omitempty"`
}

type AuthStatus 

type AuthStatus string
const (
	Disabled AuthStatus = "disabled"
	Active   AuthStatus = "active"
	Failed   AuthStatus = "failed"
)

func AuthStatusFromString 

func AuthStatusFromString(raw string) (AuthStatus, bool)

AuthStatusFromString determines the enum value with an exact case match.

func AuthStatusFromStringIgnoreCase 

func AuthStatusFromStringIgnoreCase(raw string) (AuthStatus, bool)

AuthStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (AuthStatus) IsValid 

func (_j AuthStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (AuthStatus) MarshalBinary 

func (_j AuthStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for AuthStatus.

func (AuthStatus) MarshalGQL 

func (_j AuthStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for AuthStatus.

func (AuthStatus) MarshalJSON 

func (_j AuthStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for AuthStatus.

func (AuthStatus) MarshalText 

func (_j AuthStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for AuthStatus.

func (AuthStatus) MarshalYAML 

func (_j AuthStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for AuthStatus.

func (AuthStatus) SQLTypeName 

func (AuthStatus) SQLTypeName() string

func (*AuthStatus) Scan 

func (_j *AuthStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for AuthStatus.

func (AuthStatus) String 

func (_j AuthStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern AuthStatus(%d) instead.

func (*AuthStatus) UnmarshalBinary 

func (_j *AuthStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for AuthStatus.

func (*AuthStatus) UnmarshalGQL 

func (_j *AuthStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for AuthStatus.

func (*AuthStatus) UnmarshalJSON 

func (_j *AuthStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for AuthStatus.

func (*AuthStatus) UnmarshalText 

func (_j *AuthStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for AuthStatus.

func (*AuthStatus) UnmarshalYAML 

func (_j *AuthStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for AuthStatus.

func (AuthStatus) Validate 

func (_j AuthStatus) Validate() error

Validate whether the value is within the range of enum values.

func (AuthStatus) Values 

func (AuthStatus) Values() []string

Values returns a slice of all String values of the enum.

type AuthStrategy 

type AuthStrategy struct {
	google.Credentials
	authutil.AuthorizationType
}

type AuthType 

type AuthType string
const (
	None   AuthType = "none"
	Basic  AuthType = "basic"
	Secret AuthType = "secret"
	APIKey AuthType = "api_key"
	OAuth2 AuthType = "oauth2"
	Custom AuthType = "custom"
)

func AuthTypeFromString 

func AuthTypeFromString(raw string) (AuthType, bool)

AuthTypeFromString determines the enum value with an exact case match.

func AuthTypeFromStringIgnoreCase 

func AuthTypeFromStringIgnoreCase(raw string) (AuthType, bool)

AuthTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (AuthType) IsValid 

func (_j AuthType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (AuthType) MarshalBinary 

func (_j AuthType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for AuthType.

func (AuthType) MarshalGQL 

func (_j AuthType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for AuthType.

func (AuthType) MarshalJSON 

func (_j AuthType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for AuthType.

func (AuthType) MarshalText 

func (_j AuthType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for AuthType.

func (AuthType) MarshalYAML 

func (_j AuthType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for AuthType.

func (AuthType) SQLTypeName 

func (AuthType) SQLTypeName() string

func (*AuthType) Scan 

func (_j *AuthType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for AuthType.

func (AuthType) String 

func (_j AuthType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern AuthType(%d) instead.

func (*AuthType) UnmarshalBinary 

func (_j *AuthType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for AuthType.

func (*AuthType) UnmarshalGQL 

func (_j *AuthType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for AuthType.

func (*AuthType) UnmarshalJSON 

func (_j *AuthType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for AuthType.

func (*AuthType) UnmarshalText 

func (_j *AuthType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for AuthType.

func (*AuthType) UnmarshalYAML 

func (_j *AuthType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for AuthType.

func (AuthType) Validate 

func (_j AuthType) Validate() error

Validate whether the value is within the range of enum values.

func (AuthType) Values 

func (AuthType) Values() []string

Values returns a slice of all String values of the enum.

type AutoFormDataProps added in v0.8.0 

type AutoFormDataProps struct {
	Auth *AuthSchemaProps `json:"auth,omitempty"`
}

type AutoFormFieldLogic 

type AutoFormFieldLogic struct {
	Validations map[string]AutoFormFieldLogicValidationDefinition `json:"validations,omitempty"`
}

type AutoFormFieldLogicRuleData 

type AutoFormFieldLogicRuleData struct {
	Var         *string `json:"var,omitempty"`
	MissingSome *string `json:"missing_some,omitempty"`
	Missing     *string `json:"missing,omitempty"`
}

type AutoFormFieldLogicValidationDefinition 

type AutoFormFieldLogicValidationDefinition struct {
	ErrorMessage string                                              `json:"errorMessage,omitempty"`
	Rule         map[FieldLogicOperators]*AutoFormFieldLogicRuleData `json:"rule,omitempty"`
}

type AutoFormFieldPresentationError 

type AutoFormFieldPresentationError struct {
	Required *string `json:"required,omitempty"`
	Minimum  *string `json:"minimum,omitempty"`
	Maximum  *string `json:"maximum,omitempty"`
}

type AutoFormFieldProps added in v0.8.0 

type AutoFormFieldProps struct {
	ID          string            `json:"id,omitempty"`
	Name        string            `json:"name,omitempty"`
	Type        string            `json:"type,omitempty"`
	ControlType AutoFormFieldType `json:"controlType,omitempty"`
	Required    bool              `json:"required"`
	Language    CodeLanguage      `json:"language,omitempty"`
	Framework   CodeFramework     `json:"framework,omitempty"`
	Hint        string            `json:"hint,omitempty"`
	Label       string            `json:"label,omitempty"`
	Disabled    bool              `json:"disabled"`
	Hidden      bool              `json:"hidden"`
	Placeholder string            `json:"placeholder,omitempty"`
	ReadOnly    bool              `json:"readOnly"`
	Multiple    bool              `json:"multiple"`
	MinDate     *time.Time        `json:"minDate,omitempty"`
	MaxDate     *time.Time        `json:"maxDate,omitempty"`
	Min         *int              `json:"min,omitempty"`
	Max         *int              `json:"max,omitempty"`

	Auth *AuthSchemaProps `json:"auth,omitempty"`

	// Notify is used to notify other fields after changes
	Notify []string `json:"notify,omitempty"`

	// Example Usage in JS
	// relevant: ({ formApi, scope }) => {
	//    return formApi.getValue(`${scope}.married`) == 'yes';
	// }
	// The value should be a stringified JS function
	Relevant     *string `json:"relevant,omitempty"`
	InitialValue any     `json:"initialValue,omitempty"`
	DefaultValue any     `json:"defaultValue,omitempty"`
	KeepState    bool    `json:"keepState,omitempty"`
}

type AutoFormFieldSelectOptions 

type AutoFormFieldSelectOptions struct {
	Value    string `json:"value"`
	Label    string `json:"label"`
	Metadata any    `json:"metadata,omitempty"`
}

AutoFormFieldSelectOptions represents an enumerated type with a value and label.

type AutoFormFieldType 

type AutoFormFieldType string
const (
	AutoFormFieldTypeShortText      AutoFormFieldType = "short_text"
	AutoFormFieldTypeLongText       AutoFormFieldType = "long_text"
	AutoFormFieldTypeMarkdown       AutoFormFieldType = "markdown"
	AutoFormFieldTypeSelect         AutoFormFieldType = "select"
	AutoFormFieldTypeStaticDropdown AutoFormFieldType = "static_dropdown"
	AutoFormFieldTypeNumber         AutoFormFieldType = "number"
	AutoFormFieldTypeCheckbox       AutoFormFieldType = "checkbox"
	AutoFormFieldTypeOauth2         AutoFormFieldType = "oauth"
	AutoFormFieldTypeSecretAuth     AutoFormFieldType = "secret"
	AutoFormFieldTypeCustomAuth     AutoFormFieldType = "custom_auth"
	AutoFormFieldTypeArray          AutoFormFieldType = "array"
	AutoFormFieldTypeObject         AutoFormFieldType = "fieldset"
	AutoFormFieldTypeBasicAuth      AutoFormFieldType = "basic_auth"
	AutoFormFieldTypeJSON           AutoFormFieldType = "json"
	AutoFormFieldTypeDateTime       AutoFormFieldType = "datetime"
	AutoFormFieldTypeFile           AutoFormFieldType = "file"
	AutoFormFieldTypeFileString     AutoFormFieldType = "file_string"
	AutoFormFieldTypeBoolean        AutoFormFieldType = "boolean"
	AutoFormFieldTypeDynamic        AutoFormFieldType = "dynamic"
	AutoFormFieldTypeCode           AutoFormFieldType = "code"
	AutoFormFieldTypeRichText       AutoFormFieldType = "richtext"
	AutoFormFieldTypeBranch         AutoFormFieldType = "branch"
	AutoFormFieldTypeWrapper        AutoFormFieldType = "wrapper"
	AutoFormFieldTypeCodeFramework  AutoFormFieldType = "framework"
	AutoFormFieldTypeCondition      AutoFormFieldType = "condition"
)

func FieldTypeFromString 

func FieldTypeFromString(raw string) (AutoFormFieldType, bool)

FieldTypeFromString determines the enum value with an exact case match.

func FieldTypeFromStringIgnoreCase 

func FieldTypeFromStringIgnoreCase(raw string) (AutoFormFieldType, bool)

FieldTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (AutoFormFieldType) IsValid 

func (_j AutoFormFieldType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (AutoFormFieldType) MarshalBinary 

func (_j AutoFormFieldType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for AutoFormFieldType.

func (AutoFormFieldType) MarshalGQL 

func (_j AutoFormFieldType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for AutoFormFieldType.

func (AutoFormFieldType) MarshalJSON 

func (_j AutoFormFieldType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for AutoFormFieldType.

func (AutoFormFieldType) MarshalText 

func (_j AutoFormFieldType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for AutoFormFieldType.

func (AutoFormFieldType) MarshalYAML 

func (_j AutoFormFieldType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for AutoFormFieldType.

func (AutoFormFieldType) SQLTypeName 

func (AutoFormFieldType) SQLTypeName() string

func (*AutoFormFieldType) Scan 

func (_j *AutoFormFieldType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for AutoFormFieldType.

func (AutoFormFieldType) String 

func (_j AutoFormFieldType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern AutoFormFieldType(%d) instead.

func (*AutoFormFieldType) UnmarshalBinary 

func (_j *AutoFormFieldType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for AutoFormFieldType.

func (*AutoFormFieldType) UnmarshalGQL 

func (_j *AutoFormFieldType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for AutoFormFieldType.

func (*AutoFormFieldType) UnmarshalJSON 

func (_j *AutoFormFieldType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for AutoFormFieldType.

func (*AutoFormFieldType) UnmarshalText 

func (_j *AutoFormFieldType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for AutoFormFieldType.

func (*AutoFormFieldType) UnmarshalYAML 

func (_j *AutoFormFieldType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for AutoFormFieldType.

func (AutoFormFieldType) Validate 

func (_j AutoFormFieldType) Validate() error

Validate whether the value is within the range of enum values.

func (AutoFormFieldType) Values 

func (AutoFormFieldType) Values() []string

Values returns a slice of all String values of the enum.

type AutoFormSchema 

type AutoFormSchema struct {
	Schema               string                     `json:"$schema,omitempty"`
	ID                   string                     `json:"$id,omitempty"`
	Comment              *string                    `json:"$comment,omitempty"`
	Title                string                     `json:"title,omitempty"`
	Type                 AutoFormType               `json:"type,omitempty"`
	Properties           map[string]*AutoFormSchema `json:"properties,omitempty"`
	Items                *AutoFormSchema            `json:"items,omitempty"`
	AdditionalItems      *AutoFormSchema            `json:"additionalItems,omitempty"`
	Required             []string                   `json:"required,omitempty"`
	IsRequired           bool                       `json:"isRequired,omitempty"`
	Default              any                        `json:"default,omitempty"`
	Format               string                     `json:"format,omitempty"`
	Definitions          map[string]*AutoFormSchema `json:"definitions,omitempty"`
	Description          string                     `json:"description,omitempty"`
	AdditionalProperties any                        `json:"additionalProperties,omitempty"`
	MinProperties        *int                       `json:"minProperties,omitempty"`
	MaxProperties        *int                       `json:"maxProperties,omitempty"`
	PatternProperties    map[string]*AutoFormSchema `json:"patternProperties,omitempty"`
	Dependencies         map[string]any             `json:"dependencies,omitempty"`
	Enum                 []any                      `json:"enum,omitempty"`
	AllOf                []*AutoFormSchema          `json:"allOf,omitempty"`
	AnyOf                []*AutoFormSchema          `json:"anyOf,omitempty"`
	OneOf                []*AutoFormSchema          `json:"oneOf,omitempty"`
	Not                  *AutoFormSchema            `json:"not,omitempty"`
	Minimum              any                        `json:"minimum,omitempty"`
	Maximum              any                        `json:"maximum,omitempty"`
	ExclusiveMinimum     any                        `json:"exclusiveMinimum,omitempty"`
	ExclusiveMaximum     any                        `json:"exclusiveMaximum,omitempty"`
	MinLength            *int                       `json:"minLength,omitempty"`
	MaxLength            *int                       `json:"maxLength,omitempty"`
	Pattern              string                     `json:"pattern,omitempty"`
	MinItems             *int                       `json:"minItems,omitempty"`
	MaxItems             *int                       `json:"maxItems,omitempty"`
	UniqueItems          bool                       `json:"uniqueItems,omitempty"`
	Contains             *AutoFormSchema            `json:"contains,omitempty"`
	MinContains          *int                       `json:"minContains,omitempty"`
	MaxContains          *int                       `json:"maxContains,omitempty"`
	Const                any                        `json:"const,omitempty"`
	Disabled             bool                       `json:"disabled"`
	Order                []string                   `json:"order,omitempty"`

	If   *AutoFormSchema `json:"if,omitempty"`
	Else *AutoFormSchema `json:"else,omitempty"`
	Then *AutoFormSchema `json:"then,omitempty"`

	UIControl AutoFormFieldType `json:"ui:control,omitempty"`
	// UIData            *AutoFormDataProps  `json:"ui:data,omitempty"`
	UIProps           *AutoFormFieldProps `json:"ui:props,omitempty"`
	UIComponentRemove *AutoFormSchema     `json:"ui:component:remove,omitempty"`
	UIBefore          []AutoFormSchema    `json:"ui:before,omitempty"`

	DependsOn []string `json:"dependsOn,omitempty"`
	IsDynamic bool     `json:"isDynamic,omitempty"`
	// contains filtered or unexported fields
}

func (*AutoFormSchema) GetDynamicOptionsFn 

func (af *AutoFormSchema) GetDynamicOptionsFn(ctx *DynamicFieldContext) (interface{}, error)

func (*AutoFormSchema) SetDynamicOptionsFn 

func (af *AutoFormSchema) SetDynamicOptionsFn(dynamicOptionsFn *DynamicOptionsFn)

type AutoFormType 

type AutoFormType string
const (
	Undefined AutoFormType = "undefined"
	String    AutoFormType = "string"
	Number    AutoFormType = "number"
	Object    AutoFormType = "object"
	Array     AutoFormType = "array"
	Boolean   AutoFormType = "boolean"
	Nullable  AutoFormType = "null"
	Integer   AutoFormType = "integer"
)

func (AutoFormType) String 

func (s AutoFormType) String() string

func (*AutoFormType) UnmarshalJSON 

func (s *AutoFormType) UnmarshalJSON(data []byte) error

UnmarshalJSON function to convert json into enum value

type BasicAuthSrategy 

type BasicAuthSrategy struct{}

type BranchExecutionType added in v0.9.0 

type BranchExecutionType string
const (
	BranchExecutionTypeFirstMatch BranchExecutionType = "FIRST_MATCH"
	BranchExecutionTypeAllMatches BranchExecutionType = "ALL_MATCHES"
)

func BranchExecutionTypeFromString added in v0.9.0 

func BranchExecutionTypeFromString(raw string) (BranchExecutionType, bool)

BranchExecutionTypeFromString determines the enum value with an exact case match.

func BranchExecutionTypeFromStringIgnoreCase added in v0.9.0 

func BranchExecutionTypeFromStringIgnoreCase(raw string) (BranchExecutionType, bool)

BranchExecutionTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (BranchExecutionType) IsValid added in v0.9.0 

func (_j BranchExecutionType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (BranchExecutionType) MarshalBinary added in v0.9.0 

func (_j BranchExecutionType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalGQL added in v0.9.0 

func (_j BranchExecutionType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalJSON added in v0.9.0 

func (_j BranchExecutionType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalText added in v0.9.0 

func (_j BranchExecutionType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalYAML added in v0.9.0 

func (_j BranchExecutionType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for BranchExecutionType.

func (BranchExecutionType) SQLTypeName added in v0.9.0 

func (BranchExecutionType) SQLTypeName() string

func (*BranchExecutionType) Scan added in v0.9.0 

func (_j *BranchExecutionType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for BranchExecutionType.

func (BranchExecutionType) String added in v0.9.0 

func (_j BranchExecutionType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern BranchExecutionType(%d) instead.

func (*BranchExecutionType) UnmarshalBinary added in v0.9.0 

func (_j *BranchExecutionType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalGQL added in v0.9.0 

func (_j *BranchExecutionType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalJSON added in v0.9.0 

func (_j *BranchExecutionType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalText added in v0.9.0 

func (_j *BranchExecutionType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalYAML added in v0.9.0 

func (_j *BranchExecutionType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for BranchExecutionType.

func (BranchExecutionType) Validate added in v0.9.0 

func (_j BranchExecutionType) Validate() error

Validate whether the value is within the range of enum values.

func (BranchExecutionType) Values added in v0.9.0 

func (BranchExecutionType) Values() []string

Values returns a slice of all String values of the enum.

type BranchSettings added in v0.9.0 

type BranchSettings struct {
	MaxBranches     int                 `json:"maxBranches"`
	ExecutionType   BranchExecutionType `json:"executionType"`
	DefaultBranches []FlowBranch        `json:"defaultBranches,omitempty"`
}

type BranchType 

type BranchType string
const (
	BranchTypeDefault   BranchType = "DEFAULT"
	BranchTypeCondition BranchType = "CONDITION"
)

func BranchTypeFromString added in v0.9.0 

func BranchTypeFromString(raw string) (BranchType, bool)

BranchTypeFromString determines the enum value with an exact case match.

func BranchTypeFromStringIgnoreCase added in v0.9.0 

func BranchTypeFromStringIgnoreCase(raw string) (BranchType, bool)

BranchTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (BranchType) IsValid added in v0.9.0 

func (_j BranchType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (BranchType) MarshalBinary added in v0.9.0 

func (_j BranchType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for BranchType.

func (BranchType) MarshalGQL added in v0.9.0 

func (_j BranchType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for BranchType.

func (BranchType) MarshalJSON added in v0.9.0 

func (_j BranchType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for BranchType.

func (BranchType) MarshalText added in v0.9.0 

func (_j BranchType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for BranchType.

func (BranchType) MarshalYAML added in v0.9.0 

func (_j BranchType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for BranchType.

func (BranchType) SQLTypeName added in v0.9.0 

func (BranchType) SQLTypeName() string

func (*BranchType) Scan added in v0.9.0 

func (_j *BranchType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for BranchType.

func (BranchType) String added in v0.9.0 

func (_j BranchType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern BranchType(%d) instead.

func (*BranchType) UnmarshalBinary added in v0.9.0 

func (_j *BranchType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for BranchType.

func (*BranchType) UnmarshalGQL added in v0.9.0 

func (_j *BranchType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for BranchType.

func (*BranchType) UnmarshalJSON added in v0.9.0 

func (_j *BranchType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for BranchType.

func (*BranchType) UnmarshalText added in v0.9.0 

func (_j *BranchType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for BranchType.

func (*BranchType) UnmarshalYAML added in v0.9.0 

func (_j *BranchType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for BranchType.

func (BranchType) Validate added in v0.9.0 

func (_j BranchType) Validate() error

Validate whether the value is within the range of enum values.

func (BranchType) Values added in v0.9.0 

func (BranchType) Values() []string

Values returns a slice of all String values of the enum.

type CodeFramework added in v0.9.0 

type CodeFramework string
const (
	CodeFrameworkNode   CodeFramework = "NODEJS"
	CodeFrameworkGoLang CodeFramework = "GOLANG"
	CodeFrameworkDeno   CodeFramework = "DENO"
)

func CodeFrameworkFromString added in v0.9.0 

func CodeFrameworkFromString(raw string) (CodeFramework, bool)

CodeFrameworkFromString determines the enum value with an exact case match.

func CodeFrameworkFromStringIgnoreCase added in v0.9.0 

func CodeFrameworkFromStringIgnoreCase(raw string) (CodeFramework, bool)

CodeFrameworkFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (CodeFramework) IsValid added in v0.9.0 

func (_j CodeFramework) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (CodeFramework) MarshalBinary added in v0.9.0 

func (_j CodeFramework) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for CodeFramework.

func (CodeFramework) MarshalGQL added in v0.9.0 

func (_j CodeFramework) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for CodeFramework.

func (CodeFramework) MarshalJSON added in v0.9.0 

func (_j CodeFramework) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for CodeFramework.

func (CodeFramework) MarshalText added in v0.9.0 

func (_j CodeFramework) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for CodeFramework.

func (CodeFramework) MarshalYAML added in v0.9.0 

func (_j CodeFramework) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for CodeFramework.

func (CodeFramework) SQLTypeName added in v0.9.0 

func (CodeFramework) SQLTypeName() string

func (*CodeFramework) Scan added in v0.9.0 

func (_j *CodeFramework) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for CodeFramework.

func (CodeFramework) String added in v0.9.0 

func (_j CodeFramework) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern CodeFramework(%d) instead.

func (*CodeFramework) UnmarshalBinary added in v0.9.0 

func (_j *CodeFramework) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalGQL added in v0.9.0 

func (_j *CodeFramework) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalJSON added in v0.9.0 

func (_j *CodeFramework) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalText added in v0.9.0 

func (_j *CodeFramework) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalYAML added in v0.9.0 

func (_j *CodeFramework) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for CodeFramework.

func (CodeFramework) Validate added in v0.9.0 

func (_j CodeFramework) Validate() error

Validate whether the value is within the range of enum values.

func (CodeFramework) Values added in v0.9.0 

func (CodeFramework) Values() []string

Values returns a slice of all String values of the enum.

type CodeFrameworkProps added in v0.9.0 

type CodeFrameworkProps struct {
	Files         map[string]string `json:"files"`
	SourcePath    string            `json:"sourcePath"`
	EntryPath     string            `json:"entryPath"`
	Framework     CodeFramework     `json:"framework"`
	InternalFiles []string          `json:"internalFiles"`
}

type CodeLanguage added in v0.9.0 

type CodeLanguage string
const (
	CodeLanguageJavascript CodeLanguage = "javascript"
	CodeLanguageGoLang     CodeLanguage = "go"
	CodeLanguageTypescript CodeLanguage = "typescript"
	CodeLanguageLua        CodeLanguage = "lua"
	CodeLanguagePGSql      CodeLanguage = "pgsql"
)

func CodeEditorLanguageFromString 

func CodeEditorLanguageFromString(raw string) (CodeLanguage, bool)

CodeEditorLanguageFromString determines the enum value with an exact case match.

func CodeEditorLanguageFromStringIgnoreCase 

func CodeEditorLanguageFromStringIgnoreCase(raw string) (CodeLanguage, bool)

CodeEditorLanguageFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (CodeLanguage) IsValid added in v0.9.0 

func (_j CodeLanguage) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (CodeLanguage) MarshalBinary added in v0.9.0 

func (_j CodeLanguage) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for CodeLanguage.

func (CodeLanguage) MarshalGQL added in v0.9.0 

func (_j CodeLanguage) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for CodeLanguage.

func (CodeLanguage) MarshalJSON added in v0.9.0 

func (_j CodeLanguage) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for CodeLanguage.

func (CodeLanguage) MarshalText added in v0.9.0 

func (_j CodeLanguage) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for CodeLanguage.

func (CodeLanguage) MarshalYAML added in v0.9.0 

func (_j CodeLanguage) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for CodeLanguage.

func (CodeLanguage) SQLTypeName added in v0.9.0 

func (CodeLanguage) SQLTypeName() string

func (*CodeLanguage) Scan added in v0.9.0 

func (_j *CodeLanguage) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for CodeLanguage.

func (CodeLanguage) String added in v0.9.0 

func (_j CodeLanguage) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern CodeLanguage(%d) instead.

func (*CodeLanguage) UnmarshalBinary added in v0.9.0 

func (_j *CodeLanguage) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalGQL added in v0.9.0 

func (_j *CodeLanguage) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalJSON added in v0.9.0 

func (_j *CodeLanguage) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalText added in v0.9.0 

func (_j *CodeLanguage) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalYAML added in v0.9.0 

func (_j *CodeLanguage) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for CodeLanguage.

func (CodeLanguage) Validate added in v0.9.0 

func (_j CodeLanguage) Validate() error

Validate whether the value is within the range of enum values.

func (CodeLanguage) Values added in v0.9.0 

func (CodeLanguage) Values() []string

Values returns a slice of all String values of the enum.

type ConnectorAuthMetadata 

type ConnectorAuthMetadata struct {
	ClientID     *string           `json:"clientId,omitempty"`
	ClientSecret *string           `json:"clientSecret,omitempty"`
	AuthURL      *string           `json:"authUrl,omitempty"`
	TokenURL     *string           `json:"tokenUrl,omitempty"`
	Username     *string           `json:"username,omitempty"`
	Password     *string           `json:"password,omitempty"`
	Secret       *string           `json:"secret,omitempty"`
	RedirectURL  *string           `json:"redirectUrl,omitempty"`
	Scopes       []string          `json:"scope,omitempty"`
	Key          *string           `json:"key,omitempty"`
	Extra        map[string]string `json:"extra,omitempty"`
}

type ConnectorAuthentication 

type ConnectorAuthentication struct {
	AuthType string `json:"authType"`
}

ConnectorAuthentication is a Task operation type.

type ConnectorPlatform added in v0.2.2 

type ConnectorPlatform string
const (
	ConnectorPlatformNative ConnectorPlatform = "native"
	ConnectorPlatformPlugin ConnectorPlatform = "plugin"
	ConnectorPlatformWasm   ConnectorPlatform = "wasm"
)

func ConnectorPlatformFromString added in v0.2.2 

func ConnectorPlatformFromString(raw string) (ConnectorPlatform, bool)

ConnectorPlatformFromString determines the enum value with an exact case match.

func ConnectorPlatformFromStringIgnoreCase added in v0.2.2 

func ConnectorPlatformFromStringIgnoreCase(raw string) (ConnectorPlatform, bool)

ConnectorPlatformFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (ConnectorPlatform) IsValid added in v0.2.2 

func (_j ConnectorPlatform) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ConnectorPlatform) MarshalBinary added in v0.2.2 

func (_j ConnectorPlatform) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalGQL added in v0.2.2 

func (_j ConnectorPlatform) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalJSON added in v0.2.2 

func (_j ConnectorPlatform) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalText added in v0.2.2 

func (_j ConnectorPlatform) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalYAML added in v0.2.2 

func (_j ConnectorPlatform) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for ConnectorPlatform.

func (ConnectorPlatform) SQLTypeName added in v0.2.2 

func (ConnectorPlatform) SQLTypeName() string

func (*ConnectorPlatform) Scan added in v0.2.2 

func (_j *ConnectorPlatform) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for ConnectorPlatform.

func (ConnectorPlatform) String added in v0.2.2 

func (_j ConnectorPlatform) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern ConnectorPlatform(%d) instead.

func (*ConnectorPlatform) UnmarshalBinary added in v0.2.2 

func (_j *ConnectorPlatform) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalGQL added in v0.2.2 

func (_j *ConnectorPlatform) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalJSON added in v0.2.2 

func (_j *ConnectorPlatform) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalText added in v0.2.2 

func (_j *ConnectorPlatform) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalYAML added in v0.2.2 

func (_j *ConnectorPlatform) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for ConnectorPlatform.

func (ConnectorPlatform) Validate added in v0.2.2 

func (_j ConnectorPlatform) Validate() error

Validate whether the value is within the range of enum values.

func (ConnectorPlatform) Values added in v0.2.2 

func (ConnectorPlatform) Values() []string

Values returns a slice of all String values of the enum.

type ConnectorPlugin 

type ConnectorPlugin struct {
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty"`
	// Description holds the value of the "deleted" field.
	Description string `json:"description"`
	// Version holds the value of the "version" field.
	Version string `json:"version"`
	// TeamType holds the value of the "language" field.
	Language PluginLanguage `json:"language,omitempty"`
}

ConnectorPlugin is a ConnectorPlugin model.

type ConnectorProperties 

type ConnectorProperties struct {
	FormState      FormState   `json:"formState"`
	Input          JSONObject  `json:"input"`
	Output         any         `json:"output"`
	LastTestTime   *int        `json:"lastTestTime"`
	LastTestStatus *TestStatus `json:"lastTestStatus"`
}

ConnectorProperties is a Task operation type.

type ConnectorStepData 

type ConnectorStepData struct {
	OperationID      *string             `json:"operationId"`
	AuthConnectionID *xid.ID             `json:"authConnectionId"`
	Properties       ConnectorProperties `json:"properties"`
}

type ConnectorStepMetadata 

type ConnectorStepMetadata struct {
	ConnectorName    string       `json:"connectorName,omitempty"`
	ConnectorVersion string       `json:"connectorVersion,omitempty"`
	TriggerType      *TriggerType `json:"triggerType,omitempty"`
}

type ConnectorStepPosition 

type ConnectorStepPosition struct {
	// Field of the step
	X int32 `json:"x"`

	Y int32 `json:"y"`
}

type ConnectorVersionMetadata 

type ConnectorVersionMetadata struct {
	// ID of the ent.
	ID xid.ID `json:"id,omitempty"`
	// DeletedAt holds the value of the "delete_time" field.
	DeletedAt time.Time `json:"delete_time,omitempty"`
	// CreatedAt holds the value of the "created_at" field.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// UpdatedAt holds the value of the "updated_at" field.
	UpdatedAt time.Time `json:"updated_at,omitempty"`
	// Auth holds the value of the "auth" field.
	Auth AuthOperation `json:"auth,omitempty"`
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty"`
	// DisplayName holds the value of the "display_name" field.
	DisplayName string `json:"display_name,omitempty"`
	// Description holds the value of the "description" field.
	Description string `json:"description,omitempty"`
	// Icon holds the value of the "icon" field.
	Icon string `json:"icon,omitempty"`
	// Version holds the value of the "version" field.
	Version string `json:"version,omitempty"`
	// Namespace holds the value of the "namespace" field.
	RegistryName string `json:"registry_name,omitempty"`
	// Documentation holds the value of the "documentation" field.
	Documentation *string `json:"documentation,omitempty"`
	// ReleaseNotes holds the value of the "release_notes" field.
	ReleaseNotes *string `json:"release_notes,omitempty"`
	// ConnectorID holds the value of the "connector_id" field.
	ConnectorID xid.ID `json:"connector_id,omitempty"`
	// BuildMetadata holds the value of the "build_metadata" field.
	BuildMetadata *string `json:"build_metadata,omitempty"`
	// FileURL holds the value of the "file_url" field.
	FileURL *string `json:"file_url,omitempty"`
	// FileHash holds the value of the "file_hash" field.
	FileHash *string `json:"file_hash,omitempty"`
	// Metadata holds the value of the "metadata" field.
	Metadata PluginMetadata `json:"metadata,omitempty"`
	// Operations holds the value of the "operations" field.
	Operations map[string]*Action `json:"operations,omitempty"`
	// Triggers holds the value of the "triggers" field.
	Triggers map[string]*Trigger `json:"triggers,omitempty"`
	// Approved holds the value of the "approved" field.
	Approved bool `json:"approved"`
}

ConnectorVersionMetadata is the model entity for the ConnectorVersion schema.

type Cursor added in v0.8.0 

type Cursor string

type DataType added in v0.9.0 

type DataType string

DataType Enum 

const (
	DataTypeString  DataType = "string"
	DataTypeNumber  DataType = "number"
	DataTypeBoolean DataType = "boolean"
	DataTypeDate    DataType = "date"
	DataTypeList    DataType = "list"
	DataTypeObject  DataType = "object" // Newly added
)

func (DataType) MarshalGQL added in v0.9.0 

func (dt DataType) MarshalGQL(w io.Writer)

func (DataType) MarshalJSON added in v0.9.0 

func (dt DataType) MarshalJSON() ([]byte, error)

func (*DataType) UnmarshalGQL added in v0.9.0 

func (dt *DataType) UnmarshalGQL(v interface{}) error

func (*DataType) UnmarshalJSON added in v0.9.0 

func (dt *DataType) UnmarshalJSON(data []byte) error

type DynamicFieldContext added in v0.2.7 

type DynamicFieldContext struct {
	*GetDynamicOptionsInput
	Auth  *AuthContext `json:"auth,omitempty"`
	Input any          `json:"input,omitempty"`
	Ctx   context.Context
}

func NewDynamicFieldContext added in v0.8.0 

func NewDynamicFieldContext(ctx DynamicFieldContext) *DynamicFieldContext

func (*DynamicFieldContext) GetContext added in v0.5.0 

func (c *DynamicFieldContext) GetContext() context.Context

func (*DynamicFieldContext) Respond added in v0.8.0 

func (c *DynamicFieldContext) Respond(data any, totalItems int) (*DynamicOptionsResponse, error)

func (*DynamicFieldContext) RespondJSON added in v0.8.0 

func (c *DynamicFieldContext) RespondJSON(data any, totalItems int) (JSON, error)

type DynamicFieldPaging added in v0.8.0 

type DynamicFieldPaging struct {
	*GetDynamicOptionsInput
	Auth  *AuthContext `json:"auth,omitempty"`
	Input any          `json:"input,omitempty"`
	Ctx   context.Context
}

type DynamicOptionsFilterParams added in v0.8.0 

type DynamicOptionsFilterParams struct {
	Offset     int    `json:"offset"` // The offset of the first item to return (default: 0)
	Limit      int    `json:"limit"`  // The maximum number of items to return (default: 10)
	FilterTerm string `json:"filterTerm"`
}

type DynamicOptionsFn 

type DynamicOptionsFn = func(ctx *DynamicFieldContext) (*DynamicOptionsResponse, error)

type DynamicOptionsResponse added in v0.8.0 

type DynamicOptionsResponse struct {
	Metadata OffsetPaginationMeta `json:"metadata"`
	Items    any                  `json:"items"`
}

type EntityReference 

type EntityReference struct {
	// Field such is the unique field name of the entity
	Field string `json:"field,omitempty"`

	// Value such is the unique field value of the entity
	Value string `json:"value,omitempty"`

	// Value such is the unique field value of the entity
	Version *string `json:"version,omitempty"`

	// Type of the entity
	Entity string `json:"entity,omitempty"`
}

type ExecutionMode added in v0.9.0 

type ExecutionMode string
const (
	ExecutionModeLive  ExecutionMode = "LIVE"
	ExecutionModeTest  ExecutionMode = "TEST"
	ExecutionModeDebug ExecutionMode = "DEBUG"
)

func ExecutionModeFromString added in v0.9.0 

func ExecutionModeFromString(raw string) (ExecutionMode, bool)

ExecutionModeFromString determines the enum value with an exact case match.

func ExecutionModeFromStringIgnoreCase added in v0.9.0 

func ExecutionModeFromStringIgnoreCase(raw string) (ExecutionMode, bool)

ExecutionModeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (ExecutionMode) IsValid added in v0.9.0 

func (_j ExecutionMode) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ExecutionMode) MarshalBinary added in v0.9.0 

func (_j ExecutionMode) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for ExecutionMode.

func (ExecutionMode) MarshalGQL added in v0.9.0 

func (_j ExecutionMode) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for ExecutionMode.

func (ExecutionMode) MarshalJSON added in v0.9.0 

func (_j ExecutionMode) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ExecutionMode.

func (ExecutionMode) MarshalText added in v0.9.0 

func (_j ExecutionMode) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ExecutionMode.

func (ExecutionMode) MarshalYAML added in v0.9.0 

func (_j ExecutionMode) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for ExecutionMode.

func (ExecutionMode) SQLTypeName added in v0.9.0 

func (ExecutionMode) SQLTypeName() string

func (*ExecutionMode) Scan added in v0.9.0 

func (_j *ExecutionMode) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for ExecutionMode.

func (ExecutionMode) String added in v0.9.0 

func (_j ExecutionMode) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern ExecutionMode(%d) instead.

func (*ExecutionMode) UnmarshalBinary added in v0.9.0 

func (_j *ExecutionMode) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalGQL added in v0.9.0 

func (_j *ExecutionMode) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalJSON added in v0.9.0 

func (_j *ExecutionMode) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalText added in v0.9.0 

func (_j *ExecutionMode) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalYAML added in v0.9.0 

func (_j *ExecutionMode) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for ExecutionMode.

func (ExecutionMode) Validate added in v0.9.0 

func (_j ExecutionMode) Validate() error

Validate whether the value is within the range of enum values.

func (ExecutionMode) Values added in v0.9.0 

func (ExecutionMode) Values() []string

Values returns a slice of all String values of the enum.

type ExecutionType 

type ExecutionType string
const (
	Begin  ExecutionType = "BEGIN"
	Resume ExecutionType = "RESUME"
)

func ExecutionTypeFromString 

func ExecutionTypeFromString(raw string) (ExecutionType, bool)

ExecutionTypeFromString determines the enum value with an exact case match.

func ExecutionTypeFromStringIgnoreCase 

func ExecutionTypeFromStringIgnoreCase(raw string) (ExecutionType, bool)

ExecutionTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (ExecutionType) IsValid 

func (_j ExecutionType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ExecutionType) MarshalBinary 

func (_j ExecutionType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for ExecutionType.

func (ExecutionType) MarshalGQL 

func (_j ExecutionType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for ExecutionType.

func (ExecutionType) MarshalJSON 

func (_j ExecutionType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ExecutionType.

func (ExecutionType) MarshalText 

func (_j ExecutionType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ExecutionType.

func (ExecutionType) MarshalYAML 

func (_j ExecutionType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for ExecutionType.

func (ExecutionType) SQLTypeName 

func (ExecutionType) SQLTypeName() string

func (*ExecutionType) Scan 

func (_j *ExecutionType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for ExecutionType.

func (ExecutionType) String 

func (_j ExecutionType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern ExecutionType(%d) instead.

func (*ExecutionType) UnmarshalBinary 

func (_j *ExecutionType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ExecutionType.

func (*ExecutionType) UnmarshalGQL 

func (_j *ExecutionType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for ExecutionType.

func (*ExecutionType) UnmarshalJSON 

func (_j *ExecutionType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ExecutionType.

func (*ExecutionType) UnmarshalText 

func (_j *ExecutionType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ExecutionType.

func (*ExecutionType) UnmarshalYAML 

func (_j *ExecutionType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for ExecutionType.

func (ExecutionType) Validate 

func (_j ExecutionType) Validate() error

Validate whether the value is within the range of enum values.

func (ExecutionType) Values 

func (ExecutionType) Values() []string

Values returns a slice of all String values of the enum.

type FieldLogicOperators 

type FieldLogicOperators string
const (
	Eq      FieldLogicOperators = "=="
	EEq     FieldLogicOperators = "==="
	NEq     FieldLogicOperators = "!="
	NNEq    FieldLogicOperators = "!=="
	Not     FieldLogicOperators = "!"
	NNot    FieldLogicOperators = "!!"
	Or      FieldLogicOperators = "or"
	And     FieldLogicOperators = "and"
	Lt      FieldLogicOperators = "<"
	Gt      FieldLogicOperators = ">"
	GEq     FieldLogicOperators = ">="
	LEq     FieldLogicOperators = "<="
	Between FieldLogicOperators = "between"
	Max     FieldLogicOperators = "max"
	Min     FieldLogicOperators = "min"
	Plus    FieldLogicOperators = "+"
	Minus   FieldLogicOperators = "-"
	Divide  FieldLogicOperators = "/"
	Modulo  FieldLogicOperators = "%"
	Map     FieldLogicOperators = "map"
	Reduce  FieldLogicOperators = "reduce"
	Filter  FieldLogicOperators = "filter"
	All     FieldLogicOperators = "all"
	Some    FieldLogicOperators = "some"
	Merge   FieldLogicOperators = "merge"
	In      FieldLogicOperators = "in"
	Cat     FieldLogicOperators = "cat"
	Substr  FieldLogicOperators = "substr"
)

func FieldLogicOperatorsFromString 

func FieldLogicOperatorsFromString(raw string) (FieldLogicOperators, bool)

FieldLogicOperatorsFromString determines the enum value with an exact case match.

func FieldLogicOperatorsFromStringIgnoreCase 

func FieldLogicOperatorsFromStringIgnoreCase(raw string) (FieldLogicOperators, bool)

FieldLogicOperatorsFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (FieldLogicOperators) IsValid 

func (_j FieldLogicOperators) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FieldLogicOperators) MarshalBinary 

func (_j FieldLogicOperators) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for FieldLogicOperators.

func (FieldLogicOperators) MarshalGQL 

func (_j FieldLogicOperators) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for FieldLogicOperators.

func (FieldLogicOperators) MarshalJSON 

func (_j FieldLogicOperators) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FieldLogicOperators.

func (FieldLogicOperators) MarshalText 

func (_j FieldLogicOperators) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for FieldLogicOperators.

func (FieldLogicOperators) MarshalYAML 

func (_j FieldLogicOperators) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for FieldLogicOperators.

func (FieldLogicOperators) SQLTypeName 

func (FieldLogicOperators) SQLTypeName() string

func (*FieldLogicOperators) Scan 

func (_j *FieldLogicOperators) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for FieldLogicOperators.

func (FieldLogicOperators) String 

func (_j FieldLogicOperators) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern FieldLogicOperators(%d) instead.

func (*FieldLogicOperators) UnmarshalBinary 

func (_j *FieldLogicOperators) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FieldLogicOperators.

func (*FieldLogicOperators) UnmarshalGQL 

func (_j *FieldLogicOperators) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for FieldLogicOperators.

func (*FieldLogicOperators) UnmarshalJSON 

func (_j *FieldLogicOperators) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FieldLogicOperators.

func (*FieldLogicOperators) UnmarshalText 

func (_j *FieldLogicOperators) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for FieldLogicOperators.

func (*FieldLogicOperators) UnmarshalYAML 

func (_j *FieldLogicOperators) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for FieldLogicOperators.

func (FieldLogicOperators) Validate 

func (_j FieldLogicOperators) Validate() error

Validate whether the value is within the range of enum values.

func (FieldLogicOperators) Values 

func (FieldLogicOperators) Values() []string

Values returns a slice of all String values of the enum.

type FlowBranch added in v0.9.0 

type FlowBranch struct {
	ID         string        `json:"id"`
	Name       string        `json:"name"`
	Type       BranchType    `json:"type"`
	Conditions *LogicalGroup `json:"conditions"`
}

type FlowMetadata added in v0.9.0 

type FlowMetadata struct {
	FlowVersionID xid.ID `json:"flow_version_id,omitempty"`
	// FlowID holds the value of the "flow_id" field.
	FlowID xid.ID `json:"flow_id"`
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty"`
	// LastRun field stores the timestamp of the last run of a flow version.
	LastRun *time.Time `json:"last_run,omitempty"`
	// Status indicates the current state of the flow version, represented by the FlowVersionState enumeration.
	Status FlowVersionState `json:"status"`
	// ProjectID holds the value of the "project_id" field.
	ProjectID xid.ID `json:"project_id,omitempty"`
}

func (FlowMetadata) ToSDK added in v0.9.0 

func (m FlowMetadata) ToSDK()

type FlowRunMetadata added in v0.9.0 

type FlowRunMetadata struct {
	// FlowID holds the value of the "id" field.
	FlowID xid.ID `json:"flowId,omitempty"`
	// Name holds the value of the "name" field.
	FlowName string `json:"flowName,omitempty"`
	// StepName holds the value of the "name" field.
	StepName string `json:"stepName,omitempty"`
	// ConnectorName holds the value of the "connectorName" field.
	ConnectorName string `json:"connectorName,omitempty"`
	// ConnectorVersion holds the value of the "connectorVersion" field.
	ConnectorVersion string `json:"connectorVersion,omitempty"`
	// LastRun represents the timestamp of the last run of a flow.
	LastRun *time.Time `json:"lastRun"`
}

type FlowRunStatus added in v0.9.0 

type FlowRunStatus string

FlowRunStatus represents the status of a flow run. 

const (
	FlowRunStatusReady         FlowRunStatus = "READY"
	FlowRunStatusQueued        FlowRunStatus = "QUEUED"
	FlowRunStatusRunning       FlowRunStatus = "RUNNING"
	FlowRunStatusSucceeded     FlowRunStatus = "SUCCEEDED"
	FlowRunStatusFailed        FlowRunStatus = "FAILED"
	FlowRunStatusPaused        FlowRunStatus = "PAUSED"
	FlowRunStatusInternalError FlowRunStatus = "INTERNAL_ERROR"
	FlowRunStatusQuotaExceeded FlowRunStatus = "QUOTA_EXCEEDED"
	FlowRunStatusTimeout       FlowRunStatus = "TIMEOUT"
	FlowRunStatusTerminated    FlowRunStatus = "TERMINATED"
)

Enum values for FlowRunStatus.

func FlowRunStatusFromString added in v0.9.0 

func FlowRunStatusFromString(raw string) (FlowRunStatus, bool)

FlowRunStatusFromString determines the enum value with an exact case match.

func FlowRunStatusFromStringIgnoreCase added in v0.9.0 

func FlowRunStatusFromStringIgnoreCase(raw string) (FlowRunStatus, bool)

FlowRunStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (FlowRunStatus) IsValid added in v0.9.0 

func (_j FlowRunStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowRunStatus) MarshalBinary added in v0.9.0 

func (_j FlowRunStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalGQL added in v0.9.0 

func (_j FlowRunStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalJSON added in v0.9.0 

func (_j FlowRunStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalText added in v0.9.0 

func (_j FlowRunStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalYAML added in v0.9.0 

func (_j FlowRunStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for FlowRunStatus.

func (FlowRunStatus) SQLTypeName added in v0.9.0 

func (FlowRunStatus) SQLTypeName() string

func (*FlowRunStatus) Scan added in v0.9.0 

func (_j *FlowRunStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for FlowRunStatus.

func (FlowRunStatus) String added in v0.9.0 

func (_j FlowRunStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern FlowRunStatus(%d) instead.

func (*FlowRunStatus) UnmarshalBinary added in v0.9.0 

func (_j *FlowRunStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalGQL added in v0.9.0 

func (_j *FlowRunStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalJSON added in v0.9.0 

func (_j *FlowRunStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalText added in v0.9.0 

func (_j *FlowRunStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalYAML added in v0.9.0 

func (_j *FlowRunStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for FlowRunStatus.

func (FlowRunStatus) Validate added in v0.9.0 

func (_j FlowRunStatus) Validate() error

Validate whether the value is within the range of enum values.

func (FlowRunStatus) Values added in v0.9.0 

func (FlowRunStatus) Values() []string

Values returns a slice of all String values of the enum.

type FlowSettings added in v0.9.0 

type FlowSettings struct {
	Config  map[string]interface{} `json:"config"`
	LastRun *time.Time             `json:"LastRun"`
}

type FlowStatus added in v0.9.0 

type FlowStatus string
const (
	FlowStatusEnabled  FlowStatus = "ENABLED"
	FlowStatusDisabled FlowStatus = "DISABLED"
)

func FlowStatusFromString added in v0.9.0 

func FlowStatusFromString(raw string) (FlowStatus, bool)

FlowStatusFromString determines the enum value with an exact case match.

func FlowStatusFromStringIgnoreCase added in v0.9.0 

func FlowStatusFromStringIgnoreCase(raw string) (FlowStatus, bool)

FlowStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (FlowStatus) IsValid added in v0.9.0 

func (_j FlowStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowStatus) MarshalBinary added in v0.9.0 

func (_j FlowStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowStatus.

func (FlowStatus) MarshalGQL added in v0.9.0 

func (_j FlowStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for FlowStatus.

func (FlowStatus) MarshalJSON added in v0.9.0 

func (_j FlowStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FlowStatus.

func (FlowStatus) MarshalText added in v0.9.0 

func (_j FlowStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for FlowStatus.

func (FlowStatus) MarshalYAML added in v0.9.0 

func (_j FlowStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for FlowStatus.

func (FlowStatus) SQLTypeName added in v0.9.0 

func (FlowStatus) SQLTypeName() string

func (*FlowStatus) Scan added in v0.9.0 

func (_j *FlowStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for FlowStatus.

func (FlowStatus) String added in v0.9.0 

func (_j FlowStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern FlowStatus(%d) instead.

func (*FlowStatus) UnmarshalBinary added in v0.9.0 

func (_j *FlowStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalGQL added in v0.9.0 

func (_j *FlowStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalJSON added in v0.9.0 

func (_j *FlowStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalText added in v0.9.0 

func (_j *FlowStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalYAML added in v0.9.0 

func (_j *FlowStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for FlowStatus.

func (FlowStatus) Validate added in v0.9.0 

func (_j FlowStatus) Validate() error

Validate whether the value is within the range of enum values.

func (FlowStatus) Values added in v0.9.0 

func (FlowStatus) Values() []string

Values returns a slice of all String values of the enum.

type FlowStep added in v0.9.0 

type FlowStep struct {
	// Name of the schema
	Name string `json:"name,omitempty" validate:"required"`

	// Label of the step
	Label string `json:"label,omitempty" validate:"required"`

	// Icon of the step
	Icon string `json:"icon,omitempty" validate:"required"`

	// Icon of the step
	Type FlowStepType `json:"type,omitempty" validate:"required"`

	Meta map[string]any `json:"meta"`

	Settings StepNodeSettings `json:"settings"`

	OperationID *string `json:"operationId"`

	Auth *StepNodeNodeAuthInput `json:"auth"`

	Form StepNodeFormInput `json:"form"`

	Output any `json:"output"`

	SampleOutput any `json:"sampleOutput"`

	Tests StepNodeTest `json:"tests"`

	FirstLoopStep *FlowStep `json:"firstLoopStep,omitempty"`

	NextStep *FlowStep `json:"nextStep,omitempty"`

	// Data of the step
	Children []*FlowStep `json:"children,omitempty"`

	Valid bool `json:"valid,omitempty"`

	Skip bool `json:"skip,omitempty"`
}

func FlattenSteps added in v0.5.0 

func FlattenSteps(node *FlowStep) []*FlowStep

func GetAllSteps added in v0.9.0 

func GetAllSteps(step FlowStep) []FlowStep

GetAllSteps Utility function to get all steps in a FlowStep recursively

func GetStep added in v0.9.0 

func GetStep(name string, flowRoot FlowStep) *FlowStep

GetStep retrieves a step by name in the flow hierarchy

func GetStepOrThrow added in v0.9.0 

func GetStepOrThrow(name string, flowRoot FlowStep) (*FlowStep, error)

GetStepOrThrow retrieves a step by name or throws an error if not found

func TransferStep added in v0.9.0 

func TransferStep(step FlowStep, transferFunction func(step FlowStep) FlowStep) FlowStep

TransferStep applies the transferFunction recursively to a FlowStep and its nested steps.

func (*FlowStep) Flatten added in v0.9.0 

func (s *FlowStep) Flatten() ([]FlowStep, error)

func (*FlowStep) FlattenUnsafe added in v0.9.0 

func (s *FlowStep) FlattenUnsafe() []FlowStep

func (*FlowStep) IsFlow added in v0.9.0 

func (s *FlowStep) IsFlow() bool

func (*FlowStep) IsLoop added in v0.9.0 

func (s *FlowStep) IsLoop() bool

func (*FlowStep) IsRouter added in v0.9.0 

func (s *FlowStep) IsRouter() bool

func (*FlowStep) IsTrigger added in v0.9.0 

func (s *FlowStep) IsTrigger() bool

func (*FlowStep) IsValid added in v0.9.0 

func (s *FlowStep) IsValid() bool

type FlowStepType added in v0.9.0 

type FlowStepType string
const (
	FlowStepTypeEmpty       FlowStepType = "EMPTY"
	FlowStepTypeStepTrigger FlowStepType = "STEP_TRIGGER"
	FlowStepTypeStep        FlowStepType = "STEP"
	FlowStepTypeLoop        FlowStepType = "LOOP"
	FlowStepTypeStepRouter  FlowStepType = "ROUTER"
)

func FlowStepTypeFromString added in v0.9.0 

func FlowStepTypeFromString(raw string) (FlowStepType, bool)

FlowStepTypeFromString determines the enum value with an exact case match.

func FlowStepTypeFromStringIgnoreCase added in v0.9.0 

func FlowStepTypeFromStringIgnoreCase(raw string) (FlowStepType, bool)

FlowStepTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (FlowStepType) IsValid added in v0.9.0 

func (_j FlowStepType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowStepType) MarshalBinary added in v0.9.0 

func (_j FlowStepType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowStepType.

func (FlowStepType) MarshalGQL added in v0.9.0 

func (_j FlowStepType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for FlowStepType.

func (FlowStepType) MarshalJSON added in v0.9.0 

func (_j FlowStepType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FlowStepType.

func (FlowStepType) MarshalText added in v0.9.0 

func (_j FlowStepType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for FlowStepType.

func (FlowStepType) MarshalYAML added in v0.9.0 

func (_j FlowStepType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for FlowStepType.

func (FlowStepType) SQLTypeName added in v0.9.0 

func (FlowStepType) SQLTypeName() string

func (*FlowStepType) Scan added in v0.9.0 

func (_j *FlowStepType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for FlowStepType.

func (FlowStepType) String added in v0.9.0 

func (_j FlowStepType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern FlowStepType(%d) instead.

func (*FlowStepType) UnmarshalBinary added in v0.9.0 

func (_j *FlowStepType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalGQL added in v0.9.0 

func (_j *FlowStepType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalJSON added in v0.9.0 

func (_j *FlowStepType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalText added in v0.9.0 

func (_j *FlowStepType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalYAML added in v0.9.0 

func (_j *FlowStepType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for FlowStepType.

func (FlowStepType) Validate added in v0.9.0 

func (_j FlowStepType) Validate() error

Validate whether the value is within the range of enum values.

func (FlowStepType) Values added in v0.9.0 

func (FlowStepType) Values() []string

Values returns a slice of all String values of the enum.

type FlowTemplate added in v0.9.0 

type FlowTemplate struct {
	Trigger FlowStep
	State   []int
}

type FlowTemplateType added in v0.9.0 

type FlowTemplateType = FlowTemplate

type FlowVersion added in v0.9.0 

type FlowVersion struct {
	ID xid.ID `json:"id,omitempty"`
	// FlowID holds the value of the "flow_id" field.
	FlowID xid.ID `json:"flow_id"`
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty"`
	// Steps holds the value of the "steps" field.
	Trigger FlowStep `json:"trigger,omitempty"`
	// ProjectID holds the value of the "project_id" field.
	ProjectID xid.ID `json:"project_id,omitempty"`
	// LastRun field stores the timestamp of the last run of a flow version.
	LastRun *time.Time `json:"last_run,omitempty"`
	// Status indicates the current state of the flow version, represented by the FlowVersionState enumeration.
	Status FlowVersionState `json:"status"`
}

type FlowVersionState added in v0.9.0 

type FlowVersionState string
const (
	FlowVersionStatePublished FlowVersionState = "PUBLISHED"
	FlowVersionStateDraft     FlowVersionState = "DRAFT"
	FlowVersionStateArchived  FlowVersionState = "ARCHIVE"
)

func FlowVersionStateFromString added in v0.9.0 

func FlowVersionStateFromString(raw string) (FlowVersionState, bool)

FlowVersionStateFromString determines the enum value with an exact case match.

func FlowVersionStateFromStringIgnoreCase added in v0.9.0 

func FlowVersionStateFromStringIgnoreCase(raw string) (FlowVersionState, bool)

FlowVersionStateFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (FlowVersionState) IsValid added in v0.9.0 

func (_j FlowVersionState) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowVersionState) MarshalBinary added in v0.9.0 

func (_j FlowVersionState) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowVersionState.

func (FlowVersionState) MarshalGQL added in v0.9.0 

func (_j FlowVersionState) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for FlowVersionState.

func (FlowVersionState) MarshalJSON added in v0.9.0 

func (_j FlowVersionState) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FlowVersionState.

func (FlowVersionState) MarshalText added in v0.9.0 

func (_j FlowVersionState) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for FlowVersionState.

func (FlowVersionState) MarshalYAML added in v0.9.0 

func (_j FlowVersionState) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for FlowVersionState.

func (FlowVersionState) SQLTypeName added in v0.9.0 

func (FlowVersionState) SQLTypeName() string

func (*FlowVersionState) Scan added in v0.9.0 

func (_j *FlowVersionState) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for FlowVersionState.

func (FlowVersionState) String added in v0.9.0 

func (_j FlowVersionState) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern FlowVersionState(%d) instead.

func (*FlowVersionState) UnmarshalBinary added in v0.9.0 

func (_j *FlowVersionState) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalGQL added in v0.9.0 

func (_j *FlowVersionState) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalJSON added in v0.9.0 

func (_j *FlowVersionState) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalText added in v0.9.0 

func (_j *FlowVersionState) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalYAML added in v0.9.0 

func (_j *FlowVersionState) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for FlowVersionState.

func (FlowVersionState) Validate added in v0.9.0 

func (_j FlowVersionState) Validate() error

Validate whether the value is within the range of enum values.

func (FlowVersionState) Values added in v0.9.0 

func (FlowVersionState) Values() []string

Values returns a slice of all String values of the enum.

type FormState added in v0.8.0 

type FormState struct {
	Pristine      bool           `json:"pristine"`
	Dirty         bool           `json:"dirty"`
	Disabled      bool           `json:"disabled"`
	Submitted     bool           `json:"submitted"`
	Valid         bool           `json:"valid"`
	Invalid       bool           `json:"invalid"`
	Submitting    bool           `json:"submitting"`
	Validating    int            `json:"validating"`
	Gathering     int            `json:"gathering"`
	Values        map[string]any `json:"values"`
	MaskedValues  map[string]any `json:"maskedValues"`
	Errors        map[string]any `json:"errors"`
	Touched       map[string]any `json:"touched"`
	Modified      map[string]any `json:"modified"`
	Dirt          map[string]any `json:"dirt"`
	Focused       map[string]any `json:"focused"`
	InitialValues map[string]any `json:"initialValues"`
	Data          map[string]any `json:"data"`
	Memory        map[string]any `json:"memory"`
}

type GetDynamicOptionsInput 

type GetDynamicOptionsInput struct {
	ConnectorName    string                      `json:"connectorName"`
	ConnectorVersion string                      `json:"connectorVersion"`
	FieldName        string                      `json:"fieldName"`
	OperationName    string                      `json:"operationName"`
	StepName         string                      `json:"stepName"`
	FlowID           string                      `json:"flowId"`
	FlowVersionID    string                      `json:"flowVersionId,omitempty"`
	Input            map[string]interface{}      `json:"input,omitempty"`
	Filter           *DynamicOptionsFilterParams `json:"filter,omitempty"`
}

type InternalLogger added in v0.9.0 

type InternalLogger struct {
	// contains filtered or unexported fields
}

InternalLogger provides a centralized interface for managing logs.

func (*InternalLogger) AddLog added in v0.9.0 

func (l *InternalLogger) AddLog(ctx context.Context, level LogLevel, message string)

AddLog adds a log entry to the internal log storage and writes it to the sink (if present).

func (*InternalLogger) ClearLogs added in v0.9.0 

func (l *InternalLogger) ClearLogs()

ClearLogs clears the in-memory logs.

func (*InternalLogger) GetLogs added in v0.9.0 

func (l *InternalLogger) GetLogs() []LogEntry

GetLogs retrieves all stored logs.

func (*InternalLogger) LogDebug added in v0.9.0 

func (l *InternalLogger) LogDebug(ctx context.Context, message string)

func (*InternalLogger) LogError added in v0.9.0 

func (l *InternalLogger) LogError(ctx context.Context, err error)

func (*InternalLogger) LogInfo added in v0.9.0 

func (l *InternalLogger) LogInfo(ctx context.Context, message string)

LogInfo Convenience wrappers for specific log levels

func (*InternalLogger) LogWarning added in v0.9.0 

func (l *InternalLogger) LogWarning(ctx context.Context, message string)

func (*InternalLogger) SetPrefix added in v0.9.0 

func (l *InternalLogger) SetPrefix(prefix string)

SetPrefix sets or updates the prefix for all subsequent logs.

type JSON added in v0.8.0 

type JSON = any

func ToJSON added in v0.9.0 

func ToJSON(input any) (JSON, bool)

ToJSON converts an interface of type `any` to a map[string]any. Returns the map and a boolean indicating success.

type JSONObject 

type JSONObject = map[string]any

JSONObject is a type alias for map[string]any.

func ToJSONMap added in v0.9.0 

func ToJSONMap(input any) (JSONObject, bool)

ToJSONMap converts an interface of type `any` to a map[string]any. Returns the map and a boolean indicating success.

type JobStatus added in v0.2.2 

type JobStatus string
const (
	JobStatusQueued     JobStatus = "queued"
	JobStatusRunning    JobStatus = "running"
	JobStatusCompleted  JobStatus = "completed"
	JobStatusCancelling JobStatus = "cancelling"
	JobStatusCanceled   JobStatus = "canceled"
	JobStatusFailed     JobStatus = "failed"
	JobStatusPaused     JobStatus = "paused"
)

func JobStatusFromString added in v0.2.2 

func JobStatusFromString(raw string) (JobStatus, bool)

JobStatusFromString determines the enum value with an exact case match.

func JobStatusFromStringIgnoreCase added in v0.2.2 

func JobStatusFromStringIgnoreCase(raw string) (JobStatus, bool)

JobStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (JobStatus) IsValid added in v0.2.2 

func (_j JobStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (JobStatus) MarshalBinary added in v0.2.2 

func (_j JobStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for JobStatus.

func (JobStatus) MarshalGQL added in v0.2.2 

func (_j JobStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for JobStatus.

func (JobStatus) MarshalJSON added in v0.2.2 

func (_j JobStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for JobStatus.

func (JobStatus) MarshalText added in v0.2.2 

func (_j JobStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for JobStatus.

func (JobStatus) MarshalYAML added in v0.2.2 

func (_j JobStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for JobStatus.

func (JobStatus) SQLTypeName added in v0.2.2 

func (JobStatus) SQLTypeName() string

func (*JobStatus) Scan added in v0.2.2 

func (_j *JobStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for JobStatus.

func (JobStatus) String added in v0.2.2 

func (_j JobStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern JobStatus(%d) instead.

func (*JobStatus) UnmarshalBinary added in v0.2.2 

func (_j *JobStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalGQL added in v0.2.2 

func (_j *JobStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalJSON added in v0.2.2 

func (_j *JobStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalText added in v0.2.2 

func (_j *JobStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalYAML added in v0.2.2 

func (_j *JobStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for JobStatus.

func (JobStatus) Validate added in v0.2.2 

func (_j JobStatus) Validate() error

Validate whether the value is within the range of enum values.

func (JobStatus) Values added in v0.2.2 

func (JobStatus) Values() []string

Values returns a slice of all String values of the enum.

type Log added in v0.2.7 

type Log struct {
	// contains filtered or unexported fields
}

func NewLog added in v0.2.7 

func NewLog(
	projectID string,
	flowID string,
	stepRunID *string,
	onWrite func(WriteLogLineOpts),
) *Log

func (*Log) Debug added in v0.2.7 

func (b *Log) Debug() *LogBuilder

func (*Log) Error added in v0.2.7 

func (b *Log) Error() *LogBuilder

func (*Log) Info added in v0.2.7 

func (b *Log) Info() *LogBuilder

func (*Log) Warn added in v0.2.7 

func (b *Log) Warn() *LogBuilder

type LogBuilder added in v0.2.7 

type LogBuilder struct {
	// contains filtered or unexported fields
}

func NewLogBuilder added in v0.2.7 

func NewLogBuilder(
	ops *WriteLogLineOpts,
	onWrite func(WriteLogLineOpts),
) *LogBuilder

func (*LogBuilder) Meta added in v0.2.7 

func (b *LogBuilder) Meta(meta map[string]interface{}) *LogBuilder

func (*LogBuilder) Msg added in v0.2.7 

func (b *LogBuilder) Msg(message string)

type LogEntry added in v0.9.0 

type LogEntry struct {
	Timestamp time.Time `json:"timestamp"` // Timestamp of the log
	Level     LogLevel  `json:"level"`     // Severity level of the log
	Message   string    `json:"message"`   // Log message itself
}

LogEntry represents a single log message with a timestamp and level.

type LogLevel 

type LogLevel string

LogLevel represents the severity of a log. 

const (
	LevelInfo    LogLevel = "INFO"
	LevelWarning LogLevel = "WARN"
	LevelError   LogLevel = "ERROR"
	LevelDebug   LogLevel = "DEBUG" // Optional: for verbose debugging messages
)

type LogLine added in v0.2.7 

type LogLine struct {
	// ID of the ent.
	ID xid.ID `json:"id,omitempty"`
	// CreatedAt holds the value of the "created_at" field.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// ProjectID holds the value of the "team_id" field.
	ProjectID xid.ID `json:"project_id,omitempty"`
	// StepRunID holds the value of the "step_run_id" field.
	StepRunID *string `json:"step_run_id,omitempty"`
	// FlowID holds the value of the "step_run_id" field.
	FlowID *string `json:"flow_id,omitempty"`
	// Message holds the value of the "message" field.
	Message string `json:"message,omitempty"`
	// Level holds the value of the "level" field.
	Level LogLineLevel `json:"level,omitempty"`
	// Metadata holds the value of the "metadata" field.
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

LogLine is the model entity for the LogLine schema.

type LogLineLevel added in v0.2.7 

type LogLineLevel string

LogLineLevel represents the kind of job to be started. 

const (
	LogLineLevelDebug LogLineLevel = "DEBUG"
	LogLineLevelInfo  LogLineLevel = "INFO"
	LogLineLevelWarn  LogLineLevel = "WARN"
	LogLineLevelError LogLineLevel = "ERROR"
)

Available job kinds.

func LogLineLevelFromString added in v0.2.7 

func LogLineLevelFromString(raw string) (LogLineLevel, bool)

LogLineLevelFromString determines the enum value with an exact case match.

func LogLineLevelFromStringIgnoreCase added in v0.2.7 

func LogLineLevelFromStringIgnoreCase(raw string) (LogLineLevel, bool)

LogLineLevelFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (LogLineLevel) IsValid added in v0.2.7 

func (_j LogLineLevel) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (LogLineLevel) MarshalBinary added in v0.2.7 

func (_j LogLineLevel) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for LogLineLevel.

func (LogLineLevel) MarshalGQL added in v0.2.7 

func (_j LogLineLevel) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for LogLineLevel.

func (LogLineLevel) MarshalJSON added in v0.2.7 

func (_j LogLineLevel) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for LogLineLevel.

func (LogLineLevel) MarshalText added in v0.2.7 

func (_j LogLineLevel) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for LogLineLevel.

func (LogLineLevel) MarshalYAML added in v0.2.7 

func (_j LogLineLevel) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for LogLineLevel.

func (LogLineLevel) SQLTypeName added in v0.2.7 

func (LogLineLevel) SQLTypeName() string

func (*LogLineLevel) Scan added in v0.2.7 

func (_j *LogLineLevel) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for LogLineLevel.

func (LogLineLevel) String added in v0.2.7 

func (_j LogLineLevel) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern LogLineLevel(%d) instead.

func (*LogLineLevel) UnmarshalBinary added in v0.2.7 

func (_j *LogLineLevel) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalGQL added in v0.2.7 

func (_j *LogLineLevel) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalJSON added in v0.2.7 

func (_j *LogLineLevel) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalText added in v0.2.7 

func (_j *LogLineLevel) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalYAML added in v0.2.7 

func (_j *LogLineLevel) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for LogLineLevel.

func (LogLineLevel) Validate added in v0.2.7 

func (_j LogLineLevel) Validate() error

Validate whether the value is within the range of enum values.

func (LogLineLevel) Values added in v0.2.7 

func (LogLineLevel) Values() []string

Values returns a slice of all String values of the enum.

type LogSink added in v0.9.0 

type LogSink interface {
	Write(ctx context.Context, logEntry LogEntry) error // Write a log entry to the sink
}

LogSink defines an interface for persisting logs to external systems.

type Logger added in v0.9.0 

type Logger interface {
	AddLog(ctx context.Context, level LogLevel, message string)
	SetPrefix(prefix string)
	GetLogs() []LogEntry
	ClearLogs()
	LogInfo(ctx context.Context, message string)
	LogWarning(ctx context.Context, message string)
	LogError(ctx context.Context, err error)
	LogDebug(ctx context.Context, message string)
}

Logger provides a centralized interface for managing logs.

func NewLogger added in v0.9.0 

func NewLogger(sink LogSink, level LogLevel, prefix string) Logger

NewLogger initializes a new Logger instance.

type LogicalCondition added in v0.9.0 

type LogicalCondition struct {
	ID            string             `json:"id"`
	Field         any                `json:"field,omitempty"`
	Operator      LogicalOperator    `json:"operator"`
	Value         any                `json:"value,omitempty"`
	Type          DataType           `json:"type,omitempty"`
	CaseSensitive bool               `json:"caseSensitive,omitempty"`
	Conditions    []LogicalCondition `json:"conditions,omitempty"`
}

LogicalCondition Struct

type LogicalGroup added in v0.9.0 

type LogicalGroup struct {
	ID         string             `json:"id"`
	Operator   Operator           `json:"operator"`
	Conditions []LogicalCondition `json:"conditions"`
}

LogicalGroup Struct

type LogicalOperator added in v0.9.0 

type LogicalOperator string
const (
	LogicalOperatorEqual        LogicalOperator = "EQ"
	LogicalOperatorNotEqual     LogicalOperator = "NEQ"
	LogicalOperatorGreaterThan  LogicalOperator = "GT"
	LogicalOperatorLessThan     LogicalOperator = "LT"
	LogicalOperatorGreaterEqual LogicalOperator = "GTE"
	LogicalOperatorLessEqual    LogicalOperator = "LTE"
	LogicalOperatorAnd          LogicalOperator = "AND"
	LogicalOperatorOr           LogicalOperator = "OR"
	LogicalOperatorNot          LogicalOperator = "NOT"

	LogicalOperatorDateBefore       LogicalOperator = "DATE_BEFORE"
	LogicalOperatorDateAfter        LogicalOperator = "DATE_AFTER"
	LogicalOperatorDateEquals       LogicalOperator = "DATE_EQUALS"
	LogicalOperatorBooleanIsTrue    LogicalOperator = "IS_TRUE"
	LogicalOperatorBooleanIsFalse   LogicalOperator = "IS_FALSE"
	LogicalOperatorStringStartsWith LogicalOperator = "STARTS_WITH"
	LogicalOperatorStringEndsWith   LogicalOperator = "ENDS_WITH"
	LogicalOperatorStringContains   LogicalOperator = "CONTAINS"
	LogicalOperatorArrayContains    LogicalOperator = "ARRAY_CONTAINS"
	LogicalOperatorArrayNotContains LogicalOperator = "ARRAY_NOT_CONTAINS"
)

func LogicalOperatorFromString added in v0.9.0 

func LogicalOperatorFromString(raw string) (LogicalOperator, bool)

LogicalOperatorFromString determines the enum value with an exact case match.

func LogicalOperatorFromStringIgnoreCase added in v0.9.0 

func LogicalOperatorFromStringIgnoreCase(raw string) (LogicalOperator, bool)

LogicalOperatorFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (LogicalOperator) IsValid added in v0.9.0 

func (_j LogicalOperator) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (LogicalOperator) MarshalBinary added in v0.9.0 

func (_j LogicalOperator) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for LogicalOperator.

func (LogicalOperator) MarshalGQL added in v0.9.0 

func (_j LogicalOperator) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for LogicalOperator.

func (LogicalOperator) MarshalJSON added in v0.9.0 

func (_j LogicalOperator) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for LogicalOperator.

func (LogicalOperator) MarshalText added in v0.9.0 

func (_j LogicalOperator) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for LogicalOperator.

func (LogicalOperator) MarshalYAML added in v0.9.0 

func (_j LogicalOperator) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for LogicalOperator.

func (LogicalOperator) SQLTypeName added in v0.9.0 

func (LogicalOperator) SQLTypeName() string

func (*LogicalOperator) Scan added in v0.9.0 

func (_j *LogicalOperator) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for LogicalOperator.

func (LogicalOperator) String added in v0.9.0 

func (_j LogicalOperator) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern LogicalOperator(%d) instead.

func (*LogicalOperator) UnmarshalBinary added in v0.9.0 

func (_j *LogicalOperator) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalGQL added in v0.9.0 

func (_j *LogicalOperator) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalJSON added in v0.9.0 

func (_j *LogicalOperator) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalText added in v0.9.0 

func (_j *LogicalOperator) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalYAML added in v0.9.0 

func (_j *LogicalOperator) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for LogicalOperator.

func (LogicalOperator) Validate added in v0.9.0 

func (_j LogicalOperator) Validate() error

Validate whether the value is within the range of enum values.

func (LogicalOperator) Values added in v0.9.0 

func (LogicalOperator) Values() []string

Values returns a slice of all String values of the enum.

type NodeType added in v0.9.0 

type NodeType string
const (
	NodeTypeBranch      NodeType = "branch"
	NodeTypeBoolean     NodeType = "boolean"
	NodeTypeNormal      NodeType = "normal"
	NodeTypeLoop        NodeType = "loop"
	NodeTypeAction      NodeType = "action"
	NodeTypeConditon    NodeType = "condition"
	NodeTypePlaceholder NodeType = "placeholder"
)

func NodeTypeFromString added in v0.9.0 

func NodeTypeFromString(raw string) (NodeType, bool)

NodeTypeFromString determines the enum value with an exact case match.

func NodeTypeFromStringIgnoreCase added in v0.9.0 

func NodeTypeFromStringIgnoreCase(raw string) (NodeType, bool)

NodeTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (NodeType) IsValid added in v0.9.0 

func (_j NodeType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (NodeType) MarshalBinary added in v0.9.0 

func (_j NodeType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for NodeType.

func (NodeType) MarshalGQL added in v0.9.0 

func (_j NodeType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for NodeType.

func (NodeType) MarshalJSON added in v0.9.0 

func (_j NodeType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for NodeType.

func (NodeType) MarshalText added in v0.9.0 

func (_j NodeType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for NodeType.

func (NodeType) MarshalYAML added in v0.9.0 

func (_j NodeType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for NodeType.

func (NodeType) SQLTypeName added in v0.9.0 

func (NodeType) SQLTypeName() string

func (*NodeType) Scan added in v0.9.0 

func (_j *NodeType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for NodeType.

func (NodeType) String added in v0.9.0 

func (_j NodeType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern NodeType(%d) instead.

func (*NodeType) UnmarshalBinary added in v0.9.0 

func (_j *NodeType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for NodeType.

func (*NodeType) UnmarshalGQL added in v0.9.0 

func (_j *NodeType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for NodeType.

func (*NodeType) UnmarshalJSON added in v0.9.0 

func (_j *NodeType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for NodeType.

func (*NodeType) UnmarshalText added in v0.9.0 

func (_j *NodeType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for NodeType.

func (*NodeType) UnmarshalYAML added in v0.9.0 

func (_j *NodeType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for NodeType.

func (NodeType) Validate added in v0.9.0 

func (_j NodeType) Validate() error

Validate whether the value is within the range of enum values.

func (NodeType) Values added in v0.9.0 

func (NodeType) Values() []string

Values returns a slice of all String values of the enum.

type OauthStrategy 

type OauthStrategy struct {
	ClientID          string            `json:"client_id"`
	ClientSecret      string            `json:"client_secret"`
	RedirectURL       string            `json:"redirect_url"`
	Scopes            []string          `json:"scopes"`
	Endpoint          AuthEndpoint      `json:"endpoint"`
	ResponseType      string            `json:"response_type"`
	GrantType         string            `json:"grant_type"`
	State             string            `json:"state"`
	AuthMethod        string            `json:"auth_method"`
	CodeChallenge     string            `json:"code_challenge"`
	CodeChallengeMath string            `json:"code_challenge_math"`
	PrivateKey        string            `json:"private_key"`
	ExtraParams       map[string]string `json:"extra_params"`
}

type OauthTokenResponse 

type OauthTokenResponse struct {
	AccessToken  string            `json:"access_token,omitempty"`
	TokenType    string            `json:"token_type,omitempty"`
	ExpiresIn    int64             `json:"expires_in,omitempty"`
	RefreshToken string            `json:"refresh_token,omitempty"`
	Scope        string            `json:"scope,omitempty"`
	Extra        map[string]string `json:"extra,omitempty"`
}

type OffsetPaginationMeta added in v0.8.0 

type OffsetPaginationMeta struct {
	Offset     int  `json:"offset"`
	Limit      int  `json:"limit"`
	TotalItems int  `json:"totalItems"`
	HasMore    bool `json:"hasMore"`
}

type OldEventTriggerCriteria added in v0.11.0 

type OldEventTriggerCriteria struct {
	// EventName specifies the name of the event to subscribe to (e.g., "file_uploaded").
	EventName string `json:"eventName" validate:"required"`

	// Source specifies the source of the event (e.g., "system", "integration_name").
	Source string `json:"source" validate:"required"`

	// Filters allow refining event criteria (e.g., event-specific parameters or payload conditions).
	Filters map[string]any `json:"filters,omitempty"`
}

OldEventTriggerCriteria defines trigger criteria based on system or external events.

func NewEventTriggerCriteria added in v0.9.0 

func NewEventTriggerCriteria() *OldEventTriggerCriteria

NewEventTriggerCriteria initializes a new OldEventTriggerCriteria instance with default values applied.

func (*OldEventTriggerCriteria) SetDefaults added in v0.11.0 

func (c *OldEventTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldEventTriggerCriteria.

type OldManualTriggerCriteria added in v0.11.0 

type OldManualTriggerCriteria struct {
	// Description is an optional field to describe the purpose of the manual trigger.
	Description string `json:"description,omitempty"`

	// UserInputSchema defines a schema for the input required when triggering manually.
	UserInputSchema *AutoFormSchema `json:"userInputSchema,omitempty"`

	// RequireApproval specifies if the manual trigger requires prior approval to execute.
	RequireApproval bool `json:"requireApproval"`

	// ExecutionTimeout defines the maximum allowed time for the manual step to be completed.
	ExecutionTimeout *time.Duration `json:"executionTimeout,omitempty"`
}

OldManualTriggerCriteria defines criteria for manually triggered workflows.

func NewManualTriggerCriteria added in v0.9.0 

func NewManualTriggerCriteria() *OldManualTriggerCriteria

NewManualTriggerCriteria creates a new instance of OldManualTriggerCriteria and sets its default values.

func (*OldManualTriggerCriteria) SetDefaults added in v0.11.0 

func (c *OldManualTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldManualTriggerCriteria.

type OldPollingTriggerCriteria added in v0.11.0 

type OldPollingTriggerCriteria struct {
	// Interval defines the duration between each poll (e.g., every 5 minutes).
	Interval time.Duration `json:"interval" validate:"required,gt=0"`

	// MaxRetries specifies the maximum number of retries in case polling fails.
	MaxRetries int `json:"maxRetries,omitempty" validate:"min=0"`

	// FetchLimit defines the maximum number of items to fetch per poll.
	FetchLimit int `json:"fetchLimit,omitempty" validate:"min=1"`

	// DataFilters allows specifying conditions for the data being fetched.
	DataFilters map[string]any `json:"dataFilters,omitempty"`

	// AllowEmptyData determines if polling should proceed without error when no data is returned in a poll.
	AllowEmptyData bool `json:"allowEmptyData"`

	// LastExecutionTime holds the timestamp of the last successful poll, useful for incremental polling.
	LastExecutionTime *time.Time `json:"lastExecutionTime,omitempty"`

	// Enabled determines whether the polling trigger is active.
	Enabled bool `json:"enabled" validate:"required"`

	// ExcludedDays allows specifying days when polling should be skipped (e.g., holidays).
	ExcludedDays []time.Weekday `json:"excludedDays,omitempty"`
}

OldPollingTriggerCriteria defines criteria for a polling-based trigger.

func NewPollingTriggerCriteria added in v0.9.0 

func NewPollingTriggerCriteria() *OldPollingTriggerCriteria

NewPollingTriggerCriteria initializes and returns a new OldPollingTriggerCriteria instance with default values applied.

func (*OldPollingTriggerCriteria) SetDefaults added in v0.11.0 

func (c *OldPollingTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldPollingTriggerCriteria.

type OldRetryPolicy added in v0.11.0 

type OldRetryPolicy struct {
	Enabled bool `json:"enabled" validate:"required"`

	// MaxRetries specifies the maximum number of retry attempts.
	MaxRetries int `json:"maxRetries" validate:"min=0"`

	// RetryInterval defines the time to wait between retry attempts.
	RetryInterval time.Duration `json:"retryInterval" validate:"gt=0"`

	// ExponentialBackoff determines if exponential backoff is used for retries.
	ExponentialBackoff bool `json:"exponentialBackoff"`
}

OldRetryPolicy defines the retry policy for failed event triggers.

func NewRetryPolicy added in v0.9.0 

func NewRetryPolicy() *OldRetryPolicy

NewRetryPolicy creates and returns a new OldRetryPolicy instance with default values applied.

func (*OldRetryPolicy) SetDefaults added in v0.11.0 

func (rp *OldRetryPolicy) SetDefaults()

SetDefaults applies default values for OldRetryPolicy.

type OldScheduleTriggerCriteria added in v0.11.0 

type OldScheduleTriggerCriteria struct {
	// CronExpression specifies the schedule using a cron expression.
	CronExpression string `json:"cronExpression" validate:"required,cron"`

	// StartTime specifies the time to begin the schedule execution.
	StartTime *time.Time `json:"startTime,omitempty"`

	// EndTime specifies the time to stop the schedule execution.
	EndTime *time.Time `json:"endTime,omitempty"`

	// TimeZone allows defining the time zone for the cron schedule.
	TimeZone string `json:"timeZone" validate:"required"`

	// Enabled determines if the schedule trigger is active.
	Enabled bool `json:"enabled" validate:"required"`
}

OldScheduleTriggerCriteria defines trigger criteria for scheduled workflows.

func NewScheduleTriggerCriteria added in v0.9.0 

func NewScheduleTriggerCriteria() *OldScheduleTriggerCriteria

NewScheduleTriggerCriteria creates and initializes a new OldScheduleTriggerCriteria instance with default values applied.

func (*OldScheduleTriggerCriteria) ApplyDefaults added in v0.11.0 

func (c *OldScheduleTriggerCriteria) ApplyDefaults()

ApplyDefaults applies default values to a OldScheduleTriggerCriteria struct.

func (*OldScheduleTriggerCriteria) ScheduledInterval added in v0.11.0 

func (c *OldScheduleTriggerCriteria) ScheduledInterval() time.Duration

ScheduledInterval derives the scheduled interval as a time.Duration based on the cron expression.

type OldTriggerCriteria added in v0.11.0 

type OldTriggerCriteria struct {
	// Polling specifies the configuration used for defining triggers based on polling mechanisms.
	Polling *OldPollingTriggerCriteria `json:"pollingCriteria,omitempty"`

	// Event specifies the conditions that define event-based triggers in the system.
	Event *OldEventTriggerCriteria `json:"eventCriteria,omitempty"`

	// Manual defines the criteria needed for a manual trigger configuration in the system.
	Manual *OldManualTriggerCriteria `json:"manualCriteria,omitempty"`

	// Webhook specifies the conditions required for triggering actions via a webhook.
	Webhook *OldWebhookTriggerCriteria `json:"webhookCriteria,omitempty"`

	// Schedule specifies the criteria for configuring scheduled triggers in the system.
	Schedule *OldScheduleTriggerCriteria `json:"scheduleCriteria,omitempty"`
}

OldTriggerCriteria defines the settings and criteria for configuring step-based triggers in the system.

func NewTriggerCriteria added in v0.9.0 

func NewTriggerCriteria() *OldTriggerCriteria

NewTriggerCriteria creates a new instance of OldTriggerSettings and applies default values using SetDefaults().

func (*OldTriggerCriteria) SetDefaultByType added in v0.11.0 

func (ts *OldTriggerCriteria) SetDefaultByType(strategy TriggerType)

SetDefaultByType applies default values to OldTriggerSettings.

func (*OldTriggerCriteria) SetDefaults added in v0.11.0 

func (ts *OldTriggerCriteria) SetDefaults()

SetDefaults applies default values to OldTriggerSettings.

type OldTriggerSettings added in v0.11.0 

type OldTriggerSettings struct {
	// Type holds the value of the "type" field.
	Type TriggerType `json:"strategy,omitempty" validate:"required,oneof=SCHEDULED EVENT POLLING WEBHOOK MANUAL"`

	// Criteria specifies the configuration settings and conditions for initializing step-based triggers.
	Criteria *OldTriggerCriteria `json:"criteria,omitempty"`

	// RetryPolicy specifies the retry behavior for handling failed event triggers, including limits and intervals.
	RetryPolicy *OldRetryPolicy `json:"retryPolicy,omitempty"`
}

OldTriggerSettings defines the settings and criteria for configuring step-based triggers in the system.

func NewTriggerSettings added in v0.9.0 

func NewTriggerSettings() *OldTriggerSettings

NewTriggerSettings creates a new instance of OldTriggerSettings and applies default values using SetDefaults().

func (*OldTriggerSettings) SetDefaultByType added in v0.11.0 

func (ts *OldTriggerSettings) SetDefaultByType(strategy TriggerType)

SetDefaultByType applies default values to OldTriggerSettings.

func (*OldTriggerSettings) SetDefaults added in v0.11.0 

func (ts *OldTriggerSettings) SetDefaults()

SetDefaults applies default values to OldTriggerSettings.

type OldWebhookTriggerCriteria added in v0.11.0 

type OldWebhookTriggerCriteria struct {
	// Endpoint is the URL where the webhook should listen for incoming requests.
	Endpoint string `json:"endpoint" validate:"required,url"`

	// HttpMethod specifies the HTTP method for the webhook (e.g., POST, GET).
	HttpMethod string `json:"httpMethod" validate:"required,oneof=GET POST PUT DELETE"`

	// AuthEnabled determines if the webhook requires authentication.
	AuthEnabled bool `json:"authEnabled"`

	// Headers specify any required headers that must be included in the webhook requests.
	Headers map[string]string `json:"headers,omitempty"`

	// QueryParams define any required query parameters for validation.
	QueryParams map[string]string `json:"queryParams,omitempty"`

	// ValidationSecret is an optional field for validating webhook requests (e.g., HMAC secret).
	ValidationSecret *string `json:"validationSecret,omitempty"`

	// Enabled determines if the webhook trigger is active.
	Enabled bool `json:"enabled" validate:"required"`
}

OldWebhookTriggerCriteria defines the criteria for triggering via webhook.

func NewWebhookTriggerCriteria added in v0.9.0 

func NewWebhookTriggerCriteria() *OldWebhookTriggerCriteria

NewWebhookTriggerCriteria creates a new instance of OldWebhookTriggerCriteria and initializes default values.

func (*OldWebhookTriggerCriteria) SetDefaults added in v0.11.0 

func (c *OldWebhookTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldWebhookTriggerCriteria.

type OperationAuth added in v0.9.0 

type OperationAuth struct {
	Schema   AutoFormSchema `json:"schema"`
	Required bool           `json:"required"`
	Inherit  bool           `json:"inherit"`
}

type Operator added in v0.9.0 

type Operator string

Operator Enum 

const (
	OperatorAND Operator = "AND"
	OperatorOR  Operator = "OR"
	OperatorXOR Operator = "XOR"
)

func (Operator) MarshalGQL added in v0.9.0 

func (o Operator) MarshalGQL(w io.Writer)

func (Operator) MarshalJSON added in v0.9.0 

func (o Operator) MarshalJSON() ([]byte, error)

func (*Operator) UnmarshalGQL added in v0.9.0 

func (o *Operator) UnmarshalGQL(v interface{}) error

func (*Operator) UnmarshalJSON added in v0.9.0 

func (o *Operator) UnmarshalJSON(data []byte) error

type PauseType 

type PauseType string
const (
	DelayPause   PauseType = "DELAY"
	WebhookPause PauseType = "WEBHOOK"
)

func PauseTypeFromString 

func PauseTypeFromString(raw string) (PauseType, bool)

PauseTypeFromString determines the enum value with an exact case match.

func PauseTypeFromStringIgnoreCase 

func PauseTypeFromStringIgnoreCase(raw string) (PauseType, bool)

PauseTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (PauseType) IsValid 

func (_j PauseType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (PauseType) MarshalBinary 

func (_j PauseType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for PauseType.

func (PauseType) MarshalGQL 

func (_j PauseType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for PauseType.

func (PauseType) MarshalJSON 

func (_j PauseType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for PauseType.

func (PauseType) MarshalText 

func (_j PauseType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for PauseType.

func (PauseType) MarshalYAML 

func (_j PauseType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for PauseType.

func (PauseType) SQLTypeName 

func (PauseType) SQLTypeName() string

func (*PauseType) Scan 

func (_j *PauseType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for PauseType.

func (PauseType) String 

func (_j PauseType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern PauseType(%d) instead.

func (*PauseType) UnmarshalBinary 

func (_j *PauseType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for PauseType.

func (*PauseType) UnmarshalGQL 

func (_j *PauseType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for PauseType.

func (*PauseType) UnmarshalJSON 

func (_j *PauseType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for PauseType.

func (*PauseType) UnmarshalText 

func (_j *PauseType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for PauseType.

func (*PauseType) UnmarshalYAML 

func (_j *PauseType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for PauseType.

func (PauseType) Validate 

func (_j PauseType) Validate() error

Validate whether the value is within the range of enum values.

func (PauseType) Values 

func (PauseType) Values() []string

Values returns a slice of all String values of the enum.

type PluginCompiler added in v0.2.2 

type PluginCompiler string

PluginCompiler enum definition. 

const (
	Wasm   PluginCompiler = "wasm"
	Wasi   PluginCompiler = "wasi"
	Wasix  PluginCompiler = "wasix"
	TinyGo PluginCompiler = "tinygo"
)

func (PluginCompiler) IsValid added in v0.2.2 

func (e PluginCompiler) IsValid() bool

func (PluginCompiler) MarshalGQL added in v0.2.2 

func (e PluginCompiler) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface

func (PluginCompiler) String added in v0.2.2 

func (e PluginCompiler) String() string

func (PluginCompiler) UnmarshalGQL added in v0.2.2 

func (e PluginCompiler) UnmarshalGQL(v interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface

func (PluginCompiler) Values added in v0.2.2 

func (PluginCompiler) Values() (kinds []string)

Values provides list valid values for Enum.

type PluginLanguage added in v0.2.2 

type PluginLanguage string

PluginLanguage enum definition. 

const (
	PluginLanguageRust   PluginLanguage = "rust"
	PluginLanguageGolang PluginLanguage = "golang"
	PluginLanguagePython PluginLanguage = "python"
	PluginLanguageZig    PluginLanguage = "zig"
)

func (PluginLanguage) IsValid added in v0.2.2 

func (e PluginLanguage) IsValid() bool

func (PluginLanguage) MarshalGQL added in v0.2.2 

func (e PluginLanguage) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface

func (PluginLanguage) String added in v0.2.2 

func (e PluginLanguage) String() string

func (PluginLanguage) UnmarshalGQL added in v0.2.2 

func (e PluginLanguage) UnmarshalGQL(v interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface

func (PluginLanguage) Values added in v0.2.2 

func (PluginLanguage) Values() (kinds []string)

Values provides list valid values for Enum.

type PluginMetadata 

type PluginMetadata struct {
	Compiler PluginCompiler `json:"compiler"`
	Language PluginLanguage `json:"language,omitempty"`
}

PluginMetadata is a PluginMetadata model.

type RunModeType 

type RunModeType string
const (
	TriggerRun   RunModeType = "trigger"
	ManualRun    RunModeType = "manual"
	ScheduledRun RunModeType = "schedule"
)

func RunModeTypeFromString 

func RunModeTypeFromString(raw string) (RunModeType, bool)

RunModeTypeFromString determines the enum value with an exact case match.

func RunModeTypeFromStringIgnoreCase 

func RunModeTypeFromStringIgnoreCase(raw string) (RunModeType, bool)

RunModeTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (RunModeType) IsValid 

func (_j RunModeType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (RunModeType) MarshalBinary 

func (_j RunModeType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for RunModeType.

func (RunModeType) MarshalGQL 

func (_j RunModeType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for RunModeType.

func (RunModeType) MarshalJSON 

func (_j RunModeType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for RunModeType.

func (RunModeType) MarshalText 

func (_j RunModeType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for RunModeType.

func (RunModeType) MarshalYAML 

func (_j RunModeType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for RunModeType.

func (RunModeType) SQLTypeName 

func (RunModeType) SQLTypeName() string

func (*RunModeType) Scan 

func (_j *RunModeType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for RunModeType.

func (RunModeType) String 

func (_j RunModeType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern RunModeType(%d) instead.

func (*RunModeType) UnmarshalBinary 

func (_j *RunModeType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for RunModeType.

func (*RunModeType) UnmarshalGQL 

func (_j *RunModeType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for RunModeType.

func (*RunModeType) UnmarshalJSON 

func (_j *RunModeType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for RunModeType.

func (*RunModeType) UnmarshalText 

func (_j *RunModeType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for RunModeType.

func (*RunModeType) UnmarshalYAML 

func (_j *RunModeType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for RunModeType.

func (RunModeType) Validate 

func (_j RunModeType) Validate() error

Validate whether the value is within the range of enum values.

func (RunModeType) Values 

func (RunModeType) Values() []string

Values returns a slice of all String values of the enum.

type SignLog 

type SignLog struct {
	UserAgent string
	At        *time.Time
	IP        string
}

SignLog sign log

type SignLogs 

type SignLogs struct {
	Log         string
	SignInCount uint
	Logs        []SignLog
}

SignLogs record sign in logs

type StateError added in v0.9.0 

type StateError struct {
	Reason  StateErrorReason `json:"reason"`
	Message string           `json:"message"`
	Details JSON             `json:"details,omitempty"`
	Time    time.Time        `json:"time"`
}

type StateErrorReason added in v0.9.0 

type StateErrorReason string
const (
	StateErrorReasonUnknown  StateErrorReason = "UNKNOWN"
	StateErrorReasonTimeout  StateErrorReason = "TIMEOUT"
	StateErrorReasonError    StateErrorReason = "ERROR"
	StateErrorReasonSkipped  StateErrorReason = "SKIPPED"
	StateErrorReasonAborted  StateErrorReason = "ABORTED"
	StateErrorReasonCanceled StateErrorReason = "CANCELED"
)

func StateErrorReasonFromString added in v0.9.0 

func StateErrorReasonFromString(raw string) (StateErrorReason, bool)

StateErrorReasonFromString determines the enum value with an exact case match.

func StateErrorReasonFromStringIgnoreCase added in v0.9.0 

func StateErrorReasonFromStringIgnoreCase(raw string) (StateErrorReason, bool)

StateErrorReasonFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (StateErrorReason) IsValid added in v0.9.0 

func (_j StateErrorReason) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StateErrorReason) MarshalBinary added in v0.9.0 

func (_j StateErrorReason) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for StateErrorReason.

func (StateErrorReason) MarshalGQL added in v0.9.0 

func (_j StateErrorReason) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for StateErrorReason.

func (StateErrorReason) MarshalJSON added in v0.9.0 

func (_j StateErrorReason) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for StateErrorReason.

func (StateErrorReason) MarshalText added in v0.9.0 

func (_j StateErrorReason) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for StateErrorReason.

func (StateErrorReason) MarshalYAML added in v0.9.0 

func (_j StateErrorReason) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for StateErrorReason.

func (StateErrorReason) SQLTypeName added in v0.9.0 

func (StateErrorReason) SQLTypeName() string

func (*StateErrorReason) Scan added in v0.9.0 

func (_j *StateErrorReason) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for StateErrorReason.

func (StateErrorReason) String added in v0.9.0 

func (_j StateErrorReason) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern StateErrorReason(%d) instead.

func (*StateErrorReason) UnmarshalBinary added in v0.9.0 

func (_j *StateErrorReason) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalGQL added in v0.9.0 

func (_j *StateErrorReason) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalJSON added in v0.9.0 

func (_j *StateErrorReason) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalText added in v0.9.0 

func (_j *StateErrorReason) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalYAML added in v0.9.0 

func (_j *StateErrorReason) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for StateErrorReason.

func (StateErrorReason) Validate added in v0.9.0 

func (_j StateErrorReason) Validate() error

Validate whether the value is within the range of enum values.

func (StateErrorReason) Values added in v0.9.0 

func (StateErrorReason) Values() []string

Values returns a slice of all String values of the enum.

type StepErrorSettings 

type StepErrorSettings struct {
	// ContinueOnError of the step
	ContinueOnError bool `json:"continueOnError,omitempty"`

	// RetryOnError of the step
	RetryOnError bool `json:"retryOnError,omitempty"`
}

type StepExecutionParams added in v0.9.0 

type StepExecutionParams struct {
	// Status holds the value of the "status" field.
	Status StepRunStatus `json:"status,omitempty"`
	// Order holds the value of the "order" field.
	Order int `json:"order,omitempty"`
	// Input holds the value of the "input" field.
	Input map[string]interface{} `json:"input,omitempty"`
	// Errors holds the value of the "errors" field.
	Errors []string `json:"errors,omitempty"`
	// Output holds the value of the "output" field.
	Output any `json:"output,omitempty"`
	// StartTime represents the start time of a step run.
	StartTime *time.Time `json:"start_time,omitempty"`
	// EndTime represents the end time of a step run.
	// It is a pointer to a time.Time value and can be nil.
	EndTime *time.Time `json:"end_time,omitempty"`
}

type StepExecutionUpdateParams added in v0.9.0 

type StepExecutionUpdateParams struct {
	// Status holds the value of the "status" field.
	Status *StepRunStatus `json:"status,omitempty"`
	// Errors holds the value of the "errors" field.
	Errors []string `json:"errors,omitempty"`
	// Output holds the value of the "output" field.
	Output any `json:"output,omitempty"`
}

type StepNodeConnector added in v0.9.0 

type StepNodeConnector struct {
	Name    string `json:"name,omitempty"`
	Version string `json:"version,omitempty"`
}

type StepNodeFormInput added in v0.9.0 

type StepNodeFormInput struct {
	State    FormState    `json:"state,omitempty"`
	Input    JSONObject   `json:"input,omitempty"`
	Branches []FlowBranch `json:"branches,omitempty"`
}

StepNodeFormInput represents the input structure for a form node, containing form state and input data.

type StepNodeMeta added in v0.9.0 

type StepNodeMeta struct {
	ConnectorName    string       `json:"connectorName,omitempty"`
	ConnectorVersion string       `json:"connectorVersion,omitempty"`
	TriggerType      *TriggerType `json:"triggerType,omitempty"`
	TriggerStrategy  *TriggerType `json:"triggerStrategy,omitempty"`
}

type StepNodeNodeAuthInput added in v0.9.0 

type StepNodeNodeAuthInput struct {
	ConnectionID *xid.ID `json:"connectionId"`
}

StepNodeNodeAuthInput represents the authentication input for a node in a step, including a connection ID as a UUID.

type StepNodeSettings added in v0.9.0 

type StepNodeSettings struct {
	Branch    *BranchSettings     `json:"branch,omitempty"`
	Connector StepNodeConnector   `json:"connector"`
	Trigger   *OldTriggerSettings `json:"trigger,omitempty"`
	Error     StepErrorSettings   `json:"error,omitempty"`
}

type StepNodeTest added in v0.9.0 

type StepNodeTest struct {
	Results        []StepNodeTestResult `json:"results"`
	LastTestTime   *int                 `json:"lastTestTime"`
	LastTestStatus *TestStatus          `json:"lastTestStatus"`
}

StepNodeTest represents the testing data for a step node. It includes results, last test time, and last test status.

type StepNodeTestResult added in v0.9.0 

type StepNodeTestResult struct {
	Timestamp *int        `json:"timestamp"`
	Status    *TestStatus `json:"status"`
	Output    any         `json:"output"`
}

StepNodeTestResult represents the result of a test at a specific step in a process, including its timestamp, status, and output.

type StepRunStatus added in v0.2.7 

type StepRunStatus string

StepRunStatus represents the status of a step run. 

const (
	StepRunStatusPending   StepRunStatus = "PENDING"
	StepRunStatusPaused    StepRunStatus = "PAUSED"
	StepRunStatusRunning   StepRunStatus = "RUNNING"
	StepRunStatusSucceeded StepRunStatus = "SUCCEEDED"
	StepRunStatusFailed    StepRunStatus = "FAILED"
	StepRunStatusCancelled StepRunStatus = "CANCELLED"
)

Enum values for StepRunStatus.

func StepRunStatusFromString added in v0.2.7 

func StepRunStatusFromString(raw string) (StepRunStatus, bool)

StepRunStatusFromString determines the enum value with an exact case match.

func StepRunStatusFromStringIgnoreCase added in v0.2.7 

func StepRunStatusFromStringIgnoreCase(raw string) (StepRunStatus, bool)

StepRunStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (StepRunStatus) IsValid added in v0.2.7 

func (_j StepRunStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StepRunStatus) MarshalBinary added in v0.2.7 

func (_j StepRunStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for StepRunStatus.

func (StepRunStatus) MarshalGQL added in v0.2.7 

func (_j StepRunStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for StepRunStatus.

func (StepRunStatus) MarshalJSON added in v0.2.7 

func (_j StepRunStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for StepRunStatus.

func (StepRunStatus) MarshalText added in v0.2.7 

func (_j StepRunStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for StepRunStatus.

func (StepRunStatus) MarshalYAML added in v0.2.7 

func (_j StepRunStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for StepRunStatus.

func (StepRunStatus) SQLTypeName added in v0.2.7 

func (StepRunStatus) SQLTypeName() string

func (*StepRunStatus) Scan added in v0.2.7 

func (_j *StepRunStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for StepRunStatus.

func (StepRunStatus) String added in v0.2.7 

func (_j StepRunStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern StepRunStatus(%d) instead.

func (*StepRunStatus) UnmarshalBinary added in v0.2.7 

func (_j *StepRunStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalGQL added in v0.2.7 

func (_j *StepRunStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalJSON added in v0.2.7 

func (_j *StepRunStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalText added in v0.2.7 

func (_j *StepRunStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalYAML added in v0.2.7 

func (_j *StepRunStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for StepRunStatus.

func (StepRunStatus) Validate added in v0.2.7 

func (_j StepRunStatus) Validate() error

Validate whether the value is within the range of enum values.

func (StepRunStatus) Values added in v0.2.7 

func (StepRunStatus) Values() []string

Values returns a slice of all String values of the enum.

type StepType added in v0.2.2 

type StepType string
const (
	StepTypeNormal    StepType = "normal"
	StepTypeBranch    StepType = "branch"
	StepTypeBoolean   StepType = "boolean"
	StepTypeLoop      StepType = "loop"
	StepTypeCondition StepType = "condition"
	StepTypeStart     StepType = "start"
	StepTypeEnd       StepType = "end"
	StepTypeAction    StepType = "action"
)

func StepTypeFromString added in v0.2.2 

func StepTypeFromString(raw string) (StepType, bool)

StepTypeFromString determines the enum value with an exact case match.

func StepTypeFromStringIgnoreCase added in v0.2.2 

func StepTypeFromStringIgnoreCase(raw string) (StepType, bool)

StepTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (StepType) IsValid added in v0.2.2 

func (_j StepType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StepType) MarshalBinary added in v0.2.2 

func (_j StepType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for StepType.

func (StepType) MarshalGQL added in v0.2.2 

func (_j StepType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for StepType.

func (StepType) MarshalJSON added in v0.2.2 

func (_j StepType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for StepType.

func (StepType) MarshalText added in v0.2.2 

func (_j StepType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for StepType.

func (StepType) MarshalYAML added in v0.2.2 

func (_j StepType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for StepType.

func (StepType) SQLTypeName added in v0.2.2 

func (StepType) SQLTypeName() string

func (*StepType) Scan added in v0.2.2 

func (_j *StepType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for StepType.

func (StepType) String added in v0.2.2 

func (_j StepType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern StepType(%d) instead.

func (*StepType) UnmarshalBinary added in v0.2.2 

func (_j *StepType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StepType.

func (*StepType) UnmarshalGQL added in v0.2.2 

func (_j *StepType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for StepType.

func (*StepType) UnmarshalJSON added in v0.2.2 

func (_j *StepType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for StepType.

func (*StepType) UnmarshalText added in v0.2.2 

func (_j *StepType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for StepType.

func (*StepType) UnmarshalYAML added in v0.2.2 

func (_j *StepType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for StepType.

func (StepType) Validate added in v0.2.2 

func (_j StepType) Validate() error

Validate whether the value is within the range of enum values.

func (StepType) Values added in v0.2.2 

func (StepType) Values() []string

Values returns a slice of all String values of the enum.

type StepsRunSnapshot added in v0.2.7 

type StepsRunSnapshot struct {
	// Steps          map[string]*StepState `json:"steps"`
	CurrentStepID  string  `json:"currentStepId"`
	PreviousStepID *string `json:"previousStepId"`
}

type StepsState 

type StepsState struct{}

type SystemActivityLog 

type SystemActivityLog struct {
	Level     LogLevel  `json:"level"`
	Scope     string    `json:"scope"`
	Message   string    `json:"message"`
	Timestamp time.Time `json:"timestamp"`
}

type SystemActivityLogs 

type SystemActivityLogs = []SystemActivityLog

type TaskOperation 

type TaskOperation struct {
	ID          xid.ID         `json:"id"`
	Name        string         `json:"name"`
	Description string         `json:"description"`
	Input       map[string]any `json:"input"`
	Output      map[string]any `json:"output"`
}

TaskOperation is a Task operation type.

type TestFlowStepInput added in v0.9.0 

type TestFlowStepInput struct {
	StepName string `json:"stepName"`
	FlowID   xid.ID `json:"flowId"`
}

type TestStatus 

type TestStatus string
const (
	Fail TestStatus = "fail"
	Pass TestStatus = "pass"
)

func TestStatusFromString 

func TestStatusFromString(raw string) (TestStatus, bool)

TestStatusFromString determines the enum value with an exact case match.

func TestStatusFromStringIgnoreCase 

func TestStatusFromStringIgnoreCase(raw string) (TestStatus, bool)

TestStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (TestStatus) IsValid 

func (_j TestStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (TestStatus) MarshalBinary 

func (_j TestStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for TestStatus.

func (TestStatus) MarshalGQL 

func (_j TestStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for TestStatus.

func (TestStatus) MarshalJSON 

func (_j TestStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for TestStatus.

func (TestStatus) MarshalText 

func (_j TestStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for TestStatus.

func (TestStatus) MarshalYAML 

func (_j TestStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for TestStatus.

func (TestStatus) SQLTypeName 

func (TestStatus) SQLTypeName() string

func (*TestStatus) Scan 

func (_j *TestStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for TestStatus.

func (TestStatus) String 

func (_j TestStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern TestStatus(%d) instead.

func (*TestStatus) UnmarshalBinary 

func (_j *TestStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for TestStatus.

func (*TestStatus) UnmarshalGQL 

func (_j *TestStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for TestStatus.

func (*TestStatus) UnmarshalJSON 

func (_j *TestStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for TestStatus.

func (*TestStatus) UnmarshalText 

func (_j *TestStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for TestStatus.

func (*TestStatus) UnmarshalYAML 

func (_j *TestStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for TestStatus.

func (TestStatus) Validate 

func (_j TestStatus) Validate() error

Validate whether the value is within the range of enum values.

func (TestStatus) Values 

func (TestStatus) Values() []string

Values returns a slice of all String values of the enum.

type Trigger 

type Trigger struct {
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty" validate:"required"`
	Icon string `json:"icon,omitempty"`
	// DisplayName holds the value of the "displayName" field.
	DisplayName string `json:"displayName,omitempty" validate:"required"`
	// Description holds the value of the "description" field.
	Description string `json:"description,omitempty" validate:"required"`
	// HelpText holds the value of the "helpText" field.
	HelpText *string `json:"helpText,omitempty"`
	// Input holds the value of the "input" field.
	Input *AutoFormSchema `json:"input,omitempty"`
	// SampleOutput holds the value of the "sampleOutput" field.
	SampleOutput map[string]any `json:"sampleOutput,omitempty"`
	// Auth holds the value of the "auth" field.
	Auth *OperationAuth `json:"auth,omitempty"`

	// Type holds the value of the "description" field.
	Type TriggerType `json:"type,omitempty" validate:"required,oneof=SCHEDULED EVENT POLLING WEBHOOK"`

	Settings *OldTriggerSettings `json:"settings,omitempty"`

	// Documentation represents the field used to store the connector's documentation in markdown.
	Documentation *string `json:"documentation,omitempty"`
}

Trigger .

type TriggerFlowConfig added in v0.9.0 

type TriggerFlowConfig struct {
	// FlowID of the trigger
	FlowID string `json:"flow_id,omitempty"`
}

type TriggerHookType 

type TriggerHookType string
const (
	TriggerHookTypeRun        TriggerHookType = "RUN"
	TriggerHookTypeTest       TriggerHookType = "TEST"
	TriggerHookTypeOnEnable   TriggerHookType = "ON_ENABLED"
	TriggerHookTypeOnDisabled TriggerHookType = "ON_DISABLED"
	TriggerHookTypeRenew      TriggerHookType = "RENEW"
	TriggerHookTypeOptions    TriggerHookType = "OPTIONS"
)

func TriggerHookTypeFromString 

func TriggerHookTypeFromString(raw string) (TriggerHookType, bool)

TriggerHookTypeFromString determines the enum value with an exact case match.

func TriggerHookTypeFromStringIgnoreCase 

func TriggerHookTypeFromStringIgnoreCase(raw string) (TriggerHookType, bool)

TriggerHookTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (TriggerHookType) IsValid 

func (_j TriggerHookType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (TriggerHookType) MarshalBinary 

func (_j TriggerHookType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for TriggerHookType.

func (TriggerHookType) MarshalGQL 

func (_j TriggerHookType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for TriggerHookType.

func (TriggerHookType) MarshalJSON 

func (_j TriggerHookType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for TriggerHookType.

func (TriggerHookType) MarshalText 

func (_j TriggerHookType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for TriggerHookType.

func (TriggerHookType) MarshalYAML 

func (_j TriggerHookType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for TriggerHookType.

func (TriggerHookType) SQLTypeName 

func (TriggerHookType) SQLTypeName() string

func (*TriggerHookType) Scan 

func (_j *TriggerHookType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for TriggerHookType.

func (TriggerHookType) String 

func (_j TriggerHookType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern TriggerHookType(%d) instead.

func (*TriggerHookType) UnmarshalBinary 

func (_j *TriggerHookType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for TriggerHookType.

func (*TriggerHookType) UnmarshalGQL 

func (_j *TriggerHookType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for TriggerHookType.

func (*TriggerHookType) UnmarshalJSON 

func (_j *TriggerHookType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for TriggerHookType.

func (*TriggerHookType) UnmarshalText 

func (_j *TriggerHookType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for TriggerHookType.

func (*TriggerHookType) UnmarshalYAML 

func (_j *TriggerHookType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for TriggerHookType.

func (TriggerHookType) Validate 

func (_j TriggerHookType) Validate() error

Validate whether the value is within the range of enum values.

func (TriggerHookType) Values 

func (TriggerHookType) Values() []string

Values returns a slice of all String values of the enum.

type TriggerManualConfig 

type TriggerManualConfig struct{}

type TriggerPubSubConfig 

type TriggerPubSubConfig struct {
	// Topic of the pubsub
	Topic string `json:"id,omitempty"`
	// Topic of the pubsub
	Endpoint string `json:"endpoint,omitempty"`
}

type TriggerScheduledConfig 

type TriggerScheduledConfig struct {
	// Field of the step
	RunAt string `json:"runAt,omitempty"`
}

type TriggerType 

type TriggerType string
const (
	TriggerTypeScheduled TriggerType = "SCHEDULED"
	TriggerTypeEvent     TriggerType = "EVENT"
	TriggerTypePolling   TriggerType = "POLLING"
	TriggerTypeWebhook   TriggerType = "WEBHOOK"
	TriggerTypeManual    TriggerType = "MANUAL"
)

func TriggerTypeFromString 

func TriggerTypeFromString(raw string) (TriggerType, bool)

TriggerTypeFromString determines the enum value with an exact case match.

func TriggerTypeFromStringIgnoreCase 

func TriggerTypeFromStringIgnoreCase(raw string) (TriggerType, bool)

TriggerTypeFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (TriggerType) IsValid 

func (_j TriggerType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (TriggerType) MarshalBinary 

func (_j TriggerType) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for TriggerType.

func (TriggerType) MarshalGQL 

func (_j TriggerType) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for TriggerType.

func (TriggerType) MarshalJSON 

func (_j TriggerType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for TriggerType.

func (TriggerType) MarshalText 

func (_j TriggerType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for TriggerType.

func (TriggerType) MarshalYAML 

func (_j TriggerType) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for TriggerType.

func (TriggerType) SQLTypeName 

func (TriggerType) SQLTypeName() string

func (*TriggerType) Scan 

func (_j *TriggerType) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for TriggerType.

func (TriggerType) String 

func (_j TriggerType) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern TriggerType(%d) instead.

func (*TriggerType) UnmarshalBinary 

func (_j *TriggerType) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for TriggerType.

func (*TriggerType) UnmarshalGQL 

func (_j *TriggerType) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for TriggerType.

func (*TriggerType) UnmarshalJSON 

func (_j *TriggerType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for TriggerType.

func (*TriggerType) UnmarshalText 

func (_j *TriggerType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for TriggerType.

func (*TriggerType) UnmarshalYAML 

func (_j *TriggerType) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for TriggerType.

func (TriggerType) Validate 

func (_j TriggerType) Validate() error

Validate whether the value is within the range of enum values.

func (TriggerType) Values 

func (TriggerType) Values() []string

Values returns a slice of all String values of the enum.

type TriggerWebhookConfig 

type TriggerWebhookConfig struct {
	// Endpoint of the trigger
	Endpoint string `json:"endpoint,omitempty"`
}

type Triggers 

type Triggers = map[string]*Trigger

type TriggersList 

type TriggersList = []*Trigger

type WakfloAuthStrategy 

type WakfloAuthStrategy struct{}

type WorkerStatus added in v0.9.0 

type WorkerStatus string
const (
	WorkerStatusActive      WorkerStatus = "ACTIVE"
	WorkerStatusInActive    WorkerStatus = "INACTIVE"
	WorkerStatusFaulted     WorkerStatus = "FAULTED"
	WorkerStatusMaintenance WorkerStatus = "MAINTENANCE"
)

func WorkerStatusFromString added in v0.9.0 

func WorkerStatusFromString(raw string) (WorkerStatus, bool)

WorkerStatusFromString determines the enum value with an exact case match.

func WorkerStatusFromStringIgnoreCase added in v0.9.0 

func WorkerStatusFromStringIgnoreCase(raw string) (WorkerStatus, bool)

WorkerStatusFromStringIgnoreCase determines the enum value with a case-insensitive match.

func (WorkerStatus) IsValid added in v0.9.0 

func (_j WorkerStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (WorkerStatus) MarshalBinary added in v0.9.0 

func (_j WorkerStatus) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface for WorkerStatus.

func (WorkerStatus) MarshalGQL added in v0.9.0 

func (_j WorkerStatus) MarshalGQL(w io.Writer)

MarshalGQL implements the graphql.Marshaler interface for WorkerStatus.

func (WorkerStatus) MarshalJSON added in v0.9.0 

func (_j WorkerStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for WorkerStatus.

func (WorkerStatus) MarshalText added in v0.9.0 

func (_j WorkerStatus) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for WorkerStatus.

func (WorkerStatus) MarshalYAML added in v0.9.0 

func (_j WorkerStatus) MarshalYAML() (interface{}, error)

MarshalYAML implements a YAML Marshaler for WorkerStatus.

func (WorkerStatus) SQLTypeName added in v0.9.0 

func (WorkerStatus) SQLTypeName() string

func (*WorkerStatus) Scan added in v0.9.0 

func (_j *WorkerStatus) Scan(value interface{}) error

Scan implements the sql/driver.Scanner interface for WorkerStatus.

func (WorkerStatus) String added in v0.9.0 

func (_j WorkerStatus) String() string

String returns the string of the enum value. If the enum value is invalid, it will produce a string of the following pattern WorkerStatus(%d) instead.

func (*WorkerStatus) UnmarshalBinary added in v0.9.0 

func (_j *WorkerStatus) UnmarshalBinary(text []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalGQL added in v0.9.0 

func (_j *WorkerStatus) UnmarshalGQL(value interface{}) error

UnmarshalGQL implements the graphql.Unmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalJSON added in v0.9.0 

func (_j *WorkerStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalText added in v0.9.0 

func (_j *WorkerStatus) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalYAML added in v0.9.0 

func (_j *WorkerStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements a YAML Unmarshaler for WorkerStatus.

func (WorkerStatus) Validate added in v0.9.0 

func (_j WorkerStatus) Validate() error

Validate whether the value is within the range of enum values.

func (WorkerStatus) Values added in v0.9.0 

func (WorkerStatus) Values() []string

Values returns a slice of all String values of the enum.

type WorkspacePluginMetadata 

type WorkspacePluginMetadata struct {
	Operations []TaskOperation `json:"properties,omitempty"`
	Compiler   PluginCompiler  `json:"compiler"`
	Language   PluginLanguage  `json:"language,omitempty"`
	// Name holds the value of the "name" field.
	Name string `json:"name,omitempty"`
	// Description holds the value of the "deleted" field.
	Description string `json:"description"`
	// Documentation holds the value of the "documentation" field.
	Documentation *string `json:"documentation"`
	// Description holds the value of the "deleted" field.
	Category string `json:"category"`
	// Version holds the value of the "version" field.
	Version string `json:"version"`
	// Icon holds the value of the "icon" field.
	Icon string `json:"icon"`
}

WorkspacePluginMetadata is a WorkspacePluginMetadata model.

type WriteLogLineOpts added in v0.2.7 

type WriteLogLineOpts struct {
	// The step run id
	ProjectID string `json:"project_id" validate:"required,uuid"`
	// The step run id
	StepRunID *string `json:"step_run_id" validate:"omitnil,uuid"`

	// The flow run id
	FlowID string `json:"flow_id" validate:"uuid"`

	// (optional) The time when the log line was created.
	CreatedAt *time.Time

	// (required) The message of the log line.
	Message string `json:"message" validate:"required,min=1,max=10000"`

	// (optional) The level of the log line.
	Level *string `json:"level" validate:"omitnil,oneof=INFO ERROR WARN DEBUG"`

	// (optional) The metadata of the log line.
	Metadata map[string]any `json:"metadata"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.