contexts

package
v0.0.28 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildProcessQueueContext 

func BuildProcessQueueContext(tx *gorm.DB, node *models.WorkflowNode, queueItem *models.WorkflowNodeQueueItem) (*core.ProcessQueueContext, error)

Types

type AppInstallationContext 

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

func NewAppInstallationContext 

func NewAppInstallationContext(tx *gorm.DB, node *models.WorkflowNode, installation *models.AppInstallation, encryptor crypto.Encryptor, registry *registry.Registry) *AppInstallationContext

func (*AppInstallationContext) GetConfig 

func (c *AppInstallationContext) GetConfig(name string) ([]byte, error)

func (*AppInstallationContext) GetMetadata 

func (c *AppInstallationContext) GetMetadata() any

func (*AppInstallationContext) GetSecrets 

func (c *AppInstallationContext) GetSecrets() ([]core.InstallationSecret, error)

func (*AppInstallationContext) GetState 

func (c *AppInstallationContext) GetState() string

func (*AppInstallationContext) ID 

func (c *AppInstallationContext) ID() uuid.UUID

func (*AppInstallationContext) NewBrowserAction 

func (c *AppInstallationContext) NewBrowserAction(action core.BrowserAction)

func (*AppInstallationContext) RemoveBrowserAction 

func (c *AppInstallationContext) RemoveBrowserAction()

func (*AppInstallationContext) RequestWebhook 

func (c *AppInstallationContext) RequestWebhook(configuration any) error

func (*AppInstallationContext) ScheduleResync added in v0.0.21 

func (c *AppInstallationContext) ScheduleResync(interval time.Duration) error

func (*AppInstallationContext) SetMetadata 

func (c *AppInstallationContext) SetMetadata(value any)

func (*AppInstallationContext) SetSecret 

func (c *AppInstallationContext) SetSecret(name string, value []byte) error

func (*AppInstallationContext) SetState 

func (c *AppInstallationContext) SetState(state, stateDescription string)

type AuthContext 

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

func NewAuthContext 

func NewAuthContext(tx *gorm.DB, orgID uuid.UUID, authService authorization.Authorization, authenticatedUser *models.User) *AuthContext

func (*AuthContext) AuthenticatedUser 

func (c *AuthContext) AuthenticatedUser() *core.User

func (*AuthContext) GetUser 

func (c *AuthContext) GetUser(id uuid.UUID) (*core.User, error)

func (*AuthContext) HasRole 

func (c *AuthContext) HasRole(role string) (bool, error)

func (*AuthContext) InGroup 

func (c *AuthContext) InGroup(group string) (bool, error)

type ConfigurationBuildError 

type ConfigurationBuildError struct {
	Err         error
	QueueItem   *models.WorkflowNodeQueueItem
	Node        *models.WorkflowNode
	Event       *models.WorkflowEvent
	RootEventID uuid.UUID
}

func (*ConfigurationBuildError) Error 

func (e *ConfigurationBuildError) Error() string

func (*ConfigurationBuildError) Unwrap 

func (e *ConfigurationBuildError) Unwrap() error

type EventContext 

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

func NewEventContext 

func NewEventContext(tx *gorm.DB, workflowNode *models.WorkflowNode) *EventContext

func (*EventContext) Emit 

func (s *EventContext) Emit(payloadType string, payload any) error

type ExecutionMetadataContext 

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

func NewExecutionMetadataContext 

func NewExecutionMetadataContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionMetadataContext

func (*ExecutionMetadataContext) Get 

func (m *ExecutionMetadataContext) Get() any

func (*ExecutionMetadataContext) Set 

func (m *ExecutionMetadataContext) Set(value any) error

type ExecutionRequestContext 

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

func NewExecutionRequestContext 

func NewExecutionRequestContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionRequestContext

func (*ExecutionRequestContext) ScheduleActionCall 

func (c *ExecutionRequestContext) ScheduleActionCall(actionName string, parameters map[string]any, interval time.Duration) error

type ExecutionStateContext 

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

func NewExecutionStateContext 

func NewExecutionStateContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionStateContext

func (*ExecutionStateContext) Emit 

func (s *ExecutionStateContext) Emit(channel, payloadType string, payloads []any) error

func (*ExecutionStateContext) Fail 

func (s *ExecutionStateContext) Fail(reason, message string) error

func (*ExecutionStateContext) IsFinished 

func (s *ExecutionStateContext) IsFinished() bool

func (*ExecutionStateContext) Pass 

func (s *ExecutionStateContext) Pass() error

func (*ExecutionStateContext) SetKV 

func (s *ExecutionStateContext) SetKV(key, value string) error

type IntegrationContext 

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

func NewIntegrationContext 

func NewIntegrationContext(tx *gorm.DB, registry *registry.Registry) *IntegrationContext

func (*IntegrationContext) GetIntegration 

func (c *IntegrationContext) GetIntegration(ID string) (integrations.ResourceManager, error)

type NodeConfigurationBuilder 

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

func NewNodeConfigurationBuilder 

func NewNodeConfigurationBuilder(tx *gorm.DB, workflowID uuid.UUID) *NodeConfigurationBuilder

func (*NodeConfigurationBuilder) Build 

func (b *NodeConfigurationBuilder) Build(configuration map[string]any) (map[string]any, error)

func (*NodeConfigurationBuilder) ForBlueprintNode 

func (b *NodeConfigurationBuilder) ForBlueprintNode(parentBlueprintNode *models.WorkflowNode) *NodeConfigurationBuilder

func (*NodeConfigurationBuilder) ResolveExpression 

func (b *NodeConfigurationBuilder) ResolveExpression(expression string) (any, error)

func (*NodeConfigurationBuilder) WithInput 

func (b *NodeConfigurationBuilder) WithInput(input any) *NodeConfigurationBuilder

func (*NodeConfigurationBuilder) WithPreviousExecution 

func (b *NodeConfigurationBuilder) WithPreviousExecution(previousExecutionID *uuid.UUID) *NodeConfigurationBuilder

func (*NodeConfigurationBuilder) WithRootEvent 

func (b *NodeConfigurationBuilder) WithRootEvent(rootEventID *uuid.UUID) *NodeConfigurationBuilder

type NodeMetadataContext 

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

func NewNodeMetadataContext 

func NewNodeMetadataContext(tx *gorm.DB, node *models.WorkflowNode) *NodeMetadataContext

func (*NodeMetadataContext) Get 

func (m *NodeMetadataContext) Get() any

func (*NodeMetadataContext) Set 

func (m *NodeMetadataContext) Set(value any) error

type NodeRequestContext 

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

func NewNodeRequestContext 

func NewNodeRequestContext(tx *gorm.DB, node *models.WorkflowNode) *NodeRequestContext

func (*NodeRequestContext) ScheduleActionCall 

func (c *NodeRequestContext) ScheduleActionCall(actionName string, parameters map[string]any, interval time.Duration) error

type WebhookContext 

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

func NewWebhookContext 

func NewWebhookContext(ctx context.Context, tx *gorm.DB, encryptor crypto.Encryptor, node *models.WorkflowNode, baseURL string) *WebhookContext

func (*WebhookContext) GetBaseURL added in v0.0.18 

func (c *WebhookContext) GetBaseURL() string

func (*WebhookContext) GetSecret 

func (c *WebhookContext) GetSecret() ([]byte, error)

func (*WebhookContext) ResetSecret added in v0.0.18 

func (c *WebhookContext) ResetSecret() ([]byte, []byte, error)

func (*WebhookContext) Setup 

func (c *WebhookContext) Setup(options *core.WebhookSetupOptions) (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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