oldcore

package
v0.10.4 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 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 

func PrettyPrint(data interface{})

Types

type Action 

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 

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

type ActionType 

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

func ActionTypeFromString 

func ActionTypeFromString(raw string) (ActionType, bool)

ActionTypeFromString determines the enum value with an exact case match.

func ActionTypeFromStringIgnoreCase 

func ActionTypeFromStringIgnoreCase(raw string) (ActionType, bool)

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

func (ActionType) IsValid 

func (_j ActionType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ActionType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for ActionType.

func (ActionType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for ActionType.

func (ActionType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for ActionType.

func (ActionType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for ActionType.

func (ActionType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for ActionType.

func (ActionType) SQLTypeName 

func (ActionType) SQLTypeName() string

func (*ActionType) Scan 

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

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

func (ActionType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ActionType.

func (*ActionType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for ActionType.

func (*ActionType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for ActionType.

func (*ActionType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for ActionType.

func (*ActionType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for ActionType.

func (ActionType) Validate 

func (_j ActionType) Validate() error

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

func (ActionType) Values 

func (ActionType) Values() []string

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

type ActionsList 

type ActionsList = []*Action

type ActionsMap 

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 

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

func (*AuthContext) GetExtra 

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 

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 

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 

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 

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

func BranchExecutionTypeFromString 

func BranchExecutionTypeFromString(raw string) (BranchExecutionType, bool)

BranchExecutionTypeFromString determines the enum value with an exact case match.

func BranchExecutionTypeFromStringIgnoreCase 

func BranchExecutionTypeFromStringIgnoreCase(raw string) (BranchExecutionType, bool)

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

func (BranchExecutionType) IsValid 

func (_j BranchExecutionType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (BranchExecutionType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for BranchExecutionType.

func (BranchExecutionType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for BranchExecutionType.

func (BranchExecutionType) SQLTypeName 

func (BranchExecutionType) SQLTypeName() string

func (*BranchExecutionType) Scan 

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

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

func (BranchExecutionType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for BranchExecutionType.

func (*BranchExecutionType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for BranchExecutionType.

func (BranchExecutionType) Validate 

func (_j BranchExecutionType) Validate() error

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

func (BranchExecutionType) Values 

func (BranchExecutionType) Values() []string

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

type BranchSettings 

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 

func BranchTypeFromString(raw string) (BranchType, bool)

BranchTypeFromString determines the enum value with an exact case match.

func BranchTypeFromStringIgnoreCase 

func BranchTypeFromStringIgnoreCase(raw string) (BranchType, bool)

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

func (BranchType) IsValid 

func (_j BranchType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (BranchType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for BranchType.

func (BranchType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for BranchType.

func (BranchType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for BranchType.

func (BranchType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for BranchType.

func (BranchType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for BranchType.

func (BranchType) SQLTypeName 

func (BranchType) SQLTypeName() string

func (*BranchType) Scan 

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

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

func (BranchType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for BranchType.

func (*BranchType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for BranchType.

func (*BranchType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for BranchType.

func (*BranchType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for BranchType.

func (*BranchType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for BranchType.

func (BranchType) Validate 

func (_j BranchType) Validate() error

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

func (BranchType) Values 

func (BranchType) Values() []string

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

type CodeFramework 

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

func CodeFrameworkFromString 

func CodeFrameworkFromString(raw string) (CodeFramework, bool)

CodeFrameworkFromString determines the enum value with an exact case match.

func CodeFrameworkFromStringIgnoreCase 

func CodeFrameworkFromStringIgnoreCase(raw string) (CodeFramework, bool)

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

func (CodeFramework) IsValid 

func (_j CodeFramework) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (CodeFramework) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for CodeFramework.

func (CodeFramework) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for CodeFramework.

func (CodeFramework) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for CodeFramework.

func (CodeFramework) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for CodeFramework.

func (CodeFramework) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for CodeFramework.

func (CodeFramework) SQLTypeName 

func (CodeFramework) SQLTypeName() string

func (*CodeFramework) Scan 

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

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

func (CodeFramework) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for CodeFramework.

func (*CodeFramework) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for CodeFramework.

func (CodeFramework) Validate 

func (_j CodeFramework) Validate() error

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

func (CodeFramework) Values 

func (CodeFramework) Values() []string

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

type CodeFrameworkProps 

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 

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 

func (_j CodeLanguage) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (CodeLanguage) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for CodeLanguage.

func (CodeLanguage) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for CodeLanguage.

func (CodeLanguage) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for CodeLanguage.

func (CodeLanguage) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for CodeLanguage.

func (CodeLanguage) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for CodeLanguage.

func (CodeLanguage) SQLTypeName 

func (CodeLanguage) SQLTypeName() string

func (*CodeLanguage) Scan 

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

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

func (CodeLanguage) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for CodeLanguage.

func (*CodeLanguage) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for CodeLanguage.

func (CodeLanguage) Validate 

func (_j CodeLanguage) Validate() error

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

func (CodeLanguage) Values 

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 

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

func ConnectorPlatformFromString 

func ConnectorPlatformFromString(raw string) (ConnectorPlatform, bool)

ConnectorPlatformFromString determines the enum value with an exact case match.

func ConnectorPlatformFromStringIgnoreCase 

func ConnectorPlatformFromStringIgnoreCase(raw string) (ConnectorPlatform, bool)

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

func (ConnectorPlatform) IsValid 

func (_j ConnectorPlatform) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ConnectorPlatform) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for ConnectorPlatform.

func (ConnectorPlatform) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for ConnectorPlatform.

func (ConnectorPlatform) SQLTypeName 

func (ConnectorPlatform) SQLTypeName() string

func (*ConnectorPlatform) Scan 

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

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

func (ConnectorPlatform) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for ConnectorPlatform.

func (*ConnectorPlatform) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for ConnectorPlatform.

func (ConnectorPlatform) Validate 

func (_j ConnectorPlatform) Validate() error

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

func (ConnectorPlatform) Values 

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 

type Cursor string

type DataType 

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 

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

func (DataType) MarshalJSON 

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

func (*DataType) UnmarshalGQL 

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

func (*DataType) UnmarshalJSON 

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

type DynamicFieldContext 

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

func NewDynamicFieldContext 

func NewDynamicFieldContext(ctx DynamicFieldContext) *DynamicFieldContext

func (*DynamicFieldContext) GetContext 

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

func (*DynamicFieldContext) Respond 

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

func (*DynamicFieldContext) RespondJSON 

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

type DynamicFieldPaging 

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

type DynamicOptionsFilterParams 

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 

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 

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

func ExecutionModeFromString 

func ExecutionModeFromString(raw string) (ExecutionMode, bool)

ExecutionModeFromString determines the enum value with an exact case match.

func ExecutionModeFromStringIgnoreCase 

func ExecutionModeFromStringIgnoreCase(raw string) (ExecutionMode, bool)

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

func (ExecutionMode) IsValid 

func (_j ExecutionMode) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (ExecutionMode) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for ExecutionMode.

func (ExecutionMode) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for ExecutionMode.

func (ExecutionMode) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for ExecutionMode.

func (ExecutionMode) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for ExecutionMode.

func (ExecutionMode) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for ExecutionMode.

func (ExecutionMode) SQLTypeName 

func (ExecutionMode) SQLTypeName() string

func (*ExecutionMode) Scan 

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

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

func (ExecutionMode) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for ExecutionMode.

func (*ExecutionMode) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for ExecutionMode.

func (ExecutionMode) Validate 

func (_j ExecutionMode) Validate() error

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

func (ExecutionMode) Values 

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 

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

type FlowMetadata 

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 

func (m FlowMetadata) ToSDK()

type FlowRunMetadata 

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 

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 

func FlowRunStatusFromString(raw string) (FlowRunStatus, bool)

FlowRunStatusFromString determines the enum value with an exact case match.

func FlowRunStatusFromStringIgnoreCase 

func FlowRunStatusFromStringIgnoreCase(raw string) (FlowRunStatus, bool)

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

func (FlowRunStatus) IsValid 

func (_j FlowRunStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowRunStatus) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for FlowRunStatus.

func (FlowRunStatus) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for FlowRunStatus.

func (FlowRunStatus) SQLTypeName 

func (FlowRunStatus) SQLTypeName() string

func (*FlowRunStatus) Scan 

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

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

func (FlowRunStatus) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowRunStatus.

func (*FlowRunStatus) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for FlowRunStatus.

func (FlowRunStatus) Validate 

func (_j FlowRunStatus) Validate() error

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

func (FlowRunStatus) Values 

func (FlowRunStatus) Values() []string

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

type FlowSettings 

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

type FlowStatus 

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

func FlowStatusFromString 

func FlowStatusFromString(raw string) (FlowStatus, bool)

FlowStatusFromString determines the enum value with an exact case match.

func FlowStatusFromStringIgnoreCase 

func FlowStatusFromStringIgnoreCase(raw string) (FlowStatus, bool)

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

func (FlowStatus) IsValid 

func (_j FlowStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowStatus) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowStatus.

func (FlowStatus) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for FlowStatus.

func (FlowStatus) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for FlowStatus.

func (FlowStatus) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for FlowStatus.

func (FlowStatus) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for FlowStatus.

func (FlowStatus) SQLTypeName 

func (FlowStatus) SQLTypeName() string

func (*FlowStatus) Scan 

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

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

func (FlowStatus) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowStatus.

func (*FlowStatus) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for FlowStatus.

func (FlowStatus) Validate 

func (_j FlowStatus) Validate() error

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

func (FlowStatus) Values 

func (FlowStatus) Values() []string

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

type FlowStep 

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 

func FlattenSteps(node *FlowStep) []*FlowStep

func GetAllSteps 

func GetAllSteps(step FlowStep) []FlowStep

GetAllSteps Utility function to get all steps in a FlowStep recursively

func GetStep 

func GetStep(name string, flowRoot FlowStep) *FlowStep

GetStep retrieves a step by name in the flow hierarchy

func GetStepOrThrow 

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

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

func TransferStep 

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 

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

func (*FlowStep) FlattenUnsafe 

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

func (*FlowStep) IsFlow 

func (s *FlowStep) IsFlow() bool

func (*FlowStep) IsLoop 

func (s *FlowStep) IsLoop() bool

func (*FlowStep) IsRouter 

func (s *FlowStep) IsRouter() bool

func (*FlowStep) IsTrigger 

func (s *FlowStep) IsTrigger() bool

func (*FlowStep) IsValid 

func (s *FlowStep) IsValid() bool

type FlowStepType 

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

func FlowStepTypeFromString 

func FlowStepTypeFromString(raw string) (FlowStepType, bool)

FlowStepTypeFromString determines the enum value with an exact case match.

func FlowStepTypeFromStringIgnoreCase 

func FlowStepTypeFromStringIgnoreCase(raw string) (FlowStepType, bool)

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

func (FlowStepType) IsValid 

func (_j FlowStepType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowStepType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowStepType.

func (FlowStepType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for FlowStepType.

func (FlowStepType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for FlowStepType.

func (FlowStepType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for FlowStepType.

func (FlowStepType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for FlowStepType.

func (FlowStepType) SQLTypeName 

func (FlowStepType) SQLTypeName() string

func (*FlowStepType) Scan 

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

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

func (FlowStepType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowStepType.

func (*FlowStepType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for FlowStepType.

func (FlowStepType) Validate 

func (_j FlowStepType) Validate() error

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

func (FlowStepType) Values 

func (FlowStepType) Values() []string

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

type FlowTemplate 

type FlowTemplate struct {
	Trigger FlowStep
	State   []int
}

type FlowTemplateType 

type FlowTemplateType = FlowTemplate

type FlowVersion 

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 

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

func FlowVersionStateFromString 

func FlowVersionStateFromString(raw string) (FlowVersionState, bool)

FlowVersionStateFromString determines the enum value with an exact case match.

func FlowVersionStateFromStringIgnoreCase 

func FlowVersionStateFromStringIgnoreCase(raw string) (FlowVersionState, bool)

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

func (FlowVersionState) IsValid 

func (_j FlowVersionState) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (FlowVersionState) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for FlowVersionState.

func (FlowVersionState) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for FlowVersionState.

func (FlowVersionState) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for FlowVersionState.

func (FlowVersionState) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for FlowVersionState.

func (FlowVersionState) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for FlowVersionState.

func (FlowVersionState) SQLTypeName 

func (FlowVersionState) SQLTypeName() string

func (*FlowVersionState) Scan 

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

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

func (FlowVersionState) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for FlowVersionState.

func (*FlowVersionState) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for FlowVersionState.

func (FlowVersionState) Validate 

func (_j FlowVersionState) Validate() error

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

func (FlowVersionState) Values 

func (FlowVersionState) Values() []string

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

type FormState 

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 

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

InternalLogger provides a centralized interface for managing logs.

func (*InternalLogger) AddLog 

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 

func (l *InternalLogger) ClearLogs()

ClearLogs clears the in-memory logs.

func (*InternalLogger) GetLogs 

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

GetLogs retrieves all stored logs.

func (*InternalLogger) LogDebug 

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

func (*InternalLogger) LogError 

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

func (*InternalLogger) LogInfo 

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

LogInfo Convenience wrappers for specific log levels

func (*InternalLogger) LogWarning 

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

func (*InternalLogger) SetPrefix 

func (l *InternalLogger) SetPrefix(prefix string)

SetPrefix sets or updates the prefix for all subsequent logs.

type JSON 

type JSON = any

func ToJSON 

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 

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 

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 

func JobStatusFromString(raw string) (JobStatus, bool)

JobStatusFromString determines the enum value with an exact case match.

func JobStatusFromStringIgnoreCase 

func JobStatusFromStringIgnoreCase(raw string) (JobStatus, bool)

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

func (JobStatus) IsValid 

func (_j JobStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (JobStatus) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for JobStatus.

func (JobStatus) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for JobStatus.

func (JobStatus) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for JobStatus.

func (JobStatus) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for JobStatus.

func (JobStatus) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for JobStatus.

func (JobStatus) SQLTypeName 

func (JobStatus) SQLTypeName() string

func (*JobStatus) Scan 

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

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

func (JobStatus) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for JobStatus.

func (*JobStatus) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for JobStatus.

func (JobStatus) Validate 

func (_j JobStatus) Validate() error

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

func (JobStatus) Values 

func (JobStatus) Values() []string

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

type Log 

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

func NewLog 

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

func (*Log) Debug 

func (b *Log) Debug() *LogBuilder

func (*Log) Error 

func (b *Log) Error() *LogBuilder

func (*Log) Info 

func (b *Log) Info() *LogBuilder

func (*Log) Warn 

func (b *Log) Warn() *LogBuilder

type LogBuilder 

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

func NewLogBuilder 

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

func (*LogBuilder) Meta 

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

func (*LogBuilder) Msg 

func (b *LogBuilder) Msg(message string)

type LogEntry 

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 = "WARNING"
	LevelError   LogLevel = "ERROR"
	LevelDebug   LogLevel = "DEBUG" // Optional: for verbose debugging messages
)

type LogLine 

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 

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 

func LogLineLevelFromString(raw string) (LogLineLevel, bool)

LogLineLevelFromString determines the enum value with an exact case match.

func LogLineLevelFromStringIgnoreCase 

func LogLineLevelFromStringIgnoreCase(raw string) (LogLineLevel, bool)

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

func (LogLineLevel) IsValid 

func (_j LogLineLevel) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (LogLineLevel) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for LogLineLevel.

func (LogLineLevel) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for LogLineLevel.

func (LogLineLevel) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for LogLineLevel.

func (LogLineLevel) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for LogLineLevel.

func (LogLineLevel) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for LogLineLevel.

func (LogLineLevel) SQLTypeName 

func (LogLineLevel) SQLTypeName() string

func (*LogLineLevel) Scan 

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

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

func (LogLineLevel) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for LogLineLevel.

func (*LogLineLevel) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for LogLineLevel.

func (LogLineLevel) Validate 

func (_j LogLineLevel) Validate() error

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

func (LogLineLevel) Values 

func (LogLineLevel) Values() []string

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

type LogSink 

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 

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 

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

NewLogger initializes a new Logger instance.

type LogicalCondition 

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 

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

LogicalGroup Struct

type LogicalOperator 

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 

func LogicalOperatorFromString(raw string) (LogicalOperator, bool)

LogicalOperatorFromString determines the enum value with an exact case match.

func LogicalOperatorFromStringIgnoreCase 

func LogicalOperatorFromStringIgnoreCase(raw string) (LogicalOperator, bool)

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

func (LogicalOperator) IsValid 

func (_j LogicalOperator) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (LogicalOperator) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for LogicalOperator.

func (LogicalOperator) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for LogicalOperator.

func (LogicalOperator) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for LogicalOperator.

func (LogicalOperator) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for LogicalOperator.

func (LogicalOperator) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for LogicalOperator.

func (LogicalOperator) SQLTypeName 

func (LogicalOperator) SQLTypeName() string

func (*LogicalOperator) Scan 

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

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

func (LogicalOperator) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for LogicalOperator.

func (*LogicalOperator) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for LogicalOperator.

func (LogicalOperator) Validate 

func (_j LogicalOperator) Validate() error

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

func (LogicalOperator) Values 

func (LogicalOperator) Values() []string

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

type NodeType 

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 

func NodeTypeFromString(raw string) (NodeType, bool)

NodeTypeFromString determines the enum value with an exact case match.

func NodeTypeFromStringIgnoreCase 

func NodeTypeFromStringIgnoreCase(raw string) (NodeType, bool)

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

func (NodeType) IsValid 

func (_j NodeType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (NodeType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for NodeType.

func (NodeType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for NodeType.

func (NodeType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for NodeType.

func (NodeType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for NodeType.

func (NodeType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for NodeType.

func (NodeType) SQLTypeName 

func (NodeType) SQLTypeName() string

func (*NodeType) Scan 

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

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

func (NodeType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for NodeType.

func (*NodeType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for NodeType.

func (*NodeType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for NodeType.

func (*NodeType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for NodeType.

func (*NodeType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for NodeType.

func (NodeType) Validate 

func (_j NodeType) Validate() error

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

func (NodeType) Values 

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 

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

type OldEventTriggerCriteria 

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 

func NewEventTriggerCriteria() *OldEventTriggerCriteria

NewEventTriggerCriteria initializes a new OldEventTriggerCriteria instance with default values applied.

func (*OldEventTriggerCriteria) SetDefaults 

func (c *OldEventTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldEventTriggerCriteria.

type OldManualTriggerCriteria 

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 

func NewManualTriggerCriteria() *OldManualTriggerCriteria

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

func (*OldManualTriggerCriteria) SetDefaults 

func (c *OldManualTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldManualTriggerCriteria.

type OldPollingTriggerCriteria 

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 

func NewPollingTriggerCriteria() *OldPollingTriggerCriteria

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

func (*OldPollingTriggerCriteria) SetDefaults 

func (c *OldPollingTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldPollingTriggerCriteria.

type OldRetryPolicy 

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 

func NewRetryPolicy() *OldRetryPolicy

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

func (*OldRetryPolicy) SetDefaults 

func (rp *OldRetryPolicy) SetDefaults()

SetDefaults applies default values for OldRetryPolicy.

type OldScheduleTriggerCriteria 

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 

func NewScheduleTriggerCriteria() *OldScheduleTriggerCriteria

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

func (*OldScheduleTriggerCriteria) ApplyDefaults 

func (c *OldScheduleTriggerCriteria) ApplyDefaults()

ApplyDefaults applies default values to a OldScheduleTriggerCriteria struct.

func (*OldScheduleTriggerCriteria) ScheduledInterval 

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

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

type OldTriggerCriteria 

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 

func NewTriggerCriteria() *OldTriggerCriteria

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

func (*OldTriggerCriteria) SetDefaultByType 

func (ts *OldTriggerCriteria) SetDefaultByType(strategy TriggerType)

SetDefaultByType applies default values to OldTriggerSettings.

func (*OldTriggerCriteria) SetDefaults 

func (ts *OldTriggerCriteria) SetDefaults()

SetDefaults applies default values to OldTriggerSettings.

type OldTriggerSettings 

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 

func NewTriggerSettings() *OldTriggerSettings

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

func (*OldTriggerSettings) SetDefaultByType 

func (ts *OldTriggerSettings) SetDefaultByType(strategy TriggerType)

SetDefaultByType applies default values to OldTriggerSettings.

func (*OldTriggerSettings) SetDefaults 

func (ts *OldTriggerSettings) SetDefaults()

SetDefaults applies default values to OldTriggerSettings.

type OldWebhookTriggerCriteria 

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 

func NewWebhookTriggerCriteria() *OldWebhookTriggerCriteria

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

func (*OldWebhookTriggerCriteria) SetDefaults 

func (c *OldWebhookTriggerCriteria) SetDefaults()

SetDefaults applies default values for OldWebhookTriggerCriteria.

type OperationAuth 

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

type Operator 

type Operator string

Operator Enum 

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

func (Operator) MarshalGQL 

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

func (Operator) MarshalJSON 

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

func (*Operator) UnmarshalGQL 

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

func (*Operator) UnmarshalJSON 

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 

type PluginCompiler string

PluginCompiler enum definition. 

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

func (PluginCompiler) IsValid 

func (e PluginCompiler) IsValid() bool

func (PluginCompiler) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface

func (PluginCompiler) String 

func (e PluginCompiler) String() string

func (PluginCompiler) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface

func (PluginCompiler) Values 

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

Values provides list valid values for Enum.

type PluginLanguage 

type PluginLanguage string

PluginLanguage enum definition. 

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

func (PluginLanguage) IsValid 

func (e PluginLanguage) IsValid() bool

func (PluginLanguage) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface

func (PluginLanguage) String 

func (e PluginLanguage) String() string

func (PluginLanguage) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface

func (PluginLanguage) Values 

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 

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

type StateErrorReason 

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

func StateErrorReasonFromString 

func StateErrorReasonFromString(raw string) (StateErrorReason, bool)

StateErrorReasonFromString determines the enum value with an exact case match.

func StateErrorReasonFromStringIgnoreCase 

func StateErrorReasonFromStringIgnoreCase(raw string) (StateErrorReason, bool)

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

func (StateErrorReason) IsValid 

func (_j StateErrorReason) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StateErrorReason) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for StateErrorReason.

func (StateErrorReason) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for StateErrorReason.

func (StateErrorReason) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for StateErrorReason.

func (StateErrorReason) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for StateErrorReason.

func (StateErrorReason) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for StateErrorReason.

func (StateErrorReason) SQLTypeName 

func (StateErrorReason) SQLTypeName() string

func (*StateErrorReason) Scan 

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

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

func (StateErrorReason) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for StateErrorReason.

func (*StateErrorReason) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for StateErrorReason.

func (StateErrorReason) Validate 

func (_j StateErrorReason) Validate() error

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

func (StateErrorReason) Values 

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 

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 

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 

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

type StepNodeFormInput 

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 

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 

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 

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

type StepNodeTest 

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 

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 

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 

func StepRunStatusFromString(raw string) (StepRunStatus, bool)

StepRunStatusFromString determines the enum value with an exact case match.

func StepRunStatusFromStringIgnoreCase 

func StepRunStatusFromStringIgnoreCase(raw string) (StepRunStatus, bool)

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

func (StepRunStatus) IsValid 

func (_j StepRunStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StepRunStatus) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for StepRunStatus.

func (StepRunStatus) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for StepRunStatus.

func (StepRunStatus) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for StepRunStatus.

func (StepRunStatus) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for StepRunStatus.

func (StepRunStatus) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for StepRunStatus.

func (StepRunStatus) SQLTypeName 

func (StepRunStatus) SQLTypeName() string

func (*StepRunStatus) Scan 

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

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

func (StepRunStatus) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for StepRunStatus.

func (*StepRunStatus) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for StepRunStatus.

func (StepRunStatus) Validate 

func (_j StepRunStatus) Validate() error

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

func (StepRunStatus) Values 

func (StepRunStatus) Values() []string

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

type StepType 

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 

func StepTypeFromString(raw string) (StepType, bool)

StepTypeFromString determines the enum value with an exact case match.

func StepTypeFromStringIgnoreCase 

func StepTypeFromStringIgnoreCase(raw string) (StepType, bool)

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

func (StepType) IsValid 

func (_j StepType) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (StepType) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for StepType.

func (StepType) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for StepType.

func (StepType) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for StepType.

func (StepType) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for StepType.

func (StepType) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for StepType.

func (StepType) SQLTypeName 

func (StepType) SQLTypeName() string

func (*StepType) Scan 

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

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

func (StepType) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for StepType.

func (*StepType) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for StepType.

func (*StepType) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for StepType.

func (*StepType) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for StepType.

func (*StepType) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for StepType.

func (StepType) Validate 

func (_j StepType) Validate() error

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

func (StepType) Values 

func (StepType) Values() []string

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

type StepsRunSnapshot 

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 

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 

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 

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

func WorkerStatusFromString 

func WorkerStatusFromString(raw string) (WorkerStatus, bool)

WorkerStatusFromString determines the enum value with an exact case match.

func WorkerStatusFromStringIgnoreCase 

func WorkerStatusFromStringIgnoreCase(raw string) (WorkerStatus, bool)

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

func (WorkerStatus) IsValid 

func (_j WorkerStatus) IsValid() bool

IsValid tests whether the value is a valid enum value.

func (WorkerStatus) MarshalBinary 

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

MarshalBinary implements the encoding.BinaryMarshaler interface for WorkerStatus.

func (WorkerStatus) MarshalGQL 

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

MarshalGQL implements the graphql.Marshaler interface for WorkerStatus.

func (WorkerStatus) MarshalJSON 

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

MarshalJSON implements the json.Marshaler interface for WorkerStatus.

func (WorkerStatus) MarshalText 

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

MarshalText implements the encoding.TextMarshaler interface for WorkerStatus.

func (WorkerStatus) MarshalYAML 

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

MarshalYAML implements a YAML Marshaler for WorkerStatus.

func (WorkerStatus) SQLTypeName 

func (WorkerStatus) SQLTypeName() string

func (*WorkerStatus) Scan 

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

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

func (WorkerStatus) String 

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 

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

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalGQL 

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

UnmarshalGQL implements the graphql.Unmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalText 

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

UnmarshalText implements the encoding.TextUnmarshaler interface for WorkerStatus.

func (*WorkerStatus) UnmarshalYAML 

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

UnmarshalYAML implements a YAML Unmarshaler for WorkerStatus.

func (WorkerStatus) Validate 

func (_j WorkerStatus) Validate() error

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

func (WorkerStatus) Values 

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 

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.