support

package

v0.5.3 Latest Latest Go to latest Published: Jan 27, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/superplanehq/superplane

Links

Open Source Insights

Documentation ¶

Index ¶

func AuthService(t *testing.T) *authorization.AuthService
func CreateBlueprint(t *testing.T, orgID uuid.UUID, nodes []models.Node, edges []models.Edge, ...) *models.Blueprint
func CreateNextNodeExecution(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, ...) *models.WorkflowNodeExecution
func CreateNodeExecutionWithConfiguration(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, ...) *models.WorkflowNodeExecution
func CreateOrganization(t *testing.T, r *ResourceRegistry, userID uuid.UUID) *models.Organization
func CreateSecret(t *testing.T, r *ResourceRegistry, secretData map[string]string) (*models.Secret, error)
func CreateUser(t *testing.T, r *ResourceRegistry, organizationID uuid.UUID) *models.User
func CreateWorkflow(t *testing.T, orgID uuid.UUID, userID uuid.UUID, nodes []models.WorkflowNode, ...) (*models.Workflow, []models.WorkflowNode)
func CreateWorkflowNodeExecution(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, ...) *models.WorkflowNodeExecution
func CreateWorkflowQueueItem(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, ...) *models.WorkflowNodeQueueItem
func EmitWorkflowEventForNode(t *testing.T, workflowID uuid.UUID, nodeID string, channel string, ...) *models.WorkflowEvent
func EmitWorkflowEventForNodeWithData(t *testing.T, workflowID uuid.UUID, nodeID string, channel string, ...) *models.WorkflowEvent
func NewOIDCProvider() oidc.Provider
func RandomName(prefix string) string
func VerifyWorkflowEventsCount(t *testing.T, workflowID uuid.UUID, expected int)
func VerifyWorkflowNodeExecutionKVCount(t *testing.T, workflowID uuid.UUID, expected int)
func VerifyWorkflowNodeExecutionsCount(t *testing.T, workflowID uuid.UUID, expected int)
func VerifyWorkflowNodeQueueCount(t *testing.T, workflowID uuid.UUID, expected int)
func VerifyWorkflowNodeRequestCount(t *testing.T, workflowID uuid.UUID, expected int)
type DummyIntegration
- func NewDummyIntegration(onSync func(ctx core.SyncContext) error) *DummyIntegration
- func NewDummyIntegrationWithSetupWebhook(onSync func(ctx core.SyncContext) error, ...) *DummyIntegration
- func (t *DummyIntegration) CleanupWebhook(ctx core.CleanupWebhookContext) error
- func (t *DummyIntegration) CompareWebhookConfig(a, b any) (bool, error)
- func (t *DummyIntegration) Components() []core.Component
- func (t *DummyIntegration) Configuration() []configuration.Field
- func (t *DummyIntegration) Description() string
- func (t *DummyIntegration) HandleRequest(ctx core.HTTPRequestContext)
- func (t *DummyIntegration) Icon() string
- func (t *DummyIntegration) Instructions() string
- func (t *DummyIntegration) Label() string
- func (t *DummyIntegration) ListResources(resourceType string, ctx core.ListResourcesContext) ([]core.IntegrationResource, error)
- func (t *DummyIntegration) Name() string
- func (t *DummyIntegration) SetupWebhook(ctx core.SetupWebhookContext) (any, error)
- func (t *DummyIntegration) Sync(ctx core.SyncContext) error
- func (t *DummyIntegration) Triggers() []core.Trigger
type ResourceRegistry
- func Setup(t *testing.T) *ResourceRegistry
- func SetupWithOptions(t *testing.T, options SetupOptions) *ResourceRegistry
- func (r *ResourceRegistry) Close()
type SetupOptions
type TestOIDCProvider
- func (p *TestOIDCProvider) PublicJWKs() []oidc.PublicJWK
- func (p *TestOIDCProvider) Sign(subject string, duration time.Duration, audience string, ...) (string, error)

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 CreateNextNodeExecution ¶

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

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.WorkflowNodeExecution

func CreateOrganization ¶

func CreateOrganization(t *testing.T, r *ResourceRegistry, userID uuid.UUID) *models.Organization

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 CreateWorkflow ¶

func CreateWorkflow(t *testing.T, orgID uuid.UUID, userID uuid.UUID, nodes []models.WorkflowNode, edges []models.Edge) (*models.Workflow, []models.WorkflowNode)

func CreateWorkflowNodeExecution ¶

func CreateWorkflowNodeExecution(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
) *models.WorkflowNodeExecution

func CreateWorkflowQueueItem ¶

func CreateWorkflowQueueItem(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, eventID uuid.UUID) *models.WorkflowNodeQueueItem

func EmitWorkflowEventForNode ¶

func EmitWorkflowEventForNode(t *testing.T, workflowID uuid.UUID, nodeID string, channel string, executionID *uuid.UUID) *models.WorkflowEvent

func EmitWorkflowEventForNodeWithData ¶

func EmitWorkflowEventForNodeWithData(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	channel string,
	executionID *uuid.UUID,
	data map[string]any,
) *models.WorkflowEvent

func NewOIDCProvider ¶ added in v0.1.1

func NewOIDCProvider() oidc.Provider

func RandomName ¶

func RandomName(prefix string) string

func VerifyWorkflowEventsCount ¶

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

func VerifyWorkflowNodeExecutionKVCount ¶

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

func VerifyWorkflowNodeExecutionsCount ¶

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

func VerifyWorkflowNodeQueueCount ¶

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

func VerifyWorkflowNodeRequestCount ¶

func VerifyWorkflowNodeRequestCount(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(onSync func(ctx core.SyncContext) error) *DummyIntegration

func NewDummyIntegrationWithSetupWebhook ¶ added in v0.5.0

func NewDummyIntegrationWithSetupWebhook(
	onSync func(ctx core.SyncContext) error,
	onSetupWebhook func(ctx core.SetupWebhookContext) (any, error),
) *DummyIntegration

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) 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 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
contexts

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL