support

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2026 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuthService 

func AuthService(t require.TestingT) *authorization.AuthService

func CreateBlueprint 

func CreateBlueprint(t *testing.T, orgID uuid.UUID, nodes []models.Node, edges []models.Edge, outputChannels []models.BlueprintOutputChannel) *models.Blueprint

func CreateCanvas added in v0.6.0 

func CreateCanvas(t require.TestingT, orgID uuid.UUID, userID uuid.UUID, nodes []models.CanvasNode, edges []models.Edge) (*models.Canvas, []models.CanvasNode)

func CreateCanvasNodeExecution added in v0.6.0 

func CreateCanvasNodeExecution(
	t require.TestingT,
	canvasID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
) *models.CanvasNodeExecution

func CreateNextNodeExecution 

func CreateNextNodeExecution(
	t require.TestingT,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	previous *uuid.UUID,
) *models.CanvasNodeExecution

func CreateNodeExecutionWithConfiguration 

func CreateNodeExecutionWithConfiguration(
	t require.TestingT,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
	configuration map[string]any,
) *models.CanvasNodeExecution

func CreateOrganization 

func CreateOrganization(t require.TestingT, r *ResourceRegistry, userID uuid.UUID) *models.Organization

func CreateQueueItem added in v0.6.0 

func CreateQueueItem(t require.TestingT, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, eventID uuid.UUID) *models.CanvasNodeQueueItem

func CreateSecret 

func CreateSecret(t *testing.T, r *ResourceRegistry, secretData map[string]string) (*models.Secret, error)

func CreateUser 

func CreateUser(t *testing.T, r *ResourceRegistry, organizationID uuid.UUID) *models.User

func EmitCanvasEventForNode added in v0.6.0 

func EmitCanvasEventForNode(t require.TestingT, canvasID uuid.UUID, nodeID string, channel string, executionID *uuid.UUID) *models.CanvasEvent

func EmitCanvasEventForNodeWithData added in v0.6.0 

func EmitCanvasEventForNodeWithData(
	t require.TestingT,
	canvasID uuid.UUID,
	nodeID string,
	channel string,
	executionID *uuid.UUID,
	data map[string]any,
) *models.CanvasEvent

func NewOIDCProvider added in v0.1.1 

func NewOIDCProvider() oidc.Provider

func RandomName 

func RandomName(prefix string) string

func VerifyCanvasEventsCount added in v0.6.0 

func VerifyCanvasEventsCount(t require.TestingT, canvasID uuid.UUID, expected int)

func VerifyCanvasNodeEventsCount added in v0.7.0 

func VerifyCanvasNodeEventsCount(t require.TestingT, canvasID uuid.UUID, nodeID string, expected int)

func VerifyNodeExecutionKVCount added in v0.6.0 

func VerifyNodeExecutionKVCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeExecutionsCount added in v0.6.0 

func VerifyNodeExecutionsCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeQueueCount added in v0.6.0 

func VerifyNodeQueueCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeRequestCount added in v0.6.0 

func VerifyNodeRequestCount(t require.TestingT, workflowID uuid.UUID, expected int)

Types

type DummyComponent added in v0.14.0 

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

func NewDummyComponent added in v0.14.0 

func NewDummyComponent(options DummyComponentOptions) *DummyComponent

func (*DummyComponent) Actions added in v0.14.0 

func (t *DummyComponent) Actions() []core.Action

func (*DummyComponent) Cancel added in v0.14.0 

func (t *DummyComponent) Cancel(ctx core.ExecutionContext) error

func (*DummyComponent) Cleanup added in v0.14.0 

func (t *DummyComponent) Cleanup(ctx core.SetupContext) error

func (*DummyComponent) Color added in v0.14.0 

func (t *DummyComponent) Color() string

func (*DummyComponent) Configuration added in v0.14.0 

func (t *DummyComponent) Configuration() []configuration.Field

func (*DummyComponent) Description added in v0.14.0 

func (t *DummyComponent) Description() string

func (*DummyComponent) Documentation added in v0.14.0 

func (t *DummyComponent) Documentation() string

func (*DummyComponent) ExampleOutput added in v0.14.0 

func (t *DummyComponent) ExampleOutput() map[string]any

func (*DummyComponent) Execute added in v0.14.0 

func (t *DummyComponent) Execute(ctx core.ExecutionContext) error

