models

Feb 22, 2026

Changes in this version

+ const UserTypeHuman

+ const UserTypeServiceAccount

type User

+ CreatedBy *uuid.UUID

+ Description *string

+ Type string

+ func CreateServiceAccount(tx *gorm.DB, orgID uuid.UUID, name string, description *string, ...) (*User, error)

+ func FindHumanUsersByIDs(ids []string) ([]User, error)

+ func FindServiceAccountsByOrganization(orgID string) ([]User, error)

+ func FindServiceAccountsByOrganizationInTransaction(tx *gorm.DB, orgID string) ([]User, error)

+ func FindUsersByIDs(ids []string) ([]User, error)

+ func (u *User) GetEmail() string

+ func (u *User) IsServiceAccount() bool

Feb 8, 2026

Changes in this version

+ type CanvasNodeReference struct

+ CanvasID uuid.UUID

+ CanvasName string

+ NodeID string

+ NodeName string

type Secret

+ func FindSecretByIDInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, id string) (*Secret, error)

+ func (s *Secret) UpdateName(name string) (*Secret, error)

Feb 1, 2026

Changes in this version

+ const CanvasEventStatePending

+ const CanvasEventStateRouted

+ const CanvasNodeExecutionResultCancelled

+ const CanvasNodeExecutionResultFailed

+ const CanvasNodeExecutionResultPassed

+ const CanvasNodeExecutionResultReasonError

+ const CanvasNodeExecutionResultReasonErrorResolved

+ const CanvasNodeExecutionResultReasonOk

+ const CanvasNodeExecutionStateFinished

+ const CanvasNodeExecutionStatePending

+ const CanvasNodeExecutionStateStarted

+ const CanvasNodeStateError

+ const CanvasNodeStatePaused

+ const CanvasNodeStateProcessing

+ const CanvasNodeStateReady

+ const IntegrationRequestStateCompleted

+ const IntegrationRequestStatePending

+ const IntegrationRequestTypeInvokeAction

+ const IntegrationRequestTypeSync

+ const IntegrationStateError

+ const IntegrationStatePending

+ const IntegrationStateReady

+ func CountCanvasEvents(canvasID uuid.UUID, nodeID string) (int64, error)

+ func CountCanvasesByOrganizationIDs(orgIDs []string) (map[string]int64, error)

+ func CountRootCanvasEvents(canvasID uuid.UUID) (int64, error)

+ func CountRunningExecutionsForNode(workflowID uuid.UUID, nodeID string) (int64, error)

+ func CountRunningExecutionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (int64, error)

+ func CreateNodeExecutionKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string, executionID uuid.UUID, ...) error

+ func DeleteCanvasNode(tx *gorm.DB, node CanvasNode) error

+ func DeleteIntegrationSubscriptionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) error

+ func ResumeStateForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (string, error)

+ type Canvas struct

+ CreatedAt *time.Time

+ CreatedBy *uuid.UUID

+ DeletedAt gorm.DeletedAt

+ Description string

+ Edges datatypes.JSONSlice[Edge]

+ ID uuid.UUID

+ IsTemplate bool

+ Name string

+ Nodes datatypes.JSONSlice[Node]

+ OrganizationID uuid.UUID

+ UpdatedAt *time.Time

+ func FindCanvas(orgID, id uuid.UUID) (*Canvas, error)

+ func FindCanvasByName(name string, organizationID uuid.UUID) (*Canvas, error)

+ func FindCanvasInTransaction(tx *gorm.DB, orgID, id uuid.UUID) (*Canvas, error)

+ func FindCanvasTemplate(id uuid.UUID) (*Canvas, error)

+ func FindCanvasTemplateByName(name string) (*Canvas, error)

+ func FindCanvasTemplateByNameInTransaction(tx *gorm.DB, name string) (*Canvas, error)

+ func FindCanvasTemplateInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

+ func FindCanvasWithoutOrgScope(id uuid.UUID) (*Canvas, error)

+ func FindCanvasWithoutOrgScopeInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

+ func FindUnscopedCanvas(id uuid.UUID) (*Canvas, error)

+ func FindUnscopedCanvasInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

+ func ListCanvases(orgID string, includeTemplates bool) ([]Canvas, error)

+ func ListDeletedCanvases() ([]Canvas, error)

+ func LockCanvas(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

+ func (c *Canvas) FindEdges(sourceID string, channel string) []Edge

+ func (c *Canvas) FindNode(id string) (*CanvasNode, error)

+ func (c *Canvas) SoftDelete() error

+ func (c *Canvas) SoftDeleteInTransaction(tx *gorm.DB) error

+ func (c *Canvas) TableName() string

+ type CanvasEvent struct

+ Channel string

+ CreatedAt *time.Time

+ CustomName *string

+ Data datatypes.JSONType[any]

+ ExecutionID *uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ State string

+ WorkflowID uuid.UUID

+ func FindCanvasEvent(id uuid.UUID) (*CanvasEvent, error)

+ func FindCanvasEventForCanvas(canvasID uuid.UUID, id uuid.UUID) (*CanvasEvent, error)

+ func FindCanvasEventInTransaction(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)

+ func FindCanvasEvents(ids []string) ([]CanvasEvent, error)

+ func FindCanvasEventsForExecutions(executionIDs []string) ([]CanvasEvent, error)

+ func ListCanvasEvents(canvasID uuid.UUID, nodeID string, limit int, before *time.Time) ([]CanvasEvent, error)

+ func ListCanvasEventsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) ([]CanvasEvent, error)

+ func ListPendingCanvasEvents() ([]CanvasEvent, error)

+ func ListRootCanvasEvents(canvasID uuid.UUID, limit int, before *time.Time) ([]CanvasEvent, error)

+ func LockCanvasEvent(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)

+ func (e *CanvasEvent) Routed() error

+ func (e *CanvasEvent) RoutedInTransaction(tx *gorm.DB) error

+ func (e *CanvasEvent) TableName() string

+ type CanvasNode struct

+ AppInstallationID *uuid.UUID

+ Configuration datatypes.JSONType[map[string]any]

+ CreatedAt *time.Time

+ DeletedAt gorm.DeletedAt

+ IsCollapsed bool

+ Metadata datatypes.JSONType[map[string]any]

+ Name string

+ NodeID string

+ ParentNodeID *string

+ Position datatypes.JSONType[Position]

+ Ref datatypes.JSONType[NodeRef]

+ State string

+ StateReason *string

+ Type string

+ UpdatedAt *time.Time

+ WebhookID *uuid.UUID

+ WorkflowID uuid.UUID

+ func FindCanvasNode(tx *gorm.DB, canvasID uuid.UUID, nodeID string) (*CanvasNode, error)

+ func FindCanvasNodes(canvasID uuid.UUID) ([]CanvasNode, error)

+ func FindCanvasNodesByIDs(tx *gorm.DB, canvasID uuid.UUID, nodeIDs []string) ([]CanvasNode, error)

+ func FindCanvasNodesInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)

+ func FindCanvasNodesUnscoped(workflowID uuid.UUID) ([]CanvasNode, error)

+ func FindCanvasNodesUnscopedInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)

+ func ListCanvasNodesReady() ([]CanvasNode, error)

+ func LockCanvasNode(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)

+ func LockCanvasNodeForUpdate(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)

+ func (c *CanvasNode) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

+ func (c *CanvasNode) FirstQueueItem(tx *gorm.DB) (*CanvasNodeQueueItem, error)

+ func (c *CanvasNode) TableName() string

+ func (c *CanvasNode) UpdateState(tx *gorm.DB, state string) error

+ type CanvasNodeExecution struct

+ CancelledBy *uuid.UUID

+ Configuration datatypes.JSONType[map[string]any]

+ CreatedAt *time.Time

+ EventID uuid.UUID

+ ID uuid.UUID

+ Metadata datatypes.JSONType[map[string]any]

+ NodeID string

+ ParentExecutionID *uuid.UUID

+ PreviousExecutionID *uuid.UUID

+ Result string

+ ResultMessage string

+ ResultReason string

+ RootEventID uuid.UUID

+ State string

+ UpdatedAt *time.Time

+ WorkflowID uuid.UUID

+ func LockCanvasNodeExecution(tx *gorm.DB, id uuid.UUID) (*CanvasNodeExecution, error)

+ func (e *CanvasNodeExecution) Cancel(cancelledBy *uuid.UUID) error

+ func (e *CanvasNodeExecution) CancelInTransaction(tx *gorm.DB, cancelledBy *uuid.UUID) error

+ func (e *CanvasNodeExecution) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

+ func (e *CanvasNodeExecution) Fail(reason, message string) error

+ func (e *CanvasNodeExecution) FailInTransaction(tx *gorm.DB, reason, message string) error

+ func (e *CanvasNodeExecution) GetInput(tx *gorm.DB) (any, error)

+ func (e *CanvasNodeExecution) GetOutputs() ([]CanvasEvent, error)

+ func (e *CanvasNodeExecution) GetOutputsInTransaction(tx *gorm.DB) ([]CanvasEvent, error)

+ func (e *CanvasNodeExecution) GetParentExecutionID() string

+ func (e *CanvasNodeExecution) GetPreviousExecutionID() string

+ func (e *CanvasNodeExecution) Pass(outputs map[string][]any) ([]CanvasEvent, error)

+ func (e *CanvasNodeExecution) PassInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]CanvasEvent, error)

+ func (e *CanvasNodeExecution) Start() error

+ func (e *CanvasNodeExecution) StartInTransaction(tx *gorm.DB) error

+ func (e *CanvasNodeExecution) TableName() string

+ type CanvasNodeExecutionKV struct

+ CreatedAt *time.Time

+ ExecutionID uuid.UUID

+ ID uuid.UUID

+ Key string

+ NodeID string

+ Value string

+ WorkflowID uuid.UUID

+ func (c *CanvasNodeExecutionKV) TableName() string

+ type CanvasNodeQueueItem struct

+ CreatedAt *time.Time

+ EventID uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ RootEvent *CanvasEvent

+ RootEventID uuid.UUID

+ WorkflowID uuid.UUID

+ func (i *CanvasNodeQueueItem) Delete(tx *gorm.DB) error

+ func (i *CanvasNodeQueueItem) TableName() string

+ type CanvasNodeRequest struct

+ CreatedAt time.Time

+ ExecutionID *uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ RunAt time.Time

+ Spec datatypes.JSONType[NodeExecutionRequestSpec]

+ State string

+ Type string

+ UpdatedAt time.Time

+ WorkflowID uuid.UUID

+ func (r *CanvasNodeRequest) Complete(tx *gorm.DB) error

+ func (r *CanvasNodeRequest) TableName() string

type Integration

+ AppName string

+ BrowserAction *datatypes.JSONType[BrowserAction]

+ Configuration datatypes.JSONType[map[string]any]

+ DeletedAt gorm.DeletedAt

+ InstallationName string

+ Metadata datatypes.JSONType[map[string]any]

+ OrganizationID uuid.UUID

+ State string

+ StateDescription string

+ func FindIntegration(orgID, integrationID uuid.UUID) (*Integration, error)

+ func FindMaybeDeletedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)

+ func FindUnscopedIntegration(integrationID uuid.UUID) (*Integration, error)

+ func FindUnscopedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)

+ func ListDeletedIntegrations() ([]Integration, error)

+ func LockIntegration(tx *gorm.DB, ID uuid.UUID) (*Integration, error)

+ func (a *Integration) CreateActionRequest(tx *gorm.DB, actionName string, parameters any, runAt *time.Time) error

+ func (a *Integration) CreateSyncRequest(tx *gorm.DB, runAt *time.Time) error

+ func (a *Integration) GetRequest(ID string) (*IntegrationRequest, error)

+ func (a *Integration) ListRequests(reqType string) ([]IntegrationRequest, error)

+ func (a *Integration) SoftDelete() error

+ func (a *Integration) SoftDeleteInTransaction(tx *gorm.DB) error

+ func (a *Integration) TableName() string

+ type IntegrationInvokeAction struct

+ ActionName string

+ Parameters any

+ type IntegrationRequest struct

+ AppInstallationID uuid.UUID

+ CreatedAt time.Time

+ ID uuid.UUID

+ RunAt time.Time

+ Spec datatypes.JSONType[IntegrationRequestSpec]

+ State string

+ Type string

+ UpdatedAt time.Time

+ func FindPendingRequestForIntegration(tx *gorm.DB, installationID uuid.UUID) (*IntegrationRequest, error)

+ func ListIntegrationRequests() ([]IntegrationRequest, error)

+ func LockIntegrationRequest(tx *gorm.DB, id uuid.UUID) (*IntegrationRequest, error)

+ func (r *IntegrationRequest) Complete(tx *gorm.DB) error

+ func (r *IntegrationRequest) TableName() string

+ type IntegrationRequestSpec struct

+ InvokeAction *IntegrationInvokeAction

+ type IntegrationSecret struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ InstallationID uuid.UUID

+ Name string

+ OrganizationID uuid.UUID

+ UpdatedAt *time.Time

+ Value []byte

+ func (a *IntegrationSecret) TableName() string

+ type IntegrationSubscription struct

+ Configuration datatypes.JSONType[any]

+ CreatedAt *time.Time

+ ID uuid.UUID

+ InstallationID uuid.UUID

+ NodeID string

+ UpdatedAt *time.Time

+ WorkflowID uuid.UUID

+ func CreateIntegrationSubscription(node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)

+ func CreateIntegrationSubscriptionInTransaction(tx *gorm.DB, node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)

+ func (a *IntegrationSubscription) TableName() string

type NodeSubscription

+ func ListIntegrationSubscriptions(tx *gorm.DB, installationID uuid.UUID) ([]NodeSubscription, error)

type Webhook

+ func ListIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)

+ func ListUnscopedIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)

type WorkflowNodeReference

+ func ListIntegrationNodeReferences(integrationID uuid.UUID) ([]WorkflowNodeReference, error)

Jan 27, 2026

Changes in this version

type Node

+ IntegrationID *string

Jan 26, 2026

Changes in this version

type Node

+ WarningMessage *string

Jan 24, 2026

Changes in this version

+ const WorkflowNodeExecutionResultReasonErrorResolved

+ func ResolveExecutionErrors(workflowID uuid.UUID, executionIDs []uuid.UUID) error

+ func ResolveExecutionErrorsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) error

type WorkflowNodeExecution

+ func FindNodeExecutionsByIDs(workflowID uuid.UUID, executionIDs []uuid.UUID) ([]WorkflowNodeExecution, error)

+ func FindNodeExecutionsByIDsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) ([]WorkflowNodeExecution, error)

Jan 22, 2026

Changes in this version

+ func GetInstallationID() (string, error)

+ func GetInstallationIDInTransaction(tx *gorm.DB) (string, error)

+ type InstallationMetadata struct

+ CreatedAt time.Time

+ ID int

+ InstallationID string

+ UpdatedAt time.Time

Jan 21, 2026

Changes in this version

+ var TemplateOrganizationID = uuid.Nil

+ func DeleteAppSubscriptionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) error

+ type AppInstallationSubscription struct

+ Configuration datatypes.JSONType[any]

+ CreatedAt *time.Time

+ ID uuid.UUID

+ InstallationID uuid.UUID

+ NodeID string

+ UpdatedAt *time.Time

+ WorkflowID uuid.UUID

+ func CreateAppSubscription(node *WorkflowNode, installation *AppInstallation, configuration any) (*AppInstallationSubscription, error)

+ func CreateAppSubscriptionInTransaction(tx *gorm.DB, node *WorkflowNode, installation *AppInstallation, ...) (*AppInstallationSubscription, error)

+ type NodeSubscription struct

+ Configuration datatypes.JSONType[any]

+ NodeID string

+ NodeRef datatypes.JSONType[NodeRef]

+ NodeType string

+ WorkflowID uuid.UUID

+ func ListAppSubscriptions(tx *gorm.DB, installationID uuid.UUID) ([]NodeSubscription, error)

type Workflow

+ IsTemplate bool

+ func FindWorkflowTemplate(id uuid.UUID) (*Workflow, error)

+ func FindWorkflowTemplateByName(name string) (*Workflow, error)

+ func FindWorkflowTemplateByNameInTransaction(tx *gorm.DB, name string) (*Workflow, error)

+ func FindWorkflowTemplateInTransaction(tx *gorm.DB, id uuid.UUID) (*Workflow, error)

Jan 15, 2026

Changes in this version

+ const EmailProviderSMTP

+ func GenerateNodeID(blockName string, nodeName string) string

+ func GenerateUniqueNodeID(node Node, reservedIDs map[string]bool) string

+ func NodeTypeName(node Node) string

+ func SaveInviteLink(inviteLink *OrganizationInviteLink) error

+ func UpsertEmailSettings(settings *EmailSettings) error

+ func UpsertEmailSettingsInTransaction(tx *gorm.DB, settings *EmailSettings) error

+ type EmailSettings struct

+ CreatedAt time.Time

+ ID uuid.UUID

+ Provider string

+ SMTPFromEmail string

+ SMTPFromName string

+ SMTPHost string

+ SMTPPassword []byte

+ SMTPPort int

+ SMTPUseTLS bool

+ SMTPUsername string

+ UpdatedAt time.Time

+ func FindEmailSettings(provider string) (*EmailSettings, error)

+ func FindEmailSettingsInTransaction(tx *gorm.DB, provider string) (*EmailSettings, error)

+ type OrganizationInviteLink struct

+ CreatedAt time.Time

+ Enabled bool

+ ID uuid.UUID

+ OrganizationID uuid.UUID

+ Token uuid.UUID

+ UpdatedAt time.Time

+ func CreateInviteLink(organizationID uuid.UUID) (*OrganizationInviteLink, error)

+ func CreateInviteLinkInTransaction(tx *gorm.DB, organizationID uuid.UUID) (*OrganizationInviteLink, error)

+ func FindInviteLinkByOrganizationID(organizationID string) (*OrganizationInviteLink, error)

+ func FindInviteLinkByOrganizationIDInTransaction(tx *gorm.DB, organizationID string) (*OrganizationInviteLink, error)

+ func FindInviteLinkByToken(token string) (*OrganizationInviteLink, error)

+ func FindInviteLinkByTokenInTransaction(tx *gorm.DB, token string) (*OrganizationInviteLink, error)

type User

+ func FindMaybeDeletedUserByEmailInTransaction(tx *gorm.DB, orgID, email string) (*User, error)

+ func FindMaybeDeletedUsersByIDs(ids []uuid.UUID) ([]User, error)

+ func ListActiveUsersByID(orgID string, ids []string) ([]User, error)

+ func ListActiveUsersByIDInTransaction(tx *gorm.DB, orgID string, ids []string) ([]User, error)

type WorkflowEvent

+ CustomName *string

+ func ListWorkflowEventsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) ([]WorkflowEvent, error)

type WorkflowNode

+ func FindWorkflowNodesUnscoped(workflowID uuid.UUID) ([]WorkflowNode, error)

+ func FindWorkflowNodesUnscopedInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]WorkflowNode, error)

type WorkflowNodeExecution

+ CancelledBy *uuid.UUID

Jan 8, 2026

Changes in this version

type WorkflowNodeExecution

+ func ListNodeExecutionsForRootEvents(rootEventIDs []uuid.UUID) ([]WorkflowNodeExecution, error)

Jan 6, 2026

Changes in this version

+ const AppInstallationRequestStateCompleted

+ const AppInstallationRequestStatePending

+ const AppInstallationRequestTypeSync

type AppInstallation

+ func (a *AppInstallation) CreateSyncRequest(tx *gorm.DB, runAt *time.Time) error

+ func (a *AppInstallation) GetRequest(ID string) (*AppInstallationRequest, error)

+ func (a *AppInstallation) ListRequests(reqType string) ([]AppInstallationRequest, error)

+ type AppInstallationRequest struct

+ AppInstallationID uuid.UUID

+ CreatedAt time.Time

+ ID uuid.UUID

+ RunAt time.Time

+ State string

+ Type string

+ UpdatedAt time.Time

+ func FindPendingRequestForAppInstallation(tx *gorm.DB, installationID uuid.UUID) (*AppInstallationRequest, error)

+ func ListAppInstallationRequests() ([]AppInstallationRequest, error)

+ func LockAppInstallationRequest(tx *gorm.DB, id uuid.UUID) (*AppInstallationRequest, error)

+ func (r *AppInstallationRequest) Complete(tx *gorm.DB) error

Jan 6, 2026

Changes in this version

+ const WorkflowNodeExecutionResultReasonOk

Jan 6, 2026

Changes in this version

+ const NodeTypeWidget

+ func CountActiveUsersByOrganizationIDs(orgIDs []string) (map[string]int64, error)

+ func CountWorkflowsByOrganizationIDs(orgIDs []string) (map[string]int64, error)

+ type AccountPasswordAuth struct

+ AccountID uuid.UUID

+ CreatedAt time.Time

+ ID uuid.UUID

+ PasswordHash string

+ UpdatedAt time.Time

+ func CreateAccountPasswordAuth(accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)

+ func CreateAccountPasswordAuthInTransaction(tx *gorm.DB, accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)

+ func FindAccountPasswordAuthByAccountID(accountID uuid.UUID) (*AccountPasswordAuth, error)

+ func FindAccountPasswordAuthByAccountIDInTransaction(tx *gorm.DB, accountID uuid.UUID) (*AccountPasswordAuth, error)

+ func (AccountPasswordAuth) TableName() string

+ func (a *AccountPasswordAuth) UpdatePasswordHash(passwordHash string) error

+ func (a *AccountPasswordAuth) UpdatePasswordHashInTransaction(tx *gorm.DB, passwordHash string) error

type NodeRef

+ Widget *WidgetRef

+ type WidgetRef struct

+ Name string

type Workflow

+ Nodes datatypes.JSONSlice[Node]

Dec 28, 2025

Changes in this version

+ const AppInstallationStateError

+ const AppInstallationStatePending

+ const AppInstallationStateReady

+ const DescOrgAdmin

+ const DescOrgOwner

+ const DescOrgViewer

+ const DisplayNameAdmin

+ const DisplayNameOwner

+ const DisplayNameViewer

+ const DomainTypeOrganization

+ const IntegrationAuthTypeOIDC

+ const IntegrationAuthTypeToken

+ const IntegrationTypeGithub

+ const IntegrationTypeSemaphore

+ const InvitationStateAccepted

+ const InvitationStatePending

+ const MetaDescOrgAdmin

+ const MetaDescOrgOwner

+ const MetaDescOrgViewer

+ const NodeExecutionRequestStateCompleted

+ const NodeExecutionRequestStatePending

+ const NodeRequestTypeInvokeAction

+ const NodeTypeBlueprint

+ const NodeTypeComponent

+ const NodeTypeTrigger

+ const ProviderGitHub

+ const ProviderGoogle

+ const RoleOrgAdmin

+ const RoleOrgOwner

+ const RoleOrgViewer

+ const WebhookStateFailed

+ const WebhookStatePending

+ const WebhookStateReady

+ const WorkflowEventStatePending

+ const WorkflowEventStateRouted

+ const WorkflowNodeExecutionResultCancelled

+ const WorkflowNodeExecutionResultFailed

+ const WorkflowNodeExecutionResultPassed

+ const WorkflowNodeExecutionResultReasonError

+ const WorkflowNodeExecutionStateFinished

+ const WorkflowNodeExecutionStatePending

+ const WorkflowNodeExecutionStateStarted

+ const WorkflowNodeStateError

+ const WorkflowNodeStateProcessing

+ const WorkflowNodeStateReady

+ var ErrInvitationAlreadyExists = fmt.Errorf("invitation already exists")

+ var ErrNameAlreadyUsed = fmt.Errorf("name already used")

+ func CountNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string) (int64, error)

+ func CountNodeQueueItems(workflowID uuid.UUID, nodeID string) (int64, error)

+ func CountRootWorkflowEvents(workflowID uuid.UUID) (int64, error)

+ func CountWorkflowEvents(workflowID uuid.UUID, nodeID string) (int64, error)

+ func CreateWorkflowNodeExecutionKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string, executionID uuid.UUID, ...) error

+ func DeleteGroupMetadata(groupName, domainType, domainID string) error

+ func DeleteGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID string) error

+ func DeleteMetadataForOrganization(tx *gorm.DB, domainType, domainID string) error

+ func DeleteRoleMetadata(roleName, domainType, domainID string) error

+ func DeleteRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID string) error

+ func DeleteWorkflowNode(tx *gorm.DB, node WorkflowNode) error

+ func FindRoleMetadataByNames(roleNames []string, domainType, domainID string) (map[string]*RoleMetadata, error)

+ func FormatDomain(domainType, domainID string) string

+ func GetActiveOrganizationIDs() ([]string, error)

+ func HardDeleteOrganization(id string) error

+ func PrefixGroup(groupName string) string

+ func PrefixRole(role string) string

+ func PrefixUser(userID string) string

+ func SaveInvitation(invitation *OrganizationInvitation) error

+ func SoftDeleteOrganization(id string) error

+ func SoftDeleteOrganizationInTransaction(tx *gorm.DB, id string) error

+ func UpsertGroupMetadata(groupName, domainType, domainID, displayName, description string) error

+ func UpsertGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID, displayName, description string) error

+ func UpsertRoleMetadata(roleName, domainType, domainID, displayName, description string) error

+ func UpsertRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID, displayName, description string) error

+ func ValidateDomainType(domainType string) error

+ type Account struct

+ Email string

+ ID uuid.UUID

+ Name string

+ func CreateAccount(name, email string) (*Account, error)

+ func CreateAccountInTransaction(tx *gorm.DB, name, email string) (*Account, error)

+ func FindAccountByEmail(email string) (*Account, error)

+ func FindAccountByID(id string) (*Account, error)

+ func FindAccountByProvider(provider, providerID string) (*Account, error)

+ func (a *Account) FindAccountProviderByID(provider, providerID string) (*AccountProvider, error)

+ func (a *Account) FindPendingInvitations() ([]OrganizationInvitation, error)

+ func (a *Account) GetAccountProvider(provider string) (*AccountProvider, error)

+ func (a *Account) GetAccountProviders() ([]AccountProvider, error)

+ func (a *Account) UpdateEmail(newEmail string) error

+ func (a *Account) UpdateEmailForProvider(newEmail, provider, providerID string) error

+ type AccountProvider struct

+ AccessToken string

+ AccountID uuid.UUID

+ AvatarURL string

+ CreatedAt time.Time

+ Email string

+ ID uuid.UUID

+ Name string

+ Provider string

+ ProviderID string

+ RefreshToken string

+ TokenExpiresAt *time.Time

+ UpdatedAt time.Time

+ Username string

+ type AppInstallation struct

+ AppName string

+ BrowserAction *datatypes.JSONType[BrowserAction]

+ Configuration datatypes.JSONType[map[string]any]

+ CreatedAt *time.Time

+ DeletedAt gorm.DeletedAt

+ ID uuid.UUID

+ InstallationName string

+ Metadata datatypes.JSONType[map[string]any]

+ OrganizationID uuid.UUID

+ State string

+ StateDescription string

+ UpdatedAt *time.Time

+ func CreateAppInstallation(id, orgID uuid.UUID, appName string, installationName string, ...) (*AppInstallation, error)

+ func FindAppInstallation(orgID, installationID uuid.UUID) (*AppInstallation, error)

+ func FindAppInstallationByName(orgID uuid.UUID, installationName string) (*AppInstallation, error)

+ func FindMaybeDeletedInstallationInTransaction(tx *gorm.DB, installationID uuid.UUID) (*AppInstallation, error)

+ func FindUnscopedAppInstallation(installationID uuid.UUID) (*AppInstallation, error)

+ func FindUnscopedAppInstallationInTransaction(tx *gorm.DB, installationID uuid.UUID) (*AppInstallation, error)

+ func ListAppInstallations(orgID uuid.UUID) ([]AppInstallation, error)

+ func ListDeletedAppInstallations() ([]AppInstallation, error)

+ func LockAppInstallation(tx *gorm.DB, ID uuid.UUID) (*AppInstallation, error)

+ func (a *AppInstallation) SoftDelete() error

+ func (a *AppInstallation) SoftDeleteInTransaction(tx *gorm.DB) error

+ type AppInstallationSecret struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ InstallationID uuid.UUID

+ Name string

+ OrganizationID uuid.UUID

+ UpdatedAt *time.Time

+ Value []byte

+ type Blueprint struct

+ Color string

+ Configuration datatypes.JSONSlice[configuration.Field]

+ CreatedAt *time.Time

+ CreatedBy *uuid.UUID

+ Description string

+ Edges datatypes.JSONSlice[Edge]

+ ID uuid.UUID

+ Icon string

+ Name string

+ Nodes datatypes.JSONSlice[Node]

+ OrganizationID uuid.UUID

+ OutputChannels datatypes.JSONSlice[BlueprintOutputChannel]

+ UpdatedAt *time.Time

+ func FindBlueprint(orgID, id string) (*Blueprint, error)

+ func FindBlueprintByName(name string, orgID uuid.UUID) (*Blueprint, error)

+ func FindUnscopedBlueprint(id string) (*Blueprint, error)

+ func FindUnscopedBlueprintInTransaction(tx *gorm.DB, id string) (*Blueprint, error)

+ func (b *Blueprint) FindEdges(sourceID string, channel string) []Edge

+ func (b *Blueprint) FindNode(id string) (*Node, error)

+ func (b *Blueprint) FindRootNode() *Node

+ type BlueprintOutputChannel struct

+ Name string

+ NodeID string

+ NodeOutputChannel string

+ type BlueprintRef struct

+ ID string

+ type BrowserAction struct

+ Description string

+ FormFields map[string]string

+ Method string

+ URL string

+ type ComponentRef struct

+ Name string

+ type Edge struct

+ Channel string

+ SourceID string

+ TargetID string

+ type GroupMetadata struct

+ CreatedAt time.Time

+ Description string

+ DisplayName string

+ DomainID string

+ DomainType string

+ GroupName string

+ ID uuid.UUID

+ UpdatedAt time.Time

+ func FindGroupMetadata(groupName, domainType, domainID string) (*GroupMetadata, error)

+ func (gm *GroupMetadata) BeforeCreate(tx *gorm.DB) error

+ func (gm *GroupMetadata) Create() error

+ func (gm *GroupMetadata) CreateInTransaction(tx *gorm.DB) error

+ func (gm *GroupMetadata) Update() error

+ func (gm *GroupMetadata) UpdateInTransaction(tx *gorm.DB) error

+ type Integration struct

+ Auth datatypes.JSONType[IntegrationAuth]

+ AuthType string

+ CreatedAt *time.Time

+ CreatedBy uuid.UUID

+ DomainID uuid.UUID

+ DomainType string

+ ID uuid.UUID

+ Name string

+ Type string

+ URL string

+ UpdatedAt *time.Time

+ func CreateIntegration(integration *Integration) (*Integration, error)

+ func FindDomainIntegration(domainType string, domainID uuid.UUID, id uuid.UUID) (*Integration, error)

+ func FindIntegrationByIDInTransaction(tx *gorm.DB, id uuid.UUID) (*Integration, error)

+ func FindIntegrationByName(domainType string, domainID uuid.UUID, name string) (*Integration, error)

+ func ListIntegrations(domainType string, domainID uuid.UUID) ([]*Integration, error)

+ func (i *Integration) Update() error

+ type IntegrationAuth struct

+ Token *IntegrationAuthToken

+ type IntegrationAuthToken struct

+ ValueFrom ValueDefinitionFrom

+ type IntegrationResource struct

+ DomainType string

+ IntegrationName string

+ Name string

+ Type string

+ type InvokeAction struct

+ ActionName string

+ Parameters map[string]any

+ type Node struct

+ AppInstallationID *string

+ Configuration map[string]any

+ ErrorMessage *string

+ ID string

+ IsCollapsed bool

+ Metadata map[string]any

+ Name string

+ Position Position

+ Ref NodeRef

+ Type string

+ type NodeExecutionRequestSpec struct

+ InvokeAction *InvokeAction

+ type NodeRef struct

+ Blueprint *BlueprintRef

+ Component *ComponentRef

+ Trigger *TriggerRef

+ type Organization struct

+ AllowedProviders datatypes.JSONSlice[string]

+ CreatedAt *time.Time

+ DeletedAt gorm.DeletedAt

+ Description string

+ ID uuid.UUID

+ Name string

+ UpdatedAt *time.Time

+ func CreateOrganization(name, description string) (*Organization, error)

+ func CreateOrganizationInTransaction(tx *gorm.DB, name, description string) (*Organization, error)

+ func FindOrganizationByID(id string) (*Organization, error)

+ func FindOrganizationByName(name string) (*Organization, error)

+ func FindOrganizationsForAccount(email string) ([]Organization, error)

+ func ListOrganizationsByIDs(ids []string) ([]Organization, error)

+ func (o *Organization) IsProviderAllowed(provider string) bool

+ type OrganizationInvitation struct

+ CreatedAt time.Time

+ Email string

+ ID uuid.UUID

+ InvitedBy uuid.UUID

+ OrganizationID uuid.UUID

+ State string

+ UpdatedAt time.Time

+ func CreateInvitation(organizationID, invitedBy uuid.UUID, email, state string) (*OrganizationInvitation, error)

+ func CreateInvitationInTransaction(tx *gorm.DB, organizationID, invitedBy uuid.UUID, email, state string) (*OrganizationInvitation, error)

+ func FindInvitationByID(invitationID string) (*OrganizationInvitation, error)

+ func FindInvitationByIDWithState(invitationID string, state string) (*OrganizationInvitation, error)

+ func FindPendingInvitation(email, organizationID string) (*OrganizationInvitation, error)

+ func FindPendingInvitationInTransaction(tx *gorm.DB, email, organizationID string) (*OrganizationInvitation, error)

+ func ListInvitationsInState(organizationID string, state string) ([]OrganizationInvitation, error)

+ func (i *OrganizationInvitation) Delete() error

+ type Position struct

+ X int

+ Y int

+ type RoleMetadata struct

+ CreatedAt time.Time

+ Description string

+ DisplayName string

+ DomainID string

+ DomainType string

+ ID uuid.UUID

+ RoleName string

+ UpdatedAt time.Time

+ func FindRoleMetadata(roleName, domainType, domainID string) (*RoleMetadata, error)

+ func (rm *RoleMetadata) BeforeCreate(tx *gorm.DB) error

+ func (rm *RoleMetadata) Create() error

+ func (rm *RoleMetadata) CreateInTransaction(tx *gorm.DB) error

+ func (rm *RoleMetadata) Update() error

+ func (rm *RoleMetadata) UpdateInTransaction(tx *gorm.DB) error

+ type Secret struct

+ CreatedAt *time.Time

+ CreatedBy uuid.UUID

+ Data []byte

+ DomainID uuid.UUID

+ DomainType string

+ ID uuid.UUID

+ Name string

+ Provider string

+ UpdatedAt *time.Time

+ func CreateSecret(name, provider, requesterID, domainType string, domainID uuid.UUID, ...) (*Secret, error)

+ func FindSecretByID(domainType string, domainID uuid.UUID, id string) (*Secret, error)

+ func FindSecretByName(domainType string, domainID uuid.UUID, name string) (*Secret, error)

+ func FindSecretByNameInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, name string) (*Secret, error)

+ func ListSecrets(domainType string, domainID uuid.UUID) ([]Secret, error)

+ func (s *Secret) Delete() error

+ func (s *Secret) UpdateData(data []byte) (*Secret, error)

+ type SecretData struct

+ Local map[string]string

+ type TriggerRef struct

+ Name string

+ type User struct

+ AccountID uuid.UUID

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Email string

+ ID uuid.UUID

+ Name string

+ OrganizationID uuid.UUID

+ TokenHash string

+ UpdatedAt time.Time

+ func CreateUser(orgID, accountID uuid.UUID, email, name string) (*User, error)

+ func CreateUserInTransaction(tx *gorm.DB, orgID, accountID uuid.UUID, email, name string) (*User, error)

+ func FindActiveUserByEmail(orgID, email string) (*User, error)

+ func FindActiveUserByID(orgID, id string) (*User, error)

+ func FindActiveUserByIDInTransaction(tx *gorm.DB, orgID, id string) (*User, error)

+ func FindActiveUserByTokenHash(tokenHash string) (*User, error)

+ func FindAnyUserByEmail(email string) (*User, error)

+ func FindMaybeDeletedUserByEmail(orgID, email string) (*User, error)

+ func FindMaybeDeletedUserByID(orgID, id string) (*User, error)

+ func FindUnscopedUserByID(id string) (*User, error)

+ func (u *User) Delete() error

+ func (u *User) Restore() error

+ func (u *User) RestoreInTransaction(tx *gorm.DB) error

+ func (u *User) UpdateTokenHash(tokenHash string) error

+ type ValueDefinitionFrom struct

+ Secret *ValueDefinitionFromSecret

+ type ValueDefinitionFromSecret struct

+ Key string

+ Name string

+ type Webhook struct

+ AppInstallationID *uuid.UUID

+ Configuration datatypes.JSONType[any]

+ CreatedAt *time.Time

+ DeletedAt gorm.DeletedAt

+ ID uuid.UUID

+ IntegrationID *uuid.UUID

+ MaxRetries int

+ Metadata datatypes.JSONType[any]

+ Resource datatypes.JSONType[WebhookResource]

+ RetryCount int

+ Secret []byte

+ State string

+ UpdatedAt *time.Time

+ func FindWebhook(id uuid.UUID) (*Webhook, error)

+ func FindWebhookInTransaction(tx *gorm.DB, id uuid.UUID) (*Webhook, error)

+ func ListAppInstallationWebhooks(tx *gorm.DB, installationID uuid.UUID) ([]Webhook, error)

+ func ListDeletedWebhooks() ([]Webhook, error)

+ func ListPendingWebhooks() ([]Webhook, error)

+ func ListUnscopedAppInstallationWebhooks(tx *gorm.DB, installationID uuid.UUID) ([]Webhook, error)

+ func LockWebhook(tx *gorm.DB, ID uuid.UUID) (*Webhook, error)

+ func (w *Webhook) HasExceededRetries() bool

+ func (w *Webhook) IncrementRetry(tx *gorm.DB) error

+ func (w *Webhook) MarkFailed(tx *gorm.DB) error

+ func (w *Webhook) Ready(tx *gorm.DB) error

+ func (w *Webhook) ReadyWithMetadata(tx *gorm.DB, metadata any) error

+ type WebhookResource struct

+ ID string

+ Name string

+ Type string

+ type Workflow struct

+ CreatedAt *time.Time

+ CreatedBy *uuid.UUID

+ DeletedAt gorm.DeletedAt

+ Description string

+ Edges datatypes.JSONSlice[Edge]

+ ID uuid.UUID

+ Name string

+ OrganizationID uuid.UUID

+ UpdatedAt *time.Time

+ func FindUnscopedWorkflow(id uuid.UUID) (*Workflow, error)

+ func FindUnscopedWorkflowInTransaction(tx *gorm.DB, id uuid.UUID) (*Workflow, error)

+ func FindWorkflow(orgID, id uuid.UUID) (*Workflow, error)

+ func FindWorkflowByName(name string, organizationID uuid.UUID) (*Workflow, error)

+ func FindWorkflowInTransaction(tx *gorm.DB, orgID, id uuid.UUID) (*Workflow, error)

+ func FindWorkflowWithoutOrgScope(id uuid.UUID) (*Workflow, error)

+ func FindWorkflowWithoutOrgScopeInTransaction(tx *gorm.DB, id uuid.UUID) (*Workflow, error)

+ func ListDeletedWorkflows() ([]Workflow, error)

+ func ListWorkflows(orgID string) ([]Workflow, error)

+ func LockWorkflow(tx *gorm.DB, id uuid.UUID) (*Workflow, error)

+ func (w *Workflow) FindEdges(sourceID string, channel string) []Edge

+ func (w *Workflow) FindNode(id string) (*WorkflowNode, error)

+ func (w *Workflow) SoftDelete() error

+ func (w *Workflow) SoftDeleteInTransaction(tx *gorm.DB) error

+ type WorkflowEvent struct

+ Channel string

+ CreatedAt *time.Time

+ Data datatypes.JSONType[any]

+ ExecutionID *uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ State string

+ WorkflowID uuid.UUID

+ func FindLastEventPerNode(workflowID uuid.UUID) ([]WorkflowEvent, error)

+ func FindWorkflowEvent(id uuid.UUID) (*WorkflowEvent, error)

+ func FindWorkflowEventForWorkflow(workflowID uuid.UUID, id uuid.UUID) (*WorkflowEvent, error)

+ func FindWorkflowEventInTransaction(tx *gorm.DB, id uuid.UUID) (*WorkflowEvent, error)

+ func FindWorkflowEvents(ids []string) ([]WorkflowEvent, error)

+ func FindWorkflowEventsForExecutions(executionIDs []string) ([]WorkflowEvent, error)

+ func ListPendingWorkflowEvents() ([]WorkflowEvent, error)

+ func ListRootWorkflowEvents(workflowID uuid.UUID, limit int, before *time.Time) ([]WorkflowEvent, error)

+ func ListWorkflowEvents(workflowID uuid.UUID, nodeID string, limit int, before *time.Time) ([]WorkflowEvent, error)

+ func LockWorkflowEvent(tx *gorm.DB, id uuid.UUID) (*WorkflowEvent, error)

+ func (e *WorkflowEvent) Routed() error

+ func (e *WorkflowEvent) RoutedInTransaction(tx *gorm.DB) error

+ type WorkflowNode struct

+ AppInstallationID *uuid.UUID

+ Configuration datatypes.JSONType[map[string]any]

+ CreatedAt *time.Time

+ DeletedAt gorm.DeletedAt

+ IsCollapsed bool

+ Metadata datatypes.JSONType[map[string]any]

+ Name string

+ NodeID string

+ ParentNodeID *string

+ Position datatypes.JSONType[Position]

+ Ref datatypes.JSONType[NodeRef]

+ State string

+ StateReason *string

+ Type string

+ UpdatedAt *time.Time

+ WebhookID *uuid.UUID

+ WorkflowID uuid.UUID

+ func FindWebhookNodes(webhookID uuid.UUID) ([]WorkflowNode, error)

+ func FindWebhookNodesInTransaction(tx *gorm.DB, webhookID uuid.UUID) ([]WorkflowNode, error)

+ func FindWorkflowNode(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (*WorkflowNode, error)

+ func FindWorkflowNodes(workflowID uuid.UUID) ([]WorkflowNode, error)

+ func FindWorkflowNodesByIDs(tx *gorm.DB, workflowID uuid.UUID, nodeIDs []string) ([]WorkflowNode, error)

+ func FindWorkflowNodesInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]WorkflowNode, error)

+ func ListReadyTriggers() ([]WorkflowNode, error)

+ func ListWorkflowNodesReady() ([]WorkflowNode, error)

+ func LockWorkflowNode(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*WorkflowNode, error)

+ func (w *WorkflowNode) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

+ func (w *WorkflowNode) FirstQueueItem(tx *gorm.DB) (*WorkflowNodeQueueItem, error)

+ func (w *WorkflowNode) UpdateState(tx *gorm.DB, state string) error

+ type WorkflowNodeExecution struct

+ Configuration datatypes.JSONType[map[string]any]

+ CreatedAt *time.Time

+ EventID uuid.UUID

+ ID uuid.UUID

+ Metadata datatypes.JSONType[map[string]any]

+ NodeID string

+ ParentExecutionID *uuid.UUID

+ PreviousExecutionID *uuid.UUID

+ Result string

+ ResultMessage string

+ ResultReason string

+ RootEventID uuid.UUID

+ State string

+ UpdatedAt *time.Time

+ WorkflowID uuid.UUID

+ func CreatePendingChildExecution(tx *gorm.DB, parent *WorkflowNodeExecution, childNodeID string, ...) (*WorkflowNodeExecution, error)

+ func FindChildExecutions(parentExecutionID uuid.UUID, states []string) ([]WorkflowNodeExecution, error)

+ func FindChildExecutionsForMultiple(parentExecutionIDs []string) ([]WorkflowNodeExecution, error)

+ func FindChildExecutionsInTransaction(tx *gorm.DB, parentExecutionID uuid.UUID, states []string) ([]WorkflowNodeExecution, error)

+ func FindLastExecutionPerNode(workflowID uuid.UUID) ([]WorkflowNodeExecution, error)

+ func FindNodeExecution(workflowID, id uuid.UUID) (*WorkflowNodeExecution, error)

+ func FindNodeExecutionInTransaction(tx *gorm.DB, workflowID, id uuid.UUID) (*WorkflowNodeExecution, error)

+ func FindNodeExecutionWithNodeID(workflowID, id uuid.UUID, nodeID string) (*WorkflowNodeExecution, error)

+ func FindNodeExecutionWithNodeIDInTransaction(tx *gorm.DB, workflowID, id uuid.UUID, nodeID string) (*WorkflowNodeExecution, error)

+ func FirstNodeExecutionByKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID, key, value string) (*WorkflowNodeExecution, error)

+ func ListNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string, ...) ([]WorkflowNodeExecution, error)

+ func ListPendingNodeExecutions() ([]WorkflowNodeExecution, error)

+ func LockWorkflowNodeExecution(tx *gorm.DB, id uuid.UUID) (*WorkflowNodeExecution, error)

+ func (e *WorkflowNodeExecution) Cancel() error

+ func (e *WorkflowNodeExecution) CancelInTransaction(tx *gorm.DB) error

+ func (e *WorkflowNodeExecution) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

+ func (e *WorkflowNodeExecution) Fail(reason, message string) error

+ func (e *WorkflowNodeExecution) FailInTransaction(tx *gorm.DB, reason, message string) error

+ func (e *WorkflowNodeExecution) GetInput(tx *gorm.DB) (any, error)

+ func (e *WorkflowNodeExecution) GetOutputs() ([]WorkflowEvent, error)

+ func (e *WorkflowNodeExecution) GetOutputsInTransaction(tx *gorm.DB) ([]WorkflowEvent, error)

+ func (e *WorkflowNodeExecution) GetParentExecutionID() string

+ func (e *WorkflowNodeExecution) GetPreviousExecutionID() string

+ func (e *WorkflowNodeExecution) Pass(outputs map[string][]any) ([]WorkflowEvent, error)

+ func (e *WorkflowNodeExecution) PassInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]WorkflowEvent, error)

+ func (e *WorkflowNodeExecution) Start() error

+ func (e *WorkflowNodeExecution) StartInTransaction(tx *gorm.DB) error

+ type WorkflowNodeExecutionKV struct

+ CreatedAt *time.Time

+ ExecutionID uuid.UUID

+ ID uuid.UUID

+ Key string

+ NodeID string

+ Value string

+ WorkflowID uuid.UUID

+ type WorkflowNodeQueueItem struct

+ CreatedAt *time.Time

+ EventID uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ RootEvent *WorkflowEvent

+ RootEventID uuid.UUID

+ WorkflowID uuid.UUID

+ func FindNextQueueItemPerNode(workflowID uuid.UUID) ([]WorkflowNodeQueueItem, error)

+ func FindNodeQueueItem(workflowID uuid.UUID, queueItemID uuid.UUID) (*WorkflowNodeQueueItem, error)

+ func ListNodeQueueItems(workflowID uuid.UUID, nodeID string, limit int, beforeTime *time.Time) ([]WorkflowNodeQueueItem, error)

+ func (i *WorkflowNodeQueueItem) Delete(tx *gorm.DB) error

+ type WorkflowNodeReference struct

+ NodeID string

+ NodeName string

+ WorkflowID uuid.UUID

+ WorkflowName string

+ func ListAppInstallationNodeReferences(installationID uuid.UUID) ([]WorkflowNodeReference, error)

+ type WorkflowNodeRequest struct

+ CreatedAt time.Time

+ ExecutionID *uuid.UUID

+ ID uuid.UUID

+ NodeID string

+ RunAt time.Time

+ Spec datatypes.JSONType[NodeExecutionRequestSpec]

+ State string

+ Type string

+ UpdatedAt time.Time

+ WorkflowID uuid.UUID

+ func FindPendingRequestForNode(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (*WorkflowNodeRequest, error)

+ func ListNodeRequests() ([]WorkflowNodeRequest, error)

+ func LockNodeRequest(tx *gorm.DB, id uuid.UUID) (*WorkflowNodeRequest, error)

+ func (r *WorkflowNodeRequest) Complete(tx *gorm.DB) error