models

May 4, 2026

Changes in this version

+ var ErrCanvasNameAlreadyExists = errors.New("canvas name already exists")

+ func MapCanvasNameUniqueConstraintError(err error) error

type Canvas

+ func FindCanvasByNameInTransaction(tx *gorm.DB, name string, organizationID uuid.UUID) (*Canvas, error)

type CanvasVersion

+ ChangeManagementEnabled bool

+ ChangeRequestApprovers datatypes.JSONSlice[CanvasChangeRequestApprover]

+ Description string

+ Name string

+ func (c *CanvasVersion) BeforeCreate(_ *gorm.DB) error

+ func (c *CanvasVersion) BeforeSave(_ *gorm.DB) error

+ func (c *CanvasVersion) EffectiveChangeRequestApprovers() []CanvasChangeRequestApprover

+ type CapabilityState struct

+ Name string

+ Reason *string

+ State core.IntegrationCapabilityState

type Integration

+ Capabilities datatypes.JSONSlice[CapabilityState]

+ Properties datatypes.JSONSlice[core.IntegrationPropertyDefinition]

+ SetupState *datatypes.JSONType[SetupState]

type IntegrationSecret

+ Description string

+ Editable bool

+ Label string

+ func ListIntegrationSecrets(installationID uuid.UUID) ([]IntegrationSecret, error)

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

+ type SetupState struct

+ CurrentStep *core.SetupStep

+ PreviousSteps []core.SetupStep

type User

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

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

Apr 27, 2026

Changes in this version

type Blueprint

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

Apr 17, 2026

Changes in this version

+ const CanvasVersionStateDraft

+ const CanvasVersionStatePublished

+ const CanvasVersionStateSnapshot

+ func IsChangeManagementEnabled(organizationID uuid.UUID) (bool, error)

+ func IsChangeManagementEnabledInTransaction(tx *gorm.DB, organizationID uuid.UUID) (bool, error)

+ func PromoteToLiveInTransaction(tx *gorm.DB, version *CanvasVersion, nodes []Node, edges []Edge) error

type Canvas

+ ChangeManagementEnabled bool

type CanvasVersion

+ State string

+ func FindCanvasVersionForUpdateInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)

type Integration

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

type Organization

+ ChangeManagementEnabled bool

Apr 13, 2026

Changes in this version

type Account

+ CreatedAt *time.Time

+ UpdatedAt *time.Time

+ type OrganizationWithCounts struct

+ CanvasCount int64

+ MemberCount int64

type User

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

+ type UserAccountProvider struct

+ UserID string

+ func FindUserAccountProviders(users []User) ([]UserAccountProvider, error)

Apr 3, 2026

Changes in this version

+ func DeleteEmailSettings(provider string) error

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

+ func UpdateInstallationMetadata(metadata *InstallationMetadata) error

+ func UpdateInstallationMetadataInTransaction(tx *gorm.DB, metadata *InstallationMetadata) error

type CanvasNodeExecution

+ func ListAllExecutionsForRootEvent(rootEventID uuid.UUID) ([]CanvasNodeExecution, error)

+ func ListAllExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) ([]CanvasNodeExecution, error)

+ func ListParentExecutionsForRootEvents(canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)

+ func ListParentExecutionsForRootEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)

type InstallationMetadata

+ AllowPrivateNetworkAccess bool

+ func GetInstallationMetadata() (*InstallationMetadata, error)

+ func GetInstallationMetadataInTransaction(tx *gorm.DB) (*InstallationMetadata, error)

Mar 29, 2026

Changes in this version

+ func CountRecentMagicCodes(email string, since time.Time) (int64, error)

+ func CountRecentMagicCodesInTransaction(tx *gorm.DB, email string, since time.Time) (int64, error)

+ func DemoteFromInstallationAdmin(accountID string) error

+ func IncrementAndMaybeInvalidateCodes(email string, maxVerifyAttempts int) (bool, error)

+ func IncrementAndMaybeInvalidateCodesInTransaction(conn *gorm.DB, email string, maxVerifyAttempts int) (bool, error)

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

+ func PromoteToInstallationAdmin(accountID string) error

type Account

+ InstallationAdmin bool

+ func ListAccounts(search string, limit, offset int) ([]Account, int64, error)

+ func (a *Account) IsInstallationAdmin() bool

+ type AccountMagicCode struct

+ CodeHash string

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID uuid.UUID

+ UsedAt *time.Time

+ VerifyAttempts int

+ func CreateAccountMagicCode(email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)

+ func CreateAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)

+ func FindValidAccountMagicCode(email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)

+ func FindValidAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)

+ func (AccountMagicCode) TableName() string

+ func (c *AccountMagicCode) MarkUsed() (bool, error)

+ func (c *AccountMagicCode) MarkUsedInTransaction(tx *gorm.DB) (bool, error)

type Canvas

+ func ListCanvasesPaginated(orgID, search string, limit, offset int) ([]Canvas, int64, error)

type Organization

+ func ListAllOrganizations(search string, limit, offset int) ([]Organization, int64, error)

type User

+ func ListActiveUsersByOrganization(orgID, search string, limit, offset int) ([]User, int64, error)

Mar 22, 2026

Changes in this version

+ func CountActiveHumanUsersByOrganization(orgID string) (int64, error)

+ func CountActiveHumanUsersByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

+ func CountActiveNodeExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)

+ func CountCanvasesByOrganization(orgID string) (int64, error)

+ func CountCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

+ func CountIntegrationsByOrganization(orgID string) (int64, error)

+ func CountIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

+ func CountNodeQueueItemsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)

+ func CountOrganizationsByBillingAccount(accountID string) (int64, error)

+ func CountOrganizationsByBillingAccountInTransaction(tx *gorm.DB, accountID string) (int64, error)

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

+ func MarkOrganizationUsageLimitsSynced(orgID string, retentionWindowDays *int32, syncedAt time.Time) error

+ func MarkOrganizationUsageLimitsSyncedIfNewer(orgID string, retentionWindowDays *int32, syncedAt time.Time) (bool, error)

+ func MarkOrganizationUsageLimitsSyncedIfNewerInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, syncedAt time.Time) (bool, error)

+ func MarkOrganizationUsageLimitsSyncedIfNoNewerThan(orgID string, retentionWindowDays *int32, maxExistingSyncedAt time.Time, ...) (bool, error)

+ func MarkOrganizationUsageLimitsSyncedIfNoNewerThanInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, ...) (bool, error)

+ func MarkOrganizationUsageLimitsSyncedInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, syncedAt time.Time) error

+ func MarkOrganizationUsageSynced(orgID string, syncedAt time.Time) error

+ func MarkOrganizationUsageSyncedIfUnset(orgID string, syncedAt time.Time) error

+ func MarkOrganizationUsageSyncedIfUnsetInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error

+ func MarkOrganizationUsageSyncedInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error

+ func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThan(orgID string, usageSyncedAt time.Time, retentionWindowDays *int32, ...) error

+ func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThanInTransaction(tx *gorm.DB, orgID string, usageSyncedAt time.Time, retentionWindowDays *int32, ...) error

type Canvas

+ VersioningEnabled bool

+ func ListMaybeDeletedCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Canvas, error)

type CanvasEvent

+ func ListExpiredRoutedRootCanvasEvents(referenceTime time.Time, limit int) ([]CanvasEvent, error)

+ func ListExpiredRoutedRootCanvasEventsInTransaction(tx *gorm.DB, referenceTime time.Time, limit int) ([]CanvasEvent, error)

+ func LockExpiredRoutedRootCanvasEvent(tx *gorm.DB, id uuid.UUID, referenceTime time.Time) (*CanvasEvent, error)

type CanvasNodeExecution

+ func ListNodeExecutionsForRootEventsInTransaction(tx *gorm.DB, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)

type Integration

+ func ListMaybeDeletedIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Integration, error)

type Organization

+ UsageLimitsSyncedAt *time.Time

+ UsageRetentionWindowDays *int32

+ UsageSyncedAt *time.Time

+ VersioningEnabled bool

+ func ListDeletedOrganizations() ([]Organization, error)

+ func ListDeletedOrganizationsInTransaction(tx *gorm.DB) ([]Organization, error)

+ func ListOrganizationsPendingUsageLimitsRefresh(staleBefore time.Time, limit int) ([]Organization, error)

+ func ListOrganizationsPendingUsageLimitsRefreshInTransaction(tx *gorm.DB, staleBefore time.Time, limit int) ([]Organization, error)

+ func ListOrganizationsPendingUsageSync(limit int) ([]Organization, error)

+ func ListOrganizationsPendingUsageSyncInTransaction(tx *gorm.DB, limit int) ([]Organization, error)

+ func LockDeletedOrganization(tx *gorm.DB, id uuid.UUID) (*Organization, error)

type User

+ func FindFirstHumanUserByOrganization(orgID string) (*User, error)

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

Mar 15, 2026

Changes in this version

+ const CanvasChangeRequestApprovalStateApproved

+ const CanvasChangeRequestApprovalStateRejected

+ const CanvasChangeRequestApprovalStateUnapproved

+ const CanvasChangeRequestApproverTypeAnyone

+ const CanvasChangeRequestApproverTypeRole

+ const CanvasChangeRequestApproverTypeUser

+ const CanvasChangeRequestStatusRejected

+ const WebhookStateProvisioning

+ func CreateCanvasChangeRequestApprovalInTransaction(tx *gorm.DB, approval *CanvasChangeRequestApproval) error

+ func InvalidateCanvasChangeRequestApprovalsInTransaction(tx *gorm.DB, workflowID, changeRequestID uuid.UUID, invalidatedAt time.Time) error

+ func IsCanvasVersioningEnabled(organizationID uuid.UUID) (bool, error)

+ func IsCanvasVersioningEnabledInTransaction(tx *gorm.DB, organizationID uuid.UUID) (bool, error)

+ func ListCanvasChangeRequestApprovalsByRequestIDsInTransaction(tx *gorm.DB, workflowID uuid.UUID, changeRequestIDs []uuid.UUID) (map[uuid.UUID][]CanvasChangeRequestApproval, error)

+ func ResetStuckProvisioningWebhooks() (int64, error)

type Canvas

+ CanvasVersioningEnabled bool

+ ChangeRequestApprovers datatypes.JSONSlice[CanvasChangeRequestApprover]

+ func (c *Canvas) BeforeCreate(_ *gorm.DB) error

+ func (c *Canvas) BeforeSave(_ *gorm.DB) error

+ func (c *Canvas) EffectiveChangeRequestApprovers() []CanvasChangeRequestApprover

type CanvasChangeRequest

+ BasedOnVersionID *uuid.UUID

+ ConflictingNodeIDs datatypes.JSONSlice[string]

+ func (c *CanvasChangeRequest) IsConflicted() bool

+ type CanvasChangeRequestApproval struct

+ ActorUserID *uuid.UUID

+ ApproverIndex int

+ ApproverRole *string

+ ApproverType string

+ ApproverUserID *uuid.UUID

+ CreatedAt *time.Time

+ ID uuid.UUID

+ InvalidatedAt *time.Time

+ State string

+ UpdatedAt *time.Time

+ WorkflowChangeRequestID uuid.UUID

+ WorkflowID uuid.UUID

+ func ListCanvasChangeRequestApprovals(workflowID, changeRequestID uuid.UUID) ([]CanvasChangeRequestApproval, error)

+ func ListCanvasChangeRequestApprovalsInTransaction(tx *gorm.DB, workflowID, changeRequestID uuid.UUID) ([]CanvasChangeRequestApproval, error)

+ func (c *CanvasChangeRequestApproval) TableName() string

+ type CanvasChangeRequestApprover struct

+ Role string

+ Type string

+ User string

+ func DefaultCanvasChangeRequestApprovers() []CanvasChangeRequestApprover

type CanvasChangeRequestListOptions

+ IsConflicted *bool

type Organization

+ CanvasVersioningEnabled bool

type Webhook

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

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

Mar 6, 2026

Changes in this version

+ const CanvasChangeRequestStatusOpen

+ const CanvasChangeRequestStatusPublished

+ var ErrCanvasDraftNotFound = errors.New("canvas draft not found")

+ func CountCanvasChangeRequestsFilteredInTransaction(tx *gorm.DB, workflowID uuid.UUID, options CanvasChangeRequestListOptions) (int64, error)

+ func CountPublishedCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID) (int64, error)

+ func FindLiveCanvasSpecInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]Node, []Edge, error)

+ func IsCanvasSandboxModeEnabled(organizationID uuid.UUID) (bool, error)

+ func IsCanvasSandboxModeEnabledInTransaction(tx *gorm.DB, organizationID uuid.UUID) (bool, error)

type Canvas

+ LiveVersionID *uuid.UUID

+ type CanvasChangeRequest struct

+ ChangedNodeIDs datatypes.JSONSlice[string]

+ CreatedAt *time.Time

+ Description string

+ ID uuid.UUID

+ OwnerID *uuid.UUID

+ PublishedAt *time.Time

+ Status string

+ Title string

+ UpdatedAt *time.Time

+ VersionID uuid.UUID

+ WorkflowID uuid.UUID

+ func FindCanvasChangeRequest(workflowID, changeRequestID uuid.UUID) (*CanvasChangeRequest, error)

+ func FindCanvasChangeRequestByVersionInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasChangeRequest, error)

+ func FindCanvasChangeRequestInTransaction(tx *gorm.DB, workflowID, changeRequestID uuid.UUID) (*CanvasChangeRequest, error)

+ func ListCanvasChangeRequests(workflowID uuid.UUID) ([]CanvasChangeRequest, error)

+ func ListCanvasChangeRequestsFilteredInTransaction(tx *gorm.DB, workflowID uuid.UUID, options CanvasChangeRequestListOptions) ([]CanvasChangeRequest, error)

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

+ func (c *CanvasChangeRequest) TableName() string

+ type CanvasChangeRequestListOptions struct

+ Before *time.Time

+ Limit int

+ OwnerID *uuid.UUID

+ Query string

+ Statuses []string

+ type CanvasUserDraft struct

+ CreatedAt *time.Time

+ UpdatedAt *time.Time

+ UserID uuid.UUID

+ VersionID uuid.UUID

+ WorkflowID uuid.UUID

+ func FindCanvasDraftByVersionInTransaction(tx *gorm.DB, workflowID, userID, versionID uuid.UUID) (*CanvasUserDraft, error)

+ func FindCanvasDraftInTransaction(tx *gorm.DB, workflowID, userID uuid.UUID) (*CanvasUserDraft, error)

+ func (c *CanvasUserDraft) TableName() string

+ type CanvasVersion struct

+ CreatedAt *time.Time

+ Edges datatypes.JSONSlice[Edge]

+ ID uuid.UUID

+ IsPublished bool

+ Nodes datatypes.JSONSlice[Node]

+ OwnerID *uuid.UUID

+ PublishedAt *time.Time

+ UpdatedAt *time.Time

+ WorkflowID uuid.UUID

+ func CreateCanvasSnapshotVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID, ownerID uuid.UUID, nodes []Node, ...) (*CanvasVersion, error)

+ func CreateOrResetCanvasDraftInTransaction(tx *gorm.DB, workflowID uuid.UUID, userID uuid.UUID, nodes []Node, ...) (*CanvasVersion, error)

+ func CreatePublishedCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID, ownerID *uuid.UUID, nodes []Node, ...) (*CanvasVersion, error)

+ func FindCanvasVersion(workflowID, versionID uuid.UUID) (*CanvasVersion, error)

+ func FindCanvasVersionInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)

+ func FindLiveCanvasVersionByCanvasInTransaction(tx *gorm.DB, canvas *Canvas) (*CanvasVersion, error)

+ func FindLiveCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID) (*CanvasVersion, error)

+ func ListCanvasVersions(workflowID uuid.UUID) ([]CanvasVersion, error)

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

+ func ListPublishedCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID, limit int, before *time.Time) ([]CanvasVersion, error)

+ func PublishCanvasDraftInTransaction(tx *gorm.DB, workflowID uuid.UUID, userID uuid.UUID) (*CanvasVersion, error)

+ func SaveCanvasDraftInTransaction(tx *gorm.DB, workflowID uuid.UUID, userID uuid.UUID, nodes []Node, ...) (*CanvasVersion, error)

+ func (c *CanvasVersion) TableName() string

type Organization

+ CanvasSandboxModeEnabled bool

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

Mar 1, 2026

Changes in this version

+ const OrganizationAgentOpenAIKeyStatusInvalid

+ const OrganizationAgentOpenAIKeyStatusNotConfigured

+ const OrganizationAgentOpenAIKeyStatusUnchecked

+ const OrganizationAgentOpenAIKeyStatusValid

+ func AddCanvasMemory(canvasID uuid.UUID, namespace string, values any) error

+ func AddCanvasMemoryInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any) error

+ func DeleteCanvasMemory(canvasID, memoryID uuid.UUID) error

+ func DeleteCanvasMemoryInTransaction(tx *gorm.DB, canvasID, memoryID uuid.UUID) error

+ func UpsertOrganizationAgentSettings(settings *OrganizationAgentSettings) error

+ func UpsertOrganizationAgentSettingsInTransaction(tx *gorm.DB, settings *OrganizationAgentSettings) error

+ type CanvasMemory struct

+ CanvasID uuid.UUID

+ CreatedAt time.Time

+ ID uuid.UUID

+ Namespace string

+ UpdatedAt time.Time

+ Values datatypes.JSONType[any]

+ func DeleteCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

+ func DeleteCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

+ func FindFirstCanvasMemoryByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)

+ func FindFirstCanvasMemoryByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)

+ func ListCanvasMemories(canvasID uuid.UUID) ([]CanvasMemory, error)

+ func ListCanvasMemoriesByNamespace(canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)

+ func ListCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

+ func ListCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

+ func ListCanvasMemoriesByNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)

+ func ListCanvasMemoriesInTransaction(tx *gorm.DB, canvasID uuid.UUID) ([]CanvasMemory, error)

+ func UpdateCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any, ...) ([]CanvasMemory, error)

+ func UpdateCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any, ...) ([]CanvasMemory, error)

+ func (CanvasMemory) TableName() string

+ type OrganizationAgentSettings struct

+ AgentModeEnabled bool

+ CreatedAt time.Time

+ ID uuid.UUID

+ OpenAIApiKeyCiphertext []byte

+ OpenAIKeyEncryptionKeyID *string

+ OpenAIKeyLast4 *string

+ OpenAIKeyStatus string

+ OpenAIKeyValidatedAt *time.Time

+ OpenAIKeyValidationError *string

+ OrganizationID uuid.UUID

+ UpdatedAt time.Time

+ UpdatedBy *uuid.UUID

+ func FindOrganizationAgentSettingsByOrganizationID(organizationID string) (*OrganizationAgentSettings, error)

+ func FindOrganizationAgentSettingsByOrganizationIDInTransaction(tx *gorm.DB, organizationID string) (*OrganizationAgentSettings, error)

+ func (s *OrganizationAgentSettings) TableName() string

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