func (*DummyComponent) HandleAction added in v0.14.0 

func (t *DummyComponent) HandleAction(ctx core.ActionContext) error

func (*DummyComponent) HandleWebhook added in v0.14.0 

func (t *DummyComponent) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DummyComponent) Icon added in v0.14.0 

func (t *DummyComponent) Icon() string

func (*DummyComponent) Label added in v0.14.0 

func (t *DummyComponent) Label() string

func (*DummyComponent) Name added in v0.14.0 

func (t *DummyComponent) Name() string

func (*DummyComponent) OutputChannels added in v0.14.0 

func (t *DummyComponent) OutputChannels(any) []core.OutputChannel

func (*DummyComponent) ProcessQueueItem added in v0.14.0 

func (t *DummyComponent) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DummyComponent) Setup added in v0.14.0 

func (t *DummyComponent) Setup(ctx core.SetupContext) error

type DummyComponentOptions added in v0.14.0 

type DummyComponentOptions struct {
	SetupFunc         func(ctx core.SetupContext) error
	ProcessQueueFunc  func(ctx core.ProcessQueueContext) (*uuid.UUID, error)
	ExecuteFunc       func(ctx core.ExecutionContext) error
	HandleActionFunc  func(ctx core.ActionContext) error
	HandleWebhookFunc func(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)
	CancelFunc        func(ctx core.ExecutionContext) error
	CleanupFunc       func(ctx core.SetupContext) error
}

type DummyIntegration added in v0.5.0 

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

func NewDummyIntegration added in v0.5.0 

func NewDummyIntegration(options DummyIntegrationOptions) *DummyIntegration

func (*DummyIntegration) Actions added in v0.6.0 

func (t *DummyIntegration) Actions() []core.Action

func (*DummyIntegration) Cleanup added in v0.6.0 

func (t *DummyIntegration) Cleanup(ctx core.IntegrationCleanupContext) error

func (*DummyIntegration) Components added in v0.5.0 

func (t *DummyIntegration) Components() []core.Component

func (*DummyIntegration) Configuration added in v0.5.0 

func (t *DummyIntegration) Configuration() []configuration.Field

func (*DummyIntegration) Description added in v0.5.0 

func (t *DummyIntegration) Description() string

func (*DummyIntegration) HandleAction added in v0.6.0 

func (t *DummyIntegration) HandleAction(ctx core.IntegrationActionContext) error

func (*DummyIntegration) HandleRequest added in v0.5.0 

func (t *DummyIntegration) HandleRequest(ctx core.HTTPRequestContext)

func (*DummyIntegration) Icon added in v0.5.0 

func (t *DummyIntegration) Icon() string

func (*DummyIntegration) Instructions added in v0.5.0 

func (t *DummyIntegration) Instructions() string

func (*DummyIntegration) Label added in v0.5.0 

func (t *DummyIntegration) Label() string

func (*DummyIntegration) ListResources added in v0.5.0 

func (t *DummyIntegration) ListResources(resourceType string, ctx core.ListResourcesContext) ([]core.IntegrationResource, error)

func (*DummyIntegration) Name added in v0.5.0 

func (t *DummyIntegration) Name() string

func (*DummyIntegration) Sync added in v0.5.0 

func (t *DummyIntegration) Sync(ctx core.SyncContext) error

func (*DummyIntegration) Triggers added in v0.5.0 

func (t *DummyIntegration) Triggers() []core.Trigger

type DummyIntegrationOptions added in v0.6.0 

type DummyIntegrationOptions struct {
	Components   []core.Component
	Triggers     []core.Trigger
	Actions      []core.Action
	HandleAction func(ctx core.IntegrationActionContext) error
	OnSync       func(ctx core.SyncContext) error
	OnCleanup    func(ctx core.IntegrationCleanupContext) error
}

type DummyIntegrationTrigger added in v0.12.0 

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

func NewDummyIntegrationTrigger added in v0.12.0 

func NewDummyIntegrationTrigger(options DummyIntegrationTriggerOptions) *DummyIntegrationTrigger

func (*DummyIntegrationTrigger) Actions added in v0.12.0 

func (t *DummyIntegrationTrigger) Actions() []core.Action

func (*DummyIntegrationTrigger) Cleanup added in v0.12.0 

func (t *DummyIntegrationTrigger) Cleanup(ctx core.TriggerContext) error

func (*DummyIntegrationTrigger) Color added in v0.12.0 

func (t *DummyIntegrationTrigger) Color() string

func (*DummyIntegrationTrigger) Configuration added in v0.12.0 

func (t *DummyIntegrationTrigger) Configuration() []configuration.Field

func (*DummyIntegrationTrigger) Description added in v0.12.0 

func (t *DummyIntegrationTrigger) Description() string

func (*DummyIntegrationTrigger) Documentation added in v0.12.0 

func (t *DummyIntegrationTrigger) Documentation() string

func (*DummyIntegrationTrigger) ExampleData added in v0.12.0 

func (t *DummyIntegrationTrigger) ExampleData() map[string]any

func (*DummyIntegrationTrigger) HandleAction added in v0.12.0 

func (t *DummyIntegrationTrigger) HandleAction(ctx core.TriggerActionContext) (map[string]any, error)

func (*DummyIntegrationTrigger) HandleWebhook added in v0.12.0 

func (t *DummyIntegrationTrigger) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DummyIntegrationTrigger) Icon added in v0.12.0 

func (t *DummyIntegrationTrigger) Icon() string

func (*DummyIntegrationTrigger) Label added in v0.12.0 

func (t *DummyIntegrationTrigger) Label() string

func (*DummyIntegrationTrigger) Name added in v0.12.0 

func (t *DummyIntegrationTrigger) Name() string

func (*DummyIntegrationTrigger) OnIntegrationMessage added in v0.12.0 

func (t *DummyIntegrationTrigger) OnIntegrationMessage(ctx core.IntegrationMessageContext) error

func (*DummyIntegrationTrigger) Setup added in v0.12.0 

func (t *DummyIntegrationTrigger) Setup(ctx core.TriggerContext) error

type DummyIntegrationTriggerOptions added in v0.12.0 

type DummyIntegrationTriggerOptions struct {
	Name                 string
	OnIntegrationMessage func(ctx core.IntegrationMessageContext) error
}

type DummyWebhookHandler added in v0.7.0 

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

func NewDummyWebhookHandler added in v0.7.0 

func NewDummyWebhookHandler(options DummyWebhookHandlerOptions) *DummyWebhookHandler

func (*DummyWebhookHandler) Cleanup added in v0.7.0 

func (t *DummyWebhookHandler) Cleanup(ctx core.WebhookHandlerContext) error

func (*DummyWebhookHandler) CompareConfig added in v0.7.0 

func (t *DummyWebhookHandler) CompareConfig(a, b any) (bool, error)

func (*DummyWebhookHandler) Merge added in v0.8.0 

func (t *DummyWebhookHandler) Merge(current, requested any) (any, bool, error)

func (*DummyWebhookHandler) Setup added in v0.7.0 

func (t *DummyWebhookHandler) Setup(ctx core.WebhookHandlerContext) (any, error)

type DummyWebhookHandlerOptions added in v0.7.0 

type DummyWebhookHandlerOptions struct {
	SetupFunc         func(ctx core.WebhookHandlerContext) (any, error)
	CleanupFunc       func(ctx core.WebhookHandlerContext) error
	CompareConfigFunc func(a, b any) (bool, error)
	MergeFunc         func(current, requested any) (any, bool, error)
}

type ResourceRegistry 

type ResourceRegistry struct {
	User         uuid.UUID
	UserModel    *models.User
	Organization *models.Organization
	Account      *models.Account
	Encryptor    crypto.Encryptor
	AuthService  *authorization.AuthService
	Registry     *registry.Registry
}

func Setup 

func Setup(t require.TestingT) *ResourceRegistry

func SetupWithOptions 

func SetupWithOptions(t require.TestingT, options SetupOptions) *ResourceRegistry

func (*ResourceRegistry) Close 

func (r *ResourceRegistry) Close()

type SetupOptions 

type SetupOptions struct {
	Source    bool
	Stage     bool
	Approvals int
}

type TestOIDCProvider added in v0.1.1 

type TestOIDCProvider struct{}

func (*TestOIDCProvider) PublicJWKs added in v0.1.1 

func (p *TestOIDCProvider) PublicJWKs() []oidc.PublicJWK

func (*TestOIDCProvider) Sign added in v0.1.1 

func (p *TestOIDCProvider) Sign(subject string, duration time.Duration, audience string, additionalClaims map[string]any) (string, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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