contexts

package
v0.1.6 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildProcessQueueContext 

func BuildProcessQueueContext(httpClient *http.Client, tx *gorm.DB, node *models.WorkflowNode, queueItem *models.WorkflowNodeQueueItem, configFields []configuration.Field) (*core.ProcessQueueContext, error)

func NewAppSubscriptionContext added in v0.0.45 

func NewAppSubscriptionContext(
	tx *gorm.DB,
	registry *registry.Registry,
	subscription *models.NodeSubscription,
	node *models.WorkflowNode,
	installation *models.AppInstallation,
	appCtx *AppInstallationContext,
) core.AppSubscriptionContext

func NewHTTPContext added in v0.0.43 

func NewHTTPContext(httpClient *http.Client) core.HTTPContext

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) ListSubscriptions added in v0.0.45 

func (c *AppInstallationContext) ListSubscriptions() ([]core.AppSubscriptionContext, error)

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)

func (*AppInstallationContext) Subscribe added in v0.0.45 

func (c *AppInstallationContext) Subscribe(configuration any) (*uuid.UUID, error)

type AppSubscriptionContext added in v0.0.45 

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

func (*AppSubscriptionContext) Configuration added in v0.0.45 

func (c *AppSubscriptionContext) Configuration() any

func (*AppSubscriptionContext) SendMessage added in v0.0.45 

func (c *AppSubscriptionContext) SendMessage(message any) error

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 HTTPContext added in v0.0.43 

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

func (*HTTPContext) Do added in v0.0.43 

func (c *HTTPContext) Do(request *http.Request) (*http.Response, 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) BuildExpressionEnv added in v0.1.2 

func (b *NodeConfigurationBuilder) BuildExpressionEnv(expression string) (map[string]any, error)

func (*NodeConfigurationBuilder) BuildMessageChainForExpression added in v0.0.45 

func (b *NodeConfigurationBuilder) BuildMessageChainForExpression(expression string) (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) WithConfigurationFields added in v0.0.45 

func (b *NodeConfigurationBuilder) WithConfigurationFields(fields []configuration.Field) *NodeConfigurationBuilder

func (*NodeConfigurationBuilder) WithInput 

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

func (*NodeConfigurationBuilder) WithNodeID added in v0.1.6 

func (b *NodeConfigurationBuilder) WithNodeID(nodeID string) *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 NodeWebhookContext added in v0.0.30 

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

func NewNodeWebhookContext added in v0.0.30 

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

func (*NodeWebhookContext) GetBaseURL added in v0.0.30 

func (c *NodeWebhookContext) GetBaseURL() string

func (*NodeWebhookContext) GetSecret added in v0.0.30 

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

func (*NodeWebhookContext) ResetSecret added in v0.0.30 

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

func (*NodeWebhookContext) Setup added in v0.0.30 

func (c *NodeWebhookContext) Setup() (string, error)

type NotificationContext added in v0.0.43 

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

func NewNotificationContext added in v0.0.43 

func NewNotificationContext(tx *gorm.DB, orgID, workflowID uuid.UUID) *NotificationContext

func (*NotificationContext) Send added in v0.0.43 

func (c *NotificationContext) Send(title, body, url, urlLabel string, receivers core.NotificationReceivers) error

type WebhookContext 

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

func NewWebhookContext 

func NewWebhookContext(tx *gorm.DB, webhook *models.Webhook, encryptor crypto.Encryptor, baseURL string) *WebhookContext

func (*WebhookContext) GetConfiguration added in v0.0.30 

func (c *WebhookContext) GetConfiguration() any

func (*WebhookContext) GetID added in v0.0.30 

func (c *WebhookContext) GetID() string

func (*WebhookContext) GetMetadata added in v0.0.30 

func (c *WebhookContext) GetMetadata() any

func (*WebhookContext) GetSecret 

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

func (*WebhookContext) GetURL added in v0.0.30 

func (c *WebhookContext) GetURL() string

func (*WebhookContext) SetSecret added in v0.0.30 

func (c *WebhookContext) SetSecret(secret []byte) 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.