support

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuthService 

func AuthService(t *testing.T) *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 *testing.T, 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 *testing.T,
	canvasID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
) *models.CanvasNodeExecution

func CreateNextNodeExecution 

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

func CreateNodeExecutionWithConfiguration 

func CreateNodeExecutionWithConfiguration(
	t *testing.T,
	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 *testing.T, r *ResourceRegistry, userID uuid.UUID) *models.Organization

func CreateQueueItem added in v0.6.0 

func CreateQueueItem(t *testing.T, 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 *testing.T, canvasID uuid.UUID, nodeID string, channel string, executionID *uuid.UUID) *models.CanvasEvent

func EmitCanvasEventForNodeWithData added in v0.6.0 

func EmitCanvasEventForNodeWithData(
	t *testing.T,
	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 *testing.T, canvasID uuid.UUID, expected int)

func VerifyNodeExecutionKVCount added in v0.6.0 

func VerifyNodeExecutionKVCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyNodeExecutionsCount added in v0.6.0 

func VerifyNodeExecutionsCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyNodeQueueCount added in v0.6.0 

func VerifyNodeQueueCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyNodeRequestCount added in v0.6.0 

func VerifyNodeRequestCount(t *testing.T, workflowID uuid.UUID, expected int)

Types

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) CleanupWebhook added in v0.5.0 

func (t *DummyIntegration) CleanupWebhook(ctx core.CleanupWebhookContext) error

func (*DummyIntegration) CompareWebhookConfig added in v0.5.0 

func (t *DummyIntegration) CompareWebhookConfig(a, b any) (bool, 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) SetupWebhook added in v0.5.0 

func (t *DummyIntegration) SetupWebhook(ctx core.SetupWebhookContext) (any, error)

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 {
	Actions                []core.Action
	HandleAction           func(ctx core.IntegrationActionContext) error
	OnSync                 func(ctx core.SyncContext) error
	OnCompareWebhookConfig func(a, b any) (bool, error)
	OnSetupWebhook         func(ctx core.SetupWebhookContext) (any, error)
	OnCleanup              func(ctx core.IntegrationCleanupContext) 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 *testing.T) *ResourceRegistry

func SetupWithOptions 

func SetupWithOptions(t *testing.T, 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.