api

package
v0.0.0-...-e5dac56 Latest Latest
Warning

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

Go to latest
Published: Aug 6, 2026 License: AGPL-3.0 Imports: 25 Imported by: 0

Documentation

Overview

Package api provides primitives to interact with the openapi HTTP API.

Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.4.1 DO NOT EDIT.

Index

Constants

View Source
const (
	ApiKeyAuthScopes = "ApiKeyAuth.Scopes"
	BearerAuthScopes = "BearerAuth.Scopes"
)

Variables

This section is empty.

Functions

func Handler

func Handler(si ServerInterface) http.Handler

Handler creates http.Handler with routing matching OpenAPI spec.

func HandlerFromMux

func HandlerFromMux(si ServerInterface, r chi.Router) http.Handler

HandlerFromMux creates http.Handler with routing matching OpenAPI spec based on the provided mux.

func HandlerFromMuxWithBaseURL

func HandlerFromMuxWithBaseURL(si ServerInterface, r chi.Router, baseURL string) http.Handler

func HandlerWithOptions

func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler

HandlerWithOptions creates http.Handler with additional options

func NewCombinedRouter

func NewCombinedRouter(database *sql.DB, engine execution.ExecutionEngine) http.Handler

NewCombinedRouter creates a router that combines OpenAPI handlers with essential legacy endpoints

func NewOpenAPIRouter

func NewOpenAPIRouter(database *sql.DB, engine execution.ExecutionEngine) http.Handler

NewOpenAPIRouter creates a new router with OpenAPI-generated handlers

Types

type AssistantChat200JSONResponse

type AssistantChat200JSONResponse AssistantChatResponse

func (AssistantChat200JSONResponse) VisitAssistantChatResponse

func (response AssistantChat200JSONResponse) VisitAssistantChatResponse(w http.ResponseWriter) error

type AssistantChat400JSONResponse

type AssistantChat400JSONResponse Error

func (AssistantChat400JSONResponse) VisitAssistantChatResponse

func (response AssistantChat400JSONResponse) VisitAssistantChatResponse(w http.ResponseWriter) error

type AssistantChat500JSONResponse

type AssistantChat500JSONResponse Error

func (AssistantChat500JSONResponse) VisitAssistantChatResponse

func (response AssistantChat500JSONResponse) VisitAssistantChatResponse(w http.ResponseWriter) error

type AssistantChatJSONRequestBody

type AssistantChatJSONRequestBody = AssistantChatRequest

AssistantChatJSONRequestBody defines body for AssistantChat for application/json ContentType.

type AssistantChatRequest

type AssistantChatRequest struct {
	// Messages Array of chat messages
	Messages []ChatMessage `json:"messages"`

	// WorkflowId Optional workflow ID for context-aware assistance
	WorkflowId *openapi_types.UUID `json:"workflow_id,omitempty"`
}

AssistantChatRequest defines model for AssistantChatRequest.

type AssistantChatRequestObject

type AssistantChatRequestObject struct {
	Body *AssistantChatJSONRequestBody
}

type AssistantChatResponse

type AssistantChatResponse struct {
	// Choices Array of response choices
	Choices *[]ChatChoice `json:"choices,omitempty"`

	// Created Unix timestamp
	Created *int `json:"created,omitempty"`

	// Id Response ID
	Id *string `json:"id,omitempty"`

	// Model Model used
	Model *string `json:"model,omitempty"`

	// Object Object type (e.g., "chat.completion")
	Object *string    `json:"object,omitempty"`
	Usage  *ChatUsage `json:"usage,omitempty"`
}

AssistantChatResponse defines model for AssistantChatResponse.

type AssistantChatResponseObject

type AssistantChatResponseObject interface {
	VisitAssistantChatResponse(w http.ResponseWriter) error
}

type AutoLayoutWorkflow200JSONResponse

type AutoLayoutWorkflow200JSONResponse WorkflowLayoutResult

func (AutoLayoutWorkflow200JSONResponse) VisitAutoLayoutWorkflowResponse

func (response AutoLayoutWorkflow200JSONResponse) VisitAutoLayoutWorkflowResponse(w http.ResponseWriter) error

type AutoLayoutWorkflow404JSONResponse

type AutoLayoutWorkflow404JSONResponse Error

func (AutoLayoutWorkflow404JSONResponse) VisitAutoLayoutWorkflowResponse

func (response AutoLayoutWorkflow404JSONResponse) VisitAutoLayoutWorkflowResponse(w http.ResponseWriter) error

type AutoLayoutWorkflow500JSONResponse

type AutoLayoutWorkflow500JSONResponse Error

func (AutoLayoutWorkflow500JSONResponse) VisitAutoLayoutWorkflowResponse

func (response AutoLayoutWorkflow500JSONResponse) VisitAutoLayoutWorkflowResponse(w http.ResponseWriter) error

type AutoLayoutWorkflowRequestObject

type AutoLayoutWorkflowRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
}

type AutoLayoutWorkflowResponseObject

type AutoLayoutWorkflowResponseObject interface {
	VisitAutoLayoutWorkflowResponse(w http.ResponseWriter) error
}

type ChatChoice

type ChatChoice struct {
	// FinishReason Reason for finishing a chat completion
	FinishReason *ChatFinishReason `json:"finish_reason,omitempty"`

	// Index Choice index
	Index   *int         `json:"index,omitempty"`
	Message *ChatMessage `json:"message,omitempty"`
}

ChatChoice defines model for ChatChoice.

type ChatFinishReason

type ChatFinishReason string

ChatFinishReason Reason for finishing a chat completion

const (
	ChatFinishReasonFunctionCall ChatFinishReason = "function_call"
	ChatFinishReasonLength       ChatFinishReason = "length"
	ChatFinishReasonStop         ChatFinishReason = "stop"
)

Defines values for ChatFinishReason.

type ChatMessage

type ChatMessage struct {
	// Content Message content
	Content      string        `json:"content"`
	FunctionCall *FunctionCall `json:"function_call,omitempty"`

	// Name Function name (for function role)
	Name *string `json:"name,omitempty"`

	// Role Role of a chat message
	Role ChatMessageRole `json:"role"`
}

ChatMessage defines model for ChatMessage.

type ChatMessageRole

type ChatMessageRole string

ChatMessageRole Role of a chat message

const (
	Assistant ChatMessageRole = "assistant"
	Function  ChatMessageRole = "function"
	System    ChatMessageRole = "system"
	User      ChatMessageRole = "user"
)

Defines values for ChatMessageRole.

type ChatUsage

type ChatUsage struct {
	// CompletionTokens Tokens used in completion
	CompletionTokens *int `json:"completion_tokens,omitempty"`

	// PromptTokens Tokens used in prompt
	PromptTokens *int `json:"prompt_tokens,omitempty"`

	// TotalTokens Total tokens used
	TotalTokens *int `json:"total_tokens,omitempty"`
}

ChatUsage defines model for ChatUsage.

type ChiServerOptions

type ChiServerOptions struct {
	BaseURL          string
	BaseRouter       chi.Router
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type ClaimWork200JSONResponse

type ClaimWork200JSONResponse []WorkItem

func (ClaimWork200JSONResponse) VisitClaimWorkResponse

func (response ClaimWork200JSONResponse) VisitClaimWorkResponse(w http.ResponseWriter) error

type ClaimWorkJSONRequestBody

type ClaimWorkJSONRequestBody = ClaimWorkRequest

ClaimWorkJSONRequestBody defines body for ClaimWork for application/json ContentType.

type ClaimWorkRequest

type ClaimWorkRequest struct {
	// MaxItems Maximum number of work items to claim
	MaxItems *int `json:"maxItems,omitempty"`
}

ClaimWorkRequest defines model for ClaimWorkRequest.

type ClaimWorkRequestObject

type ClaimWorkRequestObject struct {
	Id   string `json:"id"`
	Body *ClaimWorkJSONRequestBody
}

type ClaimWorkResponseObject

type ClaimWorkResponseObject interface {
	VisitClaimWorkResponse(w http.ResponseWriter) error
}

type CompleteWork200Response

type CompleteWork200Response struct {
}

func (CompleteWork200Response) VisitCompleteWorkResponse

func (response CompleteWork200Response) VisitCompleteWorkResponse(w http.ResponseWriter) error

type CompleteWorkJSONRequestBody

type CompleteWorkJSONRequestBody = CompleteWorkRequest

CompleteWorkJSONRequestBody defines body for CompleteWork for application/json ContentType.

type CompleteWorkRequest

type CompleteWorkRequest struct {
	// Error Error message if the work item failed
	Error  *string                 `json:"error,omitempty"`
	Result *map[string]interface{} `json:"result,omitempty"`
}

CompleteWorkRequest defines model for CompleteWorkRequest.

type CompleteWorkRequestObject

type CompleteWorkRequestObject struct {
	Id     string `json:"id"`
	ItemId string `json:"itemId"`
	Body   *CompleteWorkJSONRequestBody
}

type CompleteWorkResponseObject

type CompleteWorkResponseObject interface {
	VisitCompleteWorkResponse(w http.ResponseWriter) error
}

type Connection

type Connection struct {
	// Config Connection configuration containing non-sensitive connection parameters
	Config        *ConnectionConfig   `json:"config,omitempty"`
	CreatedAt     *time.Time          `json:"created_at,omitempty"`
	Id            *openapi_types.UUID `json:"id,omitempty"`
	IntegrationId *openapi_types.UUID `json:"integration_id,omitempty"`
	IsDefault     *bool               `json:"is_default,omitempty"`
	LastValidated *time.Time          `json:"last_validated,omitempty"`
	Name          *string             `json:"name,omitempty"`

	// Secret Connection secret configuration containing authentication credentials
	Secret *ConnectionSecret `json:"secret,omitempty"`

	// Status Status of a connection
	Status          *ConnectionStatus   `json:"status,omitempty"`
	UsageLimitMonth *int                `json:"usage_limit_month,omitempty"`
	UserId          *openapi_types.UUID `json:"user_id,omitempty"`
}

Connection defines model for Connection.

type ConnectionConfig

type ConnectionConfig map[string]interface{}

ConnectionConfig Connection configuration containing non-sensitive connection parameters

type ConnectionSecret

type ConnectionSecret map[string]interface{}

ConnectionSecret Connection secret configuration containing authentication credentials

type ConnectionStatus

type ConnectionStatus string

ConnectionStatus Status of a connection

const (
	ConnectionStatusExpired ConnectionStatus = "expired"
	ConnectionStatusInvalid ConnectionStatus = "invalid"
	ConnectionStatusValid   ConnectionStatus = "valid"
)

Defines values for ConnectionStatus.

type ControlWorkflowRunRequest

type ControlWorkflowRunRequest struct {
	Action string `json:"action"` // "pause", "resume", "cancel"
}

type CreateConnection201JSONResponse

type CreateConnection201JSONResponse Connection

func (CreateConnection201JSONResponse) VisitCreateConnectionResponse

func (response CreateConnection201JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection400JSONResponse

type CreateConnection400JSONResponse Error

func (CreateConnection400JSONResponse) VisitCreateConnectionResponse

func (response CreateConnection400JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection500JSONResponse

type CreateConnection500JSONResponse Error

func (CreateConnection500JSONResponse) VisitCreateConnectionResponse

func (response CreateConnection500JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnectionJSONRequestBody

type CreateConnectionJSONRequestBody = CreateConnectionRequest

CreateConnectionJSONRequestBody defines body for CreateConnection for application/json ContentType.

type CreateConnectionRequest

type CreateConnectionRequest struct {
	// Config Connection configuration containing non-sensitive connection parameters
	Config        *ConnectionConfig  `json:"config,omitempty"`
	IntegrationId openapi_types.UUID `json:"integration_id"`
	IsDefault     *bool              `json:"is_default,omitempty"`
	Name          string             `json:"name"`

	// Secret Connection secret configuration containing authentication credentials
	Secret          *ConnectionSecret `json:"secret,omitempty"`
	UsageLimitMonth *int              `json:"usage_limit_month,omitempty"`
}

CreateConnectionRequest defines model for CreateConnectionRequest.

type CreateConnectionRequestObject

type CreateConnectionRequestObject struct {
	Body *CreateConnectionJSONRequestBody
}

type CreateConnectionResponseObject

type CreateConnectionResponseObject interface {
	VisitCreateConnectionResponse(w http.ResponseWriter) error
}

type CreateTrigger201JSONResponse

type CreateTrigger201JSONResponse Trigger

func (CreateTrigger201JSONResponse) VisitCreateTriggerResponse

func (response CreateTrigger201JSONResponse) VisitCreateTriggerResponse(w http.ResponseWriter) error

type CreateTrigger400JSONResponse

type CreateTrigger400JSONResponse Error

func (CreateTrigger400JSONResponse) VisitCreateTriggerResponse

func (response CreateTrigger400JSONResponse) VisitCreateTriggerResponse(w http.ResponseWriter) error

type CreateTrigger500JSONResponse

type CreateTrigger500JSONResponse Error

func (CreateTrigger500JSONResponse) VisitCreateTriggerResponse

func (response CreateTrigger500JSONResponse) VisitCreateTriggerResponse(w http.ResponseWriter) error

type CreateTriggerJSONRequestBody

type CreateTriggerJSONRequestBody = CreateTriggerRequest

CreateTriggerJSONRequestBody defines body for CreateTrigger for application/json ContentType.

type CreateTriggerRequest

type CreateTriggerRequest struct {
	// Config Trigger configuration containing trigger-specific parameters and settings
	Config  *TriggerConfig `json:"config,omitempty"`
	Enabled *bool          `json:"enabled,omitempty"`
	Name    string         `json:"name"`

	// Type Type of trigger
	Type       TriggerType        `json:"type"`
	WorkflowId openapi_types.UUID `json:"workflow_id"`
}

CreateTriggerRequest defines model for CreateTriggerRequest.

type CreateTriggerRequestObject

type CreateTriggerRequestObject struct {
	Body *CreateTriggerJSONRequestBody
}

type CreateTriggerResponseObject

type CreateTriggerResponseObject interface {
	VisitCreateTriggerResponse(w http.ResponseWriter) error
}

type CreateWorkflow201JSONResponse

type CreateWorkflow201JSONResponse Workflow

func (CreateWorkflow201JSONResponse) VisitCreateWorkflowResponse

func (response CreateWorkflow201JSONResponse) VisitCreateWorkflowResponse(w http.ResponseWriter) error

type CreateWorkflow400JSONResponse

type CreateWorkflow400JSONResponse Error

func (CreateWorkflow400JSONResponse) VisitCreateWorkflowResponse

func (response CreateWorkflow400JSONResponse) VisitCreateWorkflowResponse(w http.ResponseWriter) error

type CreateWorkflow500JSONResponse

type CreateWorkflow500JSONResponse Error

func (CreateWorkflow500JSONResponse) VisitCreateWorkflowResponse

func (response CreateWorkflow500JSONResponse) VisitCreateWorkflowResponse(w http.ResponseWriter) error

type CreateWorkflowEdge201JSONResponse

type CreateWorkflowEdge201JSONResponse WorkflowEdge

func (CreateWorkflowEdge201JSONResponse) VisitCreateWorkflowEdgeResponse

func (response CreateWorkflowEdge201JSONResponse) VisitCreateWorkflowEdgeResponse(w http.ResponseWriter) error

type CreateWorkflowEdge400JSONResponse

type CreateWorkflowEdge400JSONResponse Error

func (CreateWorkflowEdge400JSONResponse) VisitCreateWorkflowEdgeResponse

func (response CreateWorkflowEdge400JSONResponse) VisitCreateWorkflowEdgeResponse(w http.ResponseWriter) error

type CreateWorkflowEdge404JSONResponse

type CreateWorkflowEdge404JSONResponse Error

func (CreateWorkflowEdge404JSONResponse) VisitCreateWorkflowEdgeResponse

func (response CreateWorkflowEdge404JSONResponse) VisitCreateWorkflowEdgeResponse(w http.ResponseWriter) error

type CreateWorkflowEdge500JSONResponse

type CreateWorkflowEdge500JSONResponse Error

func (CreateWorkflowEdge500JSONResponse) VisitCreateWorkflowEdgeResponse

func (response CreateWorkflowEdge500JSONResponse) VisitCreateWorkflowEdgeResponse(w http.ResponseWriter) error

type CreateWorkflowEdgeJSONRequestBody

type CreateWorkflowEdgeJSONRequestBody = CreateWorkflowEdgeRequest

CreateWorkflowEdgeJSONRequestBody defines body for CreateWorkflowEdge for application/json ContentType.

type CreateWorkflowEdgeRequest

type CreateWorkflowEdgeRequest struct {
	Id           string  `json:"id"`
	Source       string  `json:"source"`
	SourceOutput *string `json:"sourceOutput,omitempty"`
	Target       string  `json:"target"`
	TargetInput  *string `json:"targetInput,omitempty"`
}

CreateWorkflowEdgeRequest defines model for CreateWorkflowEdgeRequest.

type CreateWorkflowEdgeRequestObject

type CreateWorkflowEdgeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	Body       *CreateWorkflowEdgeJSONRequestBody
}

type CreateWorkflowEdgeResponseObject

type CreateWorkflowEdgeResponseObject interface {
	VisitCreateWorkflowEdgeResponse(w http.ResponseWriter) error
}

type CreateWorkflowJSONRequestBody

type CreateWorkflowJSONRequestBody = CreateWorkflowRequest

CreateWorkflowJSONRequestBody defines body for CreateWorkflow for application/json ContentType.

type CreateWorkflowNode201JSONResponse

type CreateWorkflowNode201JSONResponse WorkflowNode

func (CreateWorkflowNode201JSONResponse) VisitCreateWorkflowNodeResponse

func (response CreateWorkflowNode201JSONResponse) VisitCreateWorkflowNodeResponse(w http.ResponseWriter) error

type CreateWorkflowNode400JSONResponse

type CreateWorkflowNode400JSONResponse Error

func (CreateWorkflowNode400JSONResponse) VisitCreateWorkflowNodeResponse

func (response CreateWorkflowNode400JSONResponse) VisitCreateWorkflowNodeResponse(w http.ResponseWriter) error

type CreateWorkflowNode404JSONResponse

type CreateWorkflowNode404JSONResponse Error

func (CreateWorkflowNode404JSONResponse) VisitCreateWorkflowNodeResponse

func (response CreateWorkflowNode404JSONResponse) VisitCreateWorkflowNodeResponse(w http.ResponseWriter) error

type CreateWorkflowNode500JSONResponse

type CreateWorkflowNode500JSONResponse Error

func (CreateWorkflowNode500JSONResponse) VisitCreateWorkflowNodeResponse

func (response CreateWorkflowNode500JSONResponse) VisitCreateWorkflowNodeResponse(w http.ResponseWriter) error

type CreateWorkflowNodeJSONRequestBody

type CreateWorkflowNodeJSONRequestBody = CreateWorkflowNodeRequest

CreateWorkflowNodeJSONRequestBody defines body for CreateWorkflowNode for application/json ContentType.

type CreateWorkflowNodeRequest

type CreateWorkflowNodeRequest struct {
	// Config Node configuration containing node-specific parameters and settings
	Config NodeConfig `json:"config"`
	Id     string     `json:"id"`
	Name   string     `json:"name"`

	// Position Node position coordinates in the workflow canvas
	Position *NodePosition `json:"position,omitempty"`
	Type     string        `json:"type"`
}

CreateWorkflowNodeRequest defines model for CreateWorkflowNodeRequest.

type CreateWorkflowNodeRequestObject

type CreateWorkflowNodeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	Body       *CreateWorkflowNodeJSONRequestBody
}

type CreateWorkflowNodeResponseObject

type CreateWorkflowNodeResponseObject interface {
	VisitCreateWorkflowNodeResponse(w http.ResponseWriter) error
}

type CreateWorkflowRequest

type CreateWorkflowRequest struct {
	Definition  *WorkflowDefinition `json:"definition,omitempty"`
	Description *string             `json:"description,omitempty"`
	Name        string              `json:"name"`
}

CreateWorkflowRequest defines model for CreateWorkflowRequest.

type CreateWorkflowRequestObject

type CreateWorkflowRequestObject struct {
	Body *CreateWorkflowJSONRequestBody
}

type CreateWorkflowResponseObject

type CreateWorkflowResponseObject interface {
	VisitCreateWorkflowResponse(w http.ResponseWriter) error
}

type CreateWorkflowRunRequest

type CreateWorkflowRunRequest struct {
	AgentID        uuid.UUID             `json:"agent_id"`
	VersionID      uuid.UUID             `json:"version_id,omitempty"`
	TriggerID      *uuid.UUID            `json:"trigger_id,omitempty"`
	InputData      map[string]any        `json:"input_data,omitempty"`
	Variables      map[string]any        `json:"variables,omitempty"`
	TimeoutSeconds int                   `json:"timeout_seconds,omitempty"`
	RetryPolicy    execution.RetryPolicy `json:"retry_policy,omitempty"`
}

type CreateWorkflowVersion201JSONResponse

type CreateWorkflowVersion201JSONResponse WorkflowVersion

func (CreateWorkflowVersion201JSONResponse) VisitCreateWorkflowVersionResponse

func (response CreateWorkflowVersion201JSONResponse) VisitCreateWorkflowVersionResponse(w http.ResponseWriter) error

type CreateWorkflowVersion400JSONResponse

type CreateWorkflowVersion400JSONResponse Error

func (CreateWorkflowVersion400JSONResponse) VisitCreateWorkflowVersionResponse

func (response CreateWorkflowVersion400JSONResponse) VisitCreateWorkflowVersionResponse(w http.ResponseWriter) error

type CreateWorkflowVersion404JSONResponse

type CreateWorkflowVersion404JSONResponse Error

func (CreateWorkflowVersion404JSONResponse) VisitCreateWorkflowVersionResponse

func (response CreateWorkflowVersion404JSONResponse) VisitCreateWorkflowVersionResponse(w http.ResponseWriter) error

type CreateWorkflowVersion500JSONResponse

type CreateWorkflowVersion500JSONResponse Error

func (CreateWorkflowVersion500JSONResponse) VisitCreateWorkflowVersionResponse

func (response CreateWorkflowVersion500JSONResponse) VisitCreateWorkflowVersionResponse(w http.ResponseWriter) error

type CreateWorkflowVersionJSONRequestBody

type CreateWorkflowVersionJSONRequestBody = CreateWorkflowVersionRequest

CreateWorkflowVersionJSONRequestBody defines body for CreateWorkflowVersion for application/json ContentType.

type CreateWorkflowVersionRequest

type CreateWorkflowVersionRequest struct {
	Definition  *WorkflowDefinition `json:"definition,omitempty"`
	Description *string             `json:"description,omitempty"`
	Name        string              `json:"name"`
}

CreateWorkflowVersionRequest defines model for CreateWorkflowVersionRequest.

type CreateWorkflowVersionRequestObject

type CreateWorkflowVersionRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	Body       *CreateWorkflowVersionJSONRequestBody
}

type CreateWorkflowVersionResponseObject

type CreateWorkflowVersionResponseObject interface {
	VisitCreateWorkflowVersionResponse(w http.ResponseWriter) error
}

type Credential

type Credential struct {
	CreatedAt   *time.Time          `json:"created_at,omitempty"`
	Description *string             `json:"description,omitempty"`
	Id          *openapi_types.UUID `json:"id,omitempty"`
	LastUsed    *time.Time          `json:"last_used,omitempty"`
	Name        *string             `json:"name,omitempty"`

	// Status Status of a credential
	Status *CredentialStatus `json:"status,omitempty"`
	Type   *string           `json:"type,omitempty"`
}

Credential defines model for Credential.

type CredentialStatus

type CredentialStatus string

CredentialStatus Status of a credential

const (
	CredentialStatusExpired CredentialStatus = "expired"
	CredentialStatusInvalid CredentialStatus = "invalid"
	CredentialStatusRevoked CredentialStatus = "revoked"
	CredentialStatusValid   CredentialStatus = "valid"
)

Defines values for CredentialStatus.

type CredentialTestResult

type CredentialTestResult struct {
	Details *map[string]interface{} `json:"details,omitempty"`
	Error   *string                 `json:"error,omitempty"`
	Message *string                 `json:"message,omitempty"`
	Success *bool                   `json:"success,omitempty"`
}

CredentialTestResult defines model for CredentialTestResult.

type CredentialType

type CredentialType struct {
	Description    *string                 `json:"description,omitempty"`
	Id             *string                 `json:"id,omitempty"`
	Name           *string                 `json:"name,omitempty"`
	RequiredFields *[]string               `json:"required_fields,omitempty"`
	Schema         *map[string]interface{} `json:"schema,omitempty"`
	TestEndpoint   *string                 `json:"test_endpoint,omitempty"`
}

CredentialType defines model for CredentialType.

type CredentialTypeSchema

type CredentialTypeSchema struct {
	Description *string                 `json:"description,omitempty"`
	Properties  *map[string]interface{} `json:"properties,omitempty"`
	Required    *[]string               `json:"required,omitempty"`
	Title       *string                 `json:"title,omitempty"`
	Type        *string                 `json:"type,omitempty"`
}

CredentialTypeSchema defines model for CredentialTypeSchema.

type DefaultExecutor

type DefaultExecutor struct{}

DefaultExecutor performs no-op: returns input unchanged.

func (DefaultExecutor) Execute

func (DefaultExecutor) Execute(agentID string, node api.Node, input interface{}) (interface{}, error)

type DeleteConnection204Response

type DeleteConnection204Response struct {
}

func (DeleteConnection204Response) VisitDeleteConnectionResponse

func (response DeleteConnection204Response) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection404JSONResponse

type DeleteConnection404JSONResponse Error

func (DeleteConnection404JSONResponse) VisitDeleteConnectionResponse

func (response DeleteConnection404JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection500JSONResponse

type DeleteConnection500JSONResponse Error

func (DeleteConnection500JSONResponse) VisitDeleteConnectionResponse

func (response DeleteConnection500JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnectionRequestObject

type DeleteConnectionRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type DeleteConnectionResponseObject

type DeleteConnectionResponseObject interface {
	VisitDeleteConnectionResponse(w http.ResponseWriter) error
}

type DeleteTrigger204Response

type DeleteTrigger204Response struct {
}

func (DeleteTrigger204Response) VisitDeleteTriggerResponse

func (response DeleteTrigger204Response) VisitDeleteTriggerResponse(w http.ResponseWriter) error

type DeleteTrigger404JSONResponse

type DeleteTrigger404JSONResponse Error

func (DeleteTrigger404JSONResponse) VisitDeleteTriggerResponse

func (response DeleteTrigger404JSONResponse) VisitDeleteTriggerResponse(w http.ResponseWriter) error

type DeleteTrigger500JSONResponse

type DeleteTrigger500JSONResponse Error

func (DeleteTrigger500JSONResponse) VisitDeleteTriggerResponse

func (response DeleteTrigger500JSONResponse) VisitDeleteTriggerResponse(w http.ResponseWriter) error

type DeleteTriggerRequestObject

type DeleteTriggerRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type DeleteTriggerResponseObject

type DeleteTriggerResponseObject interface {
	VisitDeleteTriggerResponse(w http.ResponseWriter) error
}

type DeleteWorkflow204Response

type DeleteWorkflow204Response struct {
}

func (DeleteWorkflow204Response) VisitDeleteWorkflowResponse

func (response DeleteWorkflow204Response) VisitDeleteWorkflowResponse(w http.ResponseWriter) error

type DeleteWorkflow404JSONResponse

type DeleteWorkflow404JSONResponse Error

func (DeleteWorkflow404JSONResponse) VisitDeleteWorkflowResponse

func (response DeleteWorkflow404JSONResponse) VisitDeleteWorkflowResponse(w http.ResponseWriter) error

type DeleteWorkflow500JSONResponse

type DeleteWorkflow500JSONResponse Error

func (DeleteWorkflow500JSONResponse) VisitDeleteWorkflowResponse

func (response DeleteWorkflow500JSONResponse) VisitDeleteWorkflowResponse(w http.ResponseWriter) error

type DeleteWorkflowEdge204Response

type DeleteWorkflowEdge204Response struct {
}

func (DeleteWorkflowEdge204Response) VisitDeleteWorkflowEdgeResponse

func (response DeleteWorkflowEdge204Response) VisitDeleteWorkflowEdgeResponse(w http.ResponseWriter) error

type DeleteWorkflowEdge404JSONResponse

type DeleteWorkflowEdge404JSONResponse Error

func (DeleteWorkflowEdge404JSONResponse) VisitDeleteWorkflowEdgeResponse

func (response DeleteWorkflowEdge404JSONResponse) VisitDeleteWorkflowEdgeResponse(w http.ResponseWriter) error

type DeleteWorkflowEdge500JSONResponse

type DeleteWorkflowEdge500JSONResponse Error

func (DeleteWorkflowEdge500JSONResponse) VisitDeleteWorkflowEdgeResponse

func (response DeleteWorkflowEdge500JSONResponse) VisitDeleteWorkflowEdgeResponse(w http.ResponseWriter) error

type DeleteWorkflowEdgeRequestObject

type DeleteWorkflowEdgeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	EdgeId     string             `json:"edgeId"`
}

type DeleteWorkflowEdgeResponseObject

type DeleteWorkflowEdgeResponseObject interface {
	VisitDeleteWorkflowEdgeResponse(w http.ResponseWriter) error
}

type DeleteWorkflowNode204Response

type DeleteWorkflowNode204Response struct {
}

func (DeleteWorkflowNode204Response) VisitDeleteWorkflowNodeResponse

func (response DeleteWorkflowNode204Response) VisitDeleteWorkflowNodeResponse(w http.ResponseWriter) error

type DeleteWorkflowNode404JSONResponse

type DeleteWorkflowNode404JSONResponse Error

func (DeleteWorkflowNode404JSONResponse) VisitDeleteWorkflowNodeResponse

func (response DeleteWorkflowNode404JSONResponse) VisitDeleteWorkflowNodeResponse(w http.ResponseWriter) error

type DeleteWorkflowNode500JSONResponse

type DeleteWorkflowNode500JSONResponse Error

func (DeleteWorkflowNode500JSONResponse) VisitDeleteWorkflowNodeResponse

func (response DeleteWorkflowNode500JSONResponse) VisitDeleteWorkflowNodeResponse(w http.ResponseWriter) error

type DeleteWorkflowNodeRequestObject

type DeleteWorkflowNodeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	NodeId     string             `json:"nodeId"`
}

type DeleteWorkflowNodeResponseObject

type DeleteWorkflowNodeResponseObject interface {
	VisitDeleteWorkflowNodeResponse(w http.ResponseWriter) error
}

type DeleteWorkflowRequestObject

type DeleteWorkflowRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type DeleteWorkflowResponseObject

type DeleteWorkflowResponseObject interface {
	VisitDeleteWorkflowResponse(w http.ResponseWriter) error
}

type DeployWorkflowVersion200JSONResponse

type DeployWorkflowVersion200JSONResponse WorkflowVersion

func (DeployWorkflowVersion200JSONResponse) VisitDeployWorkflowVersionResponse

func (response DeployWorkflowVersion200JSONResponse) VisitDeployWorkflowVersionResponse(w http.ResponseWriter) error

type DeployWorkflowVersion404JSONResponse

type DeployWorkflowVersion404JSONResponse Error

func (DeployWorkflowVersion404JSONResponse) VisitDeployWorkflowVersionResponse

func (response DeployWorkflowVersion404JSONResponse) VisitDeployWorkflowVersionResponse(w http.ResponseWriter) error

type DeployWorkflowVersion500JSONResponse

type DeployWorkflowVersion500JSONResponse Error

func (DeployWorkflowVersion500JSONResponse) VisitDeployWorkflowVersionResponse

func (response DeployWorkflowVersion500JSONResponse) VisitDeployWorkflowVersionResponse(w http.ResponseWriter) error

type DeployWorkflowVersionRequestObject

type DeployWorkflowVersionRequestObject struct {
	WorkflowId    openapi_types.UUID `json:"workflowId"`
	VersionNumber int                `json:"versionNumber"`
}

type DeployWorkflowVersionResponseObject

type DeployWorkflowVersionResponseObject interface {
	VisitDeployWorkflowVersionResponse(w http.ResponseWriter) error
}

type Error

type Error struct {
	Code    *int    `json:"code,omitempty"`
	Error   *string `json:"error,omitempty"`
	Message *string `json:"message,omitempty"`
}

Error defines model for Error.

type ExecuteWorkflow200JSONResponse

type ExecuteWorkflow200JSONResponse WorkflowExecution

func (ExecuteWorkflow200JSONResponse) VisitExecuteWorkflowResponse

func (response ExecuteWorkflow200JSONResponse) VisitExecuteWorkflowResponse(w http.ResponseWriter) error

type ExecuteWorkflow400JSONResponse

type ExecuteWorkflow400JSONResponse Error

func (ExecuteWorkflow400JSONResponse) VisitExecuteWorkflowResponse

func (response ExecuteWorkflow400JSONResponse) VisitExecuteWorkflowResponse(w http.ResponseWriter) error

type ExecuteWorkflow404JSONResponse

type ExecuteWorkflow404JSONResponse Error

func (ExecuteWorkflow404JSONResponse) VisitExecuteWorkflowResponse

func (response ExecuteWorkflow404JSONResponse) VisitExecuteWorkflowResponse(w http.ResponseWriter) error

type ExecuteWorkflow500JSONResponse

type ExecuteWorkflow500JSONResponse Error

func (ExecuteWorkflow500JSONResponse) VisitExecuteWorkflowResponse

func (response ExecuteWorkflow500JSONResponse) VisitExecuteWorkflowResponse(w http.ResponseWriter) error

type ExecuteWorkflowJSONBody

type ExecuteWorkflowJSONBody struct {
	Input *map[string]interface{} `json:"input,omitempty"`
}

ExecuteWorkflowJSONBody defines parameters for ExecuteWorkflow.

type ExecuteWorkflowJSONRequestBody

type ExecuteWorkflowJSONRequestBody ExecuteWorkflowJSONBody

ExecuteWorkflowJSONRequestBody defines body for ExecuteWorkflow for application/json ContentType.

type ExecuteWorkflowRequest

type ExecuteWorkflowRequest struct {
	// Input Generic input object containing arbitrary input data
	Input *GenericInput `json:"input,omitempty"`
}

ExecuteWorkflowRequest defines model for ExecuteWorkflowRequest.

type ExecuteWorkflowRequestObject

type ExecuteWorkflowRequestObject struct {
	Id   openapi_types.UUID `json:"id"`
	Body *ExecuteWorkflowJSONRequestBody
}

type ExecuteWorkflowResponseObject

type ExecuteWorkflowResponseObject interface {
	VisitExecuteWorkflowResponse(w http.ResponseWriter) error
}

type Extension

type Extension struct {
	// Categories Extension types provided (e.g. "node", "trigger")
	Categories []string `json:"categories"`

	// Id Unique plugin identifier
	Id string `json:"id"`

	// Params Parameter schema for configuration/UI
	Params *[]ParamSpec `json:"params,omitempty"`

	// UiComponent Optional path or URL to React bundle
	UiComponent *string `json:"ui_component,omitempty"`

	// Version Semver-compliant version string
	Version string `json:"version"`
}

Extension defines model for Extension.

type FunctionCall

type FunctionCall struct {
	// Arguments Function arguments as JSON string
	Arguments *string `json:"arguments,omitempty"`

	// Name Function name
	Name *string `json:"name,omitempty"`
}

FunctionCall defines model for FunctionCall.

type GenericInput

type GenericInput map[string]interface{}

GenericInput Generic input object containing arbitrary input data

type GenericOutput

type GenericOutput map[string]interface{}

GenericOutput Generic output object containing arbitrary output data

type GenericPayload

type GenericPayload map[string]interface{}

GenericPayload Generic payload object containing arbitrary data

type GenericResult

type GenericResult map[string]interface{}

GenericResult Generic result object containing arbitrary result data

type GetConnection200JSONResponse

type GetConnection200JSONResponse Connection

func (GetConnection200JSONResponse) VisitGetConnectionResponse

func (response GetConnection200JSONResponse) VisitGetConnectionResponse(w http.ResponseWriter) error

type GetConnection404JSONResponse

type GetConnection404JSONResponse Error

func (GetConnection404JSONResponse) VisitGetConnectionResponse

func (response GetConnection404JSONResponse) VisitGetConnectionResponse(w http.ResponseWriter) error

type GetConnection500JSONResponse

type GetConnection500JSONResponse Error

func (GetConnection500JSONResponse) VisitGetConnectionResponse

func (response GetConnection500JSONResponse) VisitGetConnectionResponse(w http.ResponseWriter) error

type GetConnectionRequestObject

type GetConnectionRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type GetConnectionResponseObject

type GetConnectionResponseObject interface {
	VisitGetConnectionResponse(w http.ResponseWriter) error
}

type GetCredentialTypeSchema200JSONResponse

type GetCredentialTypeSchema200JSONResponse CredentialTypeSchema

func (GetCredentialTypeSchema200JSONResponse) VisitGetCredentialTypeSchemaResponse

func (response GetCredentialTypeSchema200JSONResponse) VisitGetCredentialTypeSchemaResponse(w http.ResponseWriter) error

type GetCredentialTypeSchema404JSONResponse

type GetCredentialTypeSchema404JSONResponse Error

func (GetCredentialTypeSchema404JSONResponse) VisitGetCredentialTypeSchemaResponse

func (response GetCredentialTypeSchema404JSONResponse) VisitGetCredentialTypeSchemaResponse(w http.ResponseWriter) error

type GetCredentialTypeSchema500JSONResponse

type GetCredentialTypeSchema500JSONResponse Error

func (GetCredentialTypeSchema500JSONResponse) VisitGetCredentialTypeSchemaResponse

func (response GetCredentialTypeSchema500JSONResponse) VisitGetCredentialTypeSchemaResponse(w http.ResponseWriter) error

type GetCredentialTypeSchemaRequestObject

type GetCredentialTypeSchemaRequestObject struct {
	Type string `json:"type"`
}

type GetCredentialTypeSchemaResponseObject

type GetCredentialTypeSchemaResponseObject interface {
	VisitGetCredentialTypeSchemaResponse(w http.ResponseWriter) error
}

type GetHealth200JSONResponse

type GetHealth200JSONResponse struct {
	Status *string `json:"status,omitempty"`
}

func (GetHealth200JSONResponse) VisitGetHealthResponse

func (response GetHealth200JSONResponse) VisitGetHealthResponse(w http.ResponseWriter) error

type GetHealth503JSONResponse

type GetHealth503JSONResponse Error

func (GetHealth503JSONResponse) VisitGetHealthResponse

func (response GetHealth503JSONResponse) VisitGetHealthResponse(w http.ResponseWriter) error

type GetHealthRequestObject

type GetHealthRequestObject struct {
}

type GetHealthResponseObject

type GetHealthResponseObject interface {
	VisitGetHealthResponse(w http.ResponseWriter) error
}

type GetLatestWorkflowVersion200JSONResponse

type GetLatestWorkflowVersion200JSONResponse WorkflowVersion

func (GetLatestWorkflowVersion200JSONResponse) VisitGetLatestWorkflowVersionResponse

func (response GetLatestWorkflowVersion200JSONResponse) VisitGetLatestWorkflowVersionResponse(w http.ResponseWriter) error

type GetLatestWorkflowVersion404JSONResponse

type GetLatestWorkflowVersion404JSONResponse Error

func (GetLatestWorkflowVersion404JSONResponse) VisitGetLatestWorkflowVersionResponse

func (response GetLatestWorkflowVersion404JSONResponse) VisitGetLatestWorkflowVersionResponse(w http.ResponseWriter) error

type GetLatestWorkflowVersion500JSONResponse

type GetLatestWorkflowVersion500JSONResponse Error

func (GetLatestWorkflowVersion500JSONResponse) VisitGetLatestWorkflowVersionResponse

func (response GetLatestWorkflowVersion500JSONResponse) VisitGetLatestWorkflowVersionResponse(w http.ResponseWriter) error

type GetLatestWorkflowVersionRequestObject

type GetLatestWorkflowVersionRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
}

type GetLatestWorkflowVersionResponseObject

type GetLatestWorkflowVersionResponseObject interface {
	VisitGetLatestWorkflowVersionResponse(w http.ResponseWriter) error
}

type GetNodeParameterOptions200JSONResponse

type GetNodeParameterOptions200JSONResponse NodeParameterOptions

func (GetNodeParameterOptions200JSONResponse) VisitGetNodeParameterOptionsResponse

func (response GetNodeParameterOptions200JSONResponse) VisitGetNodeParameterOptionsResponse(w http.ResponseWriter) error

type GetNodeParameterOptions404JSONResponse

type GetNodeParameterOptions404JSONResponse Error

func (GetNodeParameterOptions404JSONResponse) VisitGetNodeParameterOptionsResponse

func (response GetNodeParameterOptions404JSONResponse) VisitGetNodeParameterOptionsResponse(w http.ResponseWriter) error

type GetNodeParameterOptions500JSONResponse

type GetNodeParameterOptions500JSONResponse Error

func (GetNodeParameterOptions500JSONResponse) VisitGetNodeParameterOptionsResponse

func (response GetNodeParameterOptions500JSONResponse) VisitGetNodeParameterOptionsResponse(w http.ResponseWriter) error

type GetNodeParameterOptionsParams

type GetNodeParameterOptionsParams struct {
	// Context Context for dynamic option generation
	Context *string `form:"context,omitempty" json:"context,omitempty"`
}

GetNodeParameterOptionsParams defines parameters for GetNodeParameterOptions.

type GetNodeParameterOptionsRequestObject

type GetNodeParameterOptionsRequestObject struct {
	Type      string `json:"type"`
	Parameter string `json:"parameter"`
	Params    GetNodeParameterOptionsParams
}

type GetNodeParameterOptionsResponseObject

type GetNodeParameterOptionsResponseObject interface {
	VisitGetNodeParameterOptionsResponse(w http.ResponseWriter) error
}

type GetTrigger200JSONResponse

type GetTrigger200JSONResponse Trigger

func (GetTrigger200JSONResponse) VisitGetTriggerResponse

func (response GetTrigger200JSONResponse) VisitGetTriggerResponse(w http.ResponseWriter) error

type GetTrigger404JSONResponse

type GetTrigger404JSONResponse Error

func (GetTrigger404JSONResponse) VisitGetTriggerResponse

func (response GetTrigger404JSONResponse) VisitGetTriggerResponse(w http.ResponseWriter) error

type GetTrigger500JSONResponse

type GetTrigger500JSONResponse Error

func (GetTrigger500JSONResponse) VisitGetTriggerResponse

func (response GetTrigger500JSONResponse) VisitGetTriggerResponse(w http.ResponseWriter) error

type GetTriggerRequestObject

type GetTriggerRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type GetTriggerResponseObject

type GetTriggerResponseObject interface {
	VisitGetTriggerResponse(w http.ResponseWriter) error
}

type GetWorkflow200JSONResponse

type GetWorkflow200JSONResponse Workflow

func (GetWorkflow200JSONResponse) VisitGetWorkflowResponse

func (response GetWorkflow200JSONResponse) VisitGetWorkflowResponse(w http.ResponseWriter) error

type GetWorkflow404JSONResponse

type GetWorkflow404JSONResponse Error

func (GetWorkflow404JSONResponse) VisitGetWorkflowResponse

func (response GetWorkflow404JSONResponse) VisitGetWorkflowResponse(w http.ResponseWriter) error

type GetWorkflow500JSONResponse

type GetWorkflow500JSONResponse Error

func (GetWorkflow500JSONResponse) VisitGetWorkflowResponse

func (response GetWorkflow500JSONResponse) VisitGetWorkflowResponse(w http.ResponseWriter) error

type GetWorkflowDraft200JSONResponse

type GetWorkflowDraft200JSONResponse WorkflowDraft

func (GetWorkflowDraft200JSONResponse) VisitGetWorkflowDraftResponse

func (response GetWorkflowDraft200JSONResponse) VisitGetWorkflowDraftResponse(w http.ResponseWriter) error

type GetWorkflowDraft404JSONResponse

type GetWorkflowDraft404JSONResponse Error

func (GetWorkflowDraft404JSONResponse) VisitGetWorkflowDraftResponse

func (response GetWorkflowDraft404JSONResponse) VisitGetWorkflowDraftResponse(w http.ResponseWriter) error

type GetWorkflowDraft500JSONResponse

type GetWorkflowDraft500JSONResponse Error

func (GetWorkflowDraft500JSONResponse) VisitGetWorkflowDraftResponse

func (response GetWorkflowDraft500JSONResponse) VisitGetWorkflowDraftResponse(w http.ResponseWriter) error

type GetWorkflowDraftRequestObject

type GetWorkflowDraftRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
}

type GetWorkflowDraftResponseObject

type GetWorkflowDraftResponseObject interface {
	VisitGetWorkflowDraftResponse(w http.ResponseWriter) error
}

type GetWorkflowNode200JSONResponse

type GetWorkflowNode200JSONResponse WorkflowNode

func (GetWorkflowNode200JSONResponse) VisitGetWorkflowNodeResponse

func (response GetWorkflowNode200JSONResponse) VisitGetWorkflowNodeResponse(w http.ResponseWriter) error

type GetWorkflowNode404JSONResponse

type GetWorkflowNode404JSONResponse Error

func (GetWorkflowNode404JSONResponse) VisitGetWorkflowNodeResponse

func (response GetWorkflowNode404JSONResponse) VisitGetWorkflowNodeResponse(w http.ResponseWriter) error

type GetWorkflowNode500JSONResponse

type GetWorkflowNode500JSONResponse Error

func (GetWorkflowNode500JSONResponse) VisitGetWorkflowNodeResponse

func (response GetWorkflowNode500JSONResponse) VisitGetWorkflowNodeResponse(w http.ResponseWriter) error

type GetWorkflowNodeRequestObject

type GetWorkflowNodeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	NodeId     string             `json:"nodeId"`
}

type GetWorkflowNodeResponseObject

type GetWorkflowNodeResponseObject interface {
	VisitGetWorkflowNodeResponse(w http.ResponseWriter) error
}

type GetWorkflowRequestObject

type GetWorkflowRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type GetWorkflowResponseObject

type GetWorkflowResponseObject interface {
	VisitGetWorkflowResponse(w http.ResponseWriter) error
}

type GetWorkflowRun200JSONResponse

type GetWorkflowRun200JSONResponse WorkflowRun

func (GetWorkflowRun200JSONResponse) VisitGetWorkflowRunResponse

func (response GetWorkflowRun200JSONResponse) VisitGetWorkflowRunResponse(w http.ResponseWriter) error

type GetWorkflowRun404JSONResponse

type GetWorkflowRun404JSONResponse Error

func (GetWorkflowRun404JSONResponse) VisitGetWorkflowRunResponse

func (response GetWorkflowRun404JSONResponse) VisitGetWorkflowRunResponse(w http.ResponseWriter) error

type GetWorkflowRun500JSONResponse

type GetWorkflowRun500JSONResponse Error

func (GetWorkflowRun500JSONResponse) VisitGetWorkflowRunResponse

func (response GetWorkflowRun500JSONResponse) VisitGetWorkflowRunResponse(w http.ResponseWriter) error

type GetWorkflowRunRequestObject

type GetWorkflowRunRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type GetWorkflowRunResponseObject

type GetWorkflowRunResponseObject interface {
	VisitGetWorkflowRunResponse(w http.ResponseWriter) error
}

type GetWorkflowRunSteps200JSONResponse

type GetWorkflowRunSteps200JSONResponse []WorkflowStep

func (GetWorkflowRunSteps200JSONResponse) VisitGetWorkflowRunStepsResponse

func (response GetWorkflowRunSteps200JSONResponse) VisitGetWorkflowRunStepsResponse(w http.ResponseWriter) error

type GetWorkflowRunSteps404JSONResponse

type GetWorkflowRunSteps404JSONResponse Error

func (GetWorkflowRunSteps404JSONResponse) VisitGetWorkflowRunStepsResponse

func (response GetWorkflowRunSteps404JSONResponse) VisitGetWorkflowRunStepsResponse(w http.ResponseWriter) error

type GetWorkflowRunSteps500JSONResponse

type GetWorkflowRunSteps500JSONResponse Error

func (GetWorkflowRunSteps500JSONResponse) VisitGetWorkflowRunStepsResponse

func (response GetWorkflowRunSteps500JSONResponse) VisitGetWorkflowRunStepsResponse(w http.ResponseWriter) error

type GetWorkflowRunStepsRequestObject

type GetWorkflowRunStepsRequestObject struct {
	Id openapi_types.UUID `json:"id"`
}

type GetWorkflowRunStepsResponseObject

type GetWorkflowRunStepsResponseObject interface {
	VisitGetWorkflowRunStepsResponse(w http.ResponseWriter) error
}

type HTTPRequestExecutor

type HTTPRequestExecutor struct{}

HTTPRequestExecutor performs an HTTP call as configured in node.Data.

func (HTTPRequestExecutor) Execute

func (HTTPRequestExecutor) Execute(agentID string, node api.Node, input interface{}) (interface{}, error)

type HandleWebhook200Response

type HandleWebhook200Response struct {
}

func (HandleWebhook200Response) VisitHandleWebhookResponse

func (response HandleWebhook200Response) VisitHandleWebhookResponse(w http.ResponseWriter) error

type HandleWebhook404JSONResponse

type HandleWebhook404JSONResponse Error

func (HandleWebhook404JSONResponse) VisitHandleWebhookResponse

func (response HandleWebhook404JSONResponse) VisitHandleWebhookResponse(w http.ResponseWriter) error

type HandleWebhook500JSONResponse

type HandleWebhook500JSONResponse Error

func (HandleWebhook500JSONResponse) VisitHandleWebhookResponse

func (response HandleWebhook500JSONResponse) VisitHandleWebhookResponse(w http.ResponseWriter) error

type HandleWebhookJSONRequestBody

type HandleWebhookJSONRequestBody = WebhookPayload

HandleWebhookJSONRequestBody defines body for HandleWebhook for application/json ContentType.

type HandleWebhookRequestObject

type HandleWebhookRequestObject struct {
	Token string `json:"token"`
	Body  *HandleWebhookJSONRequestBody
}

type HandleWebhookResponseObject

type HandleWebhookResponseObject interface {
	VisitHandleWebhookResponse(w http.ResponseWriter) error
}

type Hub

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

Hub maintains active websocket clients for an agent and broadcasts messages to them.

func GetHub

func GetHub(agentID string) *Hub

GetHub returns the Hub for a given agentID, creating it if necessary.

func (*Hub) Broadcast

func (h *Hub) Broadcast(message []byte)

Broadcast sends a message to all registered clients (exported).

type IfExecutor

type IfExecutor struct{}

IfExecutor filters items based on a boolean condition.

func (IfExecutor) Execute

func (IfExecutor) Execute(agentID string, node api.Node, input interface{}) (interface{}, error)

type Integration

type Integration struct {
	Capabilities *[]string  `json:"capabilities,omitempty"`
	CreatedAt    *time.Time `json:"created_at,omitempty"`

	// CredentialType Type of credential required for this integration
	CredentialType *string             `json:"credential_type,omitempty"`
	Description    *string             `json:"description,omitempty"`
	Id             *openapi_types.UUID `json:"id,omitempty"`
	Name           *string             `json:"name,omitempty"`

	// Status Status of an integration
	Status    *IntegrationStatus `json:"status,omitempty"`
	Type      *string            `json:"type,omitempty"`
	UpdatedAt *time.Time         `json:"updated_at,omitempty"`
}

Integration defines model for Integration.

type IntegrationStatus

type IntegrationStatus string

IntegrationStatus Status of an integration

const (
	IntegrationStatusActive   IntegrationStatus = "active"
	IntegrationStatusInactive IntegrationStatus = "inactive"
)

Defines values for IntegrationStatus.

type InvalidParamFormatError

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

func (*InvalidParamFormatError) Error

func (e *InvalidParamFormatError) Error() string

func (*InvalidParamFormatError) Unwrap

func (e *InvalidParamFormatError) Unwrap() error

type ListConnections200JSONResponse

type ListConnections200JSONResponse []Connection

func (ListConnections200JSONResponse) VisitListConnectionsResponse

func (response ListConnections200JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnections500JSONResponse

type ListConnections500JSONResponse Error

func (ListConnections500JSONResponse) VisitListConnectionsResponse

func (response ListConnections500JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnectionsRequestObject

type ListConnectionsRequestObject struct {
}

type ListConnectionsResponseObject

type ListConnectionsResponseObject interface {
	VisitListConnectionsResponse(w http.ResponseWriter) error
}

type ListCredentialTypes200JSONResponse

type ListCredentialTypes200JSONResponse []CredentialType

func (ListCredentialTypes200JSONResponse) VisitListCredentialTypesResponse

func (response ListCredentialTypes200JSONResponse) VisitListCredentialTypesResponse(w http.ResponseWriter) error

type ListCredentialTypes500JSONResponse

type ListCredentialTypes500JSONResponse Error

func (ListCredentialTypes500JSONResponse) VisitListCredentialTypesResponse

func (response ListCredentialTypes500JSONResponse) VisitListCredentialTypesResponse(w http.ResponseWriter) error

type ListCredentialTypesRequestObject

type ListCredentialTypesRequestObject struct {
}

type ListCredentialTypesResponseObject

type ListCredentialTypesResponseObject interface {
	VisitListCredentialTypesResponse(w http.ResponseWriter) error
}

type ListCredentials200JSONResponse

type ListCredentials200JSONResponse []Credential

func (ListCredentials200JSONResponse) VisitListCredentialsResponse

func (response ListCredentials200JSONResponse) VisitListCredentialsResponse(w http.ResponseWriter) error

type ListCredentials500JSONResponse

type ListCredentials500JSONResponse Error

func (ListCredentials500JSONResponse) VisitListCredentialsResponse

func (response ListCredentials500JSONResponse) VisitListCredentialsResponse(w http.ResponseWriter) error

type ListCredentialsParams

type ListCredentialsParams struct {
	// CredentialType Filter by credential type
	CredentialType *string `form:"credential_type,omitempty" json:"credential_type,omitempty"`
}

ListCredentialsParams defines parameters for ListCredentials.

type ListCredentialsRequestObject

type ListCredentialsRequestObject struct {
	Params ListCredentialsParams
}

type ListCredentialsResponseObject

type ListCredentialsResponseObject interface {
	VisitListCredentialsResponse(w http.ResponseWriter) error
}

type ListExtensions200JSONResponse

type ListExtensions200JSONResponse []Extension

func (ListExtensions200JSONResponse) VisitListExtensionsResponse

func (response ListExtensions200JSONResponse) VisitListExtensionsResponse(w http.ResponseWriter) error

type ListExtensions500JSONResponse

type ListExtensions500JSONResponse Error

func (ListExtensions500JSONResponse) VisitListExtensionsResponse

func (response ListExtensions500JSONResponse) VisitListExtensionsResponse(w http.ResponseWriter) error

type ListExtensionsRequestObject

type ListExtensionsRequestObject struct {
}

type ListExtensionsResponseObject

type ListExtensionsResponseObject interface {
	VisitListExtensionsResponse(w http.ResponseWriter) error
}

type ListIntegrations200JSONResponse

type ListIntegrations200JSONResponse []Integration

func (ListIntegrations200JSONResponse) VisitListIntegrationsResponse

func (response ListIntegrations200JSONResponse) VisitListIntegrationsResponse(w http.ResponseWriter) error

type ListIntegrations500JSONResponse

type ListIntegrations500JSONResponse Error

func (ListIntegrations500JSONResponse) VisitListIntegrationsResponse

func (response ListIntegrations500JSONResponse) VisitListIntegrationsResponse(w http.ResponseWriter) error

type ListIntegrationsRequestObject

type ListIntegrationsRequestObject struct {
}

type ListIntegrationsResponseObject

type ListIntegrationsResponseObject interface {
	VisitListIntegrationsResponse(w http.ResponseWriter) error
}

type ListNodeTypes200JSONResponse

type ListNodeTypes200JSONResponse []NodeType

func (ListNodeTypes200JSONResponse) VisitListNodeTypesResponse

func (response ListNodeTypes200JSONResponse) VisitListNodeTypesResponse(w http.ResponseWriter) error

type ListNodeTypesParams

type ListNodeTypesParams struct {
	// Kind Filter by node kind (can be comma-separated)
	Kind *string `form:"kind,omitempty" json:"kind,omitempty"`
}

ListNodeTypesParams defines parameters for ListNodeTypes.

type ListNodeTypesRequestObject

type ListNodeTypesRequestObject struct {
	Params ListNodeTypesParams
}

type ListNodeTypesResponseObject

type ListNodeTypesResponseObject interface {
	VisitListNodeTypesResponse(w http.ResponseWriter) error
}

type ListTriggers200JSONResponse

type ListTriggers200JSONResponse []Trigger

func (ListTriggers200JSONResponse) VisitListTriggersResponse

func (response ListTriggers200JSONResponse) VisitListTriggersResponse(w http.ResponseWriter) error

type ListTriggers500JSONResponse

type ListTriggers500JSONResponse Error

func (ListTriggers500JSONResponse) VisitListTriggersResponse

func (response ListTriggers500JSONResponse) VisitListTriggersResponse(w http.ResponseWriter) error

type ListTriggersRequestObject

type ListTriggersRequestObject struct {
}

type ListTriggersResponseObject

type ListTriggersResponseObject interface {
	VisitListTriggersResponse(w http.ResponseWriter) error
}

type ListWorkers200JSONResponse

type ListWorkers200JSONResponse []Worker

func (ListWorkers200JSONResponse) VisitListWorkersResponse

func (response ListWorkers200JSONResponse) VisitListWorkersResponse(w http.ResponseWriter) error

type ListWorkers500JSONResponse

type ListWorkers500JSONResponse Error

func (ListWorkers500JSONResponse) VisitListWorkersResponse

func (response ListWorkers500JSONResponse) VisitListWorkersResponse(w http.ResponseWriter) error

type ListWorkersRequestObject

type ListWorkersRequestObject struct {
}

type ListWorkersResponseObject

type ListWorkersResponseObject interface {
	VisitListWorkersResponse(w http.ResponseWriter) error
}

type ListWorkflowEdges200JSONResponse

type ListWorkflowEdges200JSONResponse []WorkflowEdge

func (ListWorkflowEdges200JSONResponse) VisitListWorkflowEdgesResponse

func (response ListWorkflowEdges200JSONResponse) VisitListWorkflowEdgesResponse(w http.ResponseWriter) error

type ListWorkflowEdges404JSONResponse

type ListWorkflowEdges404JSONResponse Error

func (ListWorkflowEdges404JSONResponse) VisitListWorkflowEdgesResponse

func (response ListWorkflowEdges404JSONResponse) VisitListWorkflowEdgesResponse(w http.ResponseWriter) error

type ListWorkflowEdges500JSONResponse

type ListWorkflowEdges500JSONResponse Error

func (ListWorkflowEdges500JSONResponse) VisitListWorkflowEdgesResponse

func (response ListWorkflowEdges500JSONResponse) VisitListWorkflowEdgesResponse(w http.ResponseWriter) error

type ListWorkflowEdgesRequestObject

type ListWorkflowEdgesRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
}

type ListWorkflowEdgesResponseObject

type ListWorkflowEdgesResponseObject interface {
	VisitListWorkflowEdgesResponse(w http.ResponseWriter) error
}

type ListWorkflowNodes200JSONResponse

type ListWorkflowNodes200JSONResponse []WorkflowNode

func (ListWorkflowNodes200JSONResponse) VisitListWorkflowNodesResponse

func (response ListWorkflowNodes200JSONResponse) VisitListWorkflowNodesResponse(w http.ResponseWriter) error

type ListWorkflowNodes404JSONResponse

type ListWorkflowNodes404JSONResponse Error

func (ListWorkflowNodes404JSONResponse) VisitListWorkflowNodesResponse

func (response ListWorkflowNodes404JSONResponse) VisitListWorkflowNodesResponse(w http.ResponseWriter) error

type ListWorkflowNodes500JSONResponse

type ListWorkflowNodes500JSONResponse Error

func (ListWorkflowNodes500JSONResponse) VisitListWorkflowNodesResponse

func (response ListWorkflowNodes500JSONResponse) VisitListWorkflowNodesResponse(w http.ResponseWriter) error

type ListWorkflowNodesRequestObject

type ListWorkflowNodesRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
}

type ListWorkflowNodesResponseObject

type ListWorkflowNodesResponseObject interface {
	VisitListWorkflowNodesResponse(w http.ResponseWriter) error
}

type ListWorkflowRuns200JSONResponse

type ListWorkflowRuns200JSONResponse WorkflowRunList

func (ListWorkflowRuns200JSONResponse) VisitListWorkflowRunsResponse

func (response ListWorkflowRuns200JSONResponse) VisitListWorkflowRunsResponse(w http.ResponseWriter) error

type ListWorkflowRuns500JSONResponse

type ListWorkflowRuns500JSONResponse Error

func (ListWorkflowRuns500JSONResponse) VisitListWorkflowRunsResponse

func (response ListWorkflowRuns500JSONResponse) VisitListWorkflowRunsResponse(w http.ResponseWriter) error

type ListWorkflowRunsParams

type ListWorkflowRunsParams struct {
	WorkflowId *openapi_types.UUID `form:"workflow_id,omitempty" json:"workflow_id,omitempty"`
	Status     *WorkflowRunStatus  `form:"status,omitempty" json:"status,omitempty"`
	Page       *int                `form:"page,omitempty" json:"page,omitempty"`
	Limit      *int                `form:"limit,omitempty" json:"limit,omitempty"`
}

ListWorkflowRunsParams defines parameters for ListWorkflowRuns.

type ListWorkflowRunsRequestObject

type ListWorkflowRunsRequestObject struct {
	Params ListWorkflowRunsParams
}

type ListWorkflowRunsResponseObject

type ListWorkflowRunsResponseObject interface {
	VisitListWorkflowRunsResponse(w http.ResponseWriter) error
}

type ListWorkflowVersions200JSONResponse

type ListWorkflowVersions200JSONResponse WorkflowVersionList

func (ListWorkflowVersions200JSONResponse) VisitListWorkflowVersionsResponse

func (response ListWorkflowVersions200JSONResponse) VisitListWorkflowVersionsResponse(w http.ResponseWriter) error

type ListWorkflowVersions404JSONResponse

type ListWorkflowVersions404JSONResponse Error

func (ListWorkflowVersions404JSONResponse) VisitListWorkflowVersionsResponse

func (response ListWorkflowVersions404JSONResponse) VisitListWorkflowVersionsResponse(w http.ResponseWriter) error

type ListWorkflowVersions500JSONResponse

type ListWorkflowVersions500JSONResponse Error

func (ListWorkflowVersions500JSONResponse) VisitListWorkflowVersionsResponse

func (response ListWorkflowVersions500JSONResponse) VisitListWorkflowVersionsResponse(w http.ResponseWriter) error

type ListWorkflowVersionsParams

type ListWorkflowVersionsParams struct {
	Page  *int `form:"page,omitempty" json:"page,omitempty"`
	Limit *int `form:"limit,omitempty" json:"limit,omitempty"`
}

ListWorkflowVersionsParams defines parameters for ListWorkflowVersions.

type ListWorkflowVersionsRequestObject

type ListWorkflowVersionsRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	Params     ListWorkflowVersionsParams
}

type ListWorkflowVersionsResponseObject

type ListWorkflowVersionsResponseObject interface {
	VisitListWorkflowVersionsResponse(w http.ResponseWriter) error
}

type ListWorkflows200JSONResponse

type ListWorkflows200JSONResponse WorkflowList

func (ListWorkflows200JSONResponse) VisitListWorkflowsResponse

func (response ListWorkflows200JSONResponse) VisitListWorkflowsResponse(w http.ResponseWriter) error

type ListWorkflows500JSONResponse

type ListWorkflows500JSONResponse Error

func (ListWorkflows500JSONResponse) VisitListWorkflowsResponse

func (response ListWorkflows500JSONResponse) VisitListWorkflowsResponse(w http.ResponseWriter) error

type ListWorkflowsParams

type ListWorkflowsParams struct {
	Page  *int `form:"page,omitempty" json:"page,omitempty"`
	Limit *int `form:"limit,omitempty" json:"limit,omitempty"`
}

ListWorkflowsParams defines parameters for ListWorkflows.

type ListWorkflowsRequestObject

type ListWorkflowsRequestObject struct {
	Params ListWorkflowsParams
}

type ListWorkflowsResponseObject

type ListWorkflowsResponseObject interface {
	VisitListWorkflowsResponse(w http.ResponseWriter) error
}

type MiddlewareFunc

type MiddlewareFunc func(http.Handler) http.Handler

type NodeConfig

type NodeConfig map[string]interface{}

NodeConfig Node configuration containing node-specific parameters and settings

type NodeExecutor

type NodeExecutor interface {
	Execute(agentID string, node api.Node, input interface{}) (interface{}, error)
}

NodeExecutor defines execution logic for a node type.

type NodeInput

type NodeInput struct {
	Description *string `json:"description,omitempty"`
	Name        *string `json:"name,omitempty"`
	Required    *bool   `json:"required,omitempty"`
	Type        *string `json:"type,omitempty"`
}

NodeInput defines model for NodeInput.

type NodeKind

type NodeKind string

NodeKind Kind of node functionality

const (
	NodeKindAction  NodeKind = "action"
	NodeKindMemory  NodeKind = "memory"
	NodeKindModel   NodeKind = "model"
	NodeKindTool    NodeKind = "tool"
	NodeKindTrigger NodeKind = "trigger"
)

Defines values for NodeKind.

type NodeOutput

type NodeOutput struct {
	Description *string `json:"description,omitempty"`
	Name        *string `json:"name,omitempty"`
	Type        *string `json:"type,omitempty"`
}

NodeOutput defines model for NodeOutput.

type NodeParameterOptions

type NodeParameterOptions struct {
	ContextDependent *bool `json:"context_dependent,omitempty"`
	Dynamic          *bool `json:"dynamic,omitempty"`
	Options          *[]struct {
		Description *string `json:"description,omitempty"`
		Label       *string `json:"label,omitempty"`
		Value       *string `json:"value,omitempty"`
	} `json:"options,omitempty"`
}

NodeParameterOptions defines model for NodeParameterOptions.

type NodePosition

type NodePosition struct {
	// X X coordinate position
	X *float32 `json:"x,omitempty"`

	// Y Y coordinate position
	Y *float32 `json:"y,omitempty"`
}

NodePosition Node position coordinates in the workflow canvas

type NodeTestResult

type NodeTestResult struct {
	Error         *string                 `json:"error,omitempty"`
	ExecutionTime *float32                `json:"execution_time,omitempty"`
	Logs          *[]string               `json:"logs,omitempty"`
	Output        *map[string]interface{} `json:"output,omitempty"`
	Success       *bool                   `json:"success,omitempty"`
}

NodeTestResult defines model for NodeTestResult.

type NodeType

type NodeType struct {
	Description *string       `json:"description,omitempty"`
	Id          *string       `json:"id,omitempty"`
	Inputs      *[]NodeInput  `json:"inputs,omitempty"`
	Kinds       *[]NodeKind   `json:"kinds,omitempty"`
	Name        *string       `json:"name,omitempty"`
	Outputs     *[]NodeOutput `json:"outputs,omitempty"`
}

NodeType defines model for NodeType.

type OpenAPIHandlers

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

OpenAPIHandlers implements the StrictServerInterface for type-safe OpenAPI handling

func NewOpenAPIHandlers

func NewOpenAPIHandlers(database *sql.DB, engine execution.ExecutionEngine, openAIAPIKey string) *OpenAPIHandlers

NewOpenAPIHandlers creates a new OpenAPI handlers instance

func (*OpenAPIHandlers) AssistantChat

AssistantChat provides AI-powered assistance for workflow building

func (*OpenAPIHandlers) AutoLayoutWorkflow

AutoLayoutWorkflow auto-layouts workflow nodes

func (*OpenAPIHandlers) ClaimWork

ClaimWork allows a worker to claim work items

func (*OpenAPIHandlers) CompleteWork

CompleteWork marks a work item as completed

func (*OpenAPIHandlers) CreateConnection

CreateConnection creates a new connection

func (*OpenAPIHandlers) CreateTrigger

CreateTrigger creates a new trigger

func (*OpenAPIHandlers) CreateWorkflow

CreateWorkflow creates a new workflow

func (*OpenAPIHandlers) CreateWorkflowEdge

CreateWorkflowEdge creates a new edge in workflow

func (*OpenAPIHandlers) CreateWorkflowNode

CreateWorkflowNode creates a new node in workflow

func (*OpenAPIHandlers) CreateWorkflowVersion

CreateWorkflowVersion creates a new version of a workflow

func (*OpenAPIHandlers) DeleteConnection

DeleteConnection removes a connection

func (*OpenAPIHandlers) DeleteTrigger

DeleteTrigger removes a trigger

func (*OpenAPIHandlers) DeleteWorkflow

DeleteWorkflow removes a workflow

func (*OpenAPIHandlers) DeleteWorkflowEdge

DeleteWorkflowEdge deletes a workflow edge

func (*OpenAPIHandlers) DeleteWorkflowNode

DeleteWorkflowNode deletes a workflow node

func (*OpenAPIHandlers) DeployWorkflowVersion

DeployWorkflowVersion deploys a specific version of a workflow (makes it current)

func (*OpenAPIHandlers) ExecuteWorkflow

ExecuteWorkflow executes a workflow

func (*OpenAPIHandlers) GetConnection

GetConnection retrieves a single connection by ID

func (*OpenAPIHandlers) GetCredentialTypeSchema

GetCredentialTypeSchema gets JSON schema for credential type

func (*OpenAPIHandlers) GetHealth

GetHealth implements the health check endpoint

func (*OpenAPIHandlers) GetLatestWorkflowVersion

GetLatestWorkflowVersion gets the latest version of a workflow

func (*OpenAPIHandlers) GetNodeParameterOptions

GetNodeParameterOptions gets dynamic options for node parameters

func (*OpenAPIHandlers) GetTrigger

GetTrigger retrieves a single trigger by ID

func (*OpenAPIHandlers) GetWorkflow

GetWorkflow retrieves a single workflow by ID

func (*OpenAPIHandlers) GetWorkflowDraft

GetWorkflowDraft gets the current draft of a workflow

func (*OpenAPIHandlers) GetWorkflowNode

GetWorkflowNode retrieves a specific workflow node

func (*OpenAPIHandlers) GetWorkflowRun

GetWorkflowRun retrieves a single workflow run by ID

func (*OpenAPIHandlers) GetWorkflowRunSteps

GetWorkflowRunSteps retrieves steps for a workflow run

func (*OpenAPIHandlers) HandleWebhook

HandleWebhook processes incoming webhook requests

func (*OpenAPIHandlers) ListConnections

ListConnections retrieves all connections

func (*OpenAPIHandlers) ListCredentialTypes

ListCredentialTypes lists credential type definitions

func (*OpenAPIHandlers) ListCredentials

ListCredentials lists credentials for selection in nodes

func (*OpenAPIHandlers) ListExtensions

ListExtensions implements the listExtensions operation.

func (*OpenAPIHandlers) ListIntegrations

ListIntegrations lists available integrations

func (*OpenAPIHandlers) ListNodeTypes

ListNodeTypes returns all registered node type metadata

func (*OpenAPIHandlers) ListTriggers

ListTriggers retrieves all triggers

func (*OpenAPIHandlers) ListWorkers

ListWorkers retrieves all workers

func (*OpenAPIHandlers) ListWorkflowEdges

ListWorkflowEdges lists all edges in a workflow

func (*OpenAPIHandlers) ListWorkflowNodes

ListWorkflowNodes lists all nodes in a workflow

func (*OpenAPIHandlers) ListWorkflowRuns

ListWorkflowRuns retrieves workflow runs with optional filtering

func (*OpenAPIHandlers) ListWorkflowVersions

ListWorkflowVersions lists all versions of a workflow

func (*OpenAPIHandlers) ListWorkflows

ListWorkflows retrieves all workflows with pagination

func (*OpenAPIHandlers) RegisterWorker

RegisterWorker registers a new worker

func (*OpenAPIHandlers) TestCredentials

TestCredentials tests credentials for a specific type

func (*OpenAPIHandlers) TestWorkflowDraftNode

TestWorkflowDraftNode tests a single node in the workflow draft

func (*OpenAPIHandlers) UnregisterWorker

UnregisterWorker removes a worker

func (*OpenAPIHandlers) UpdateConnection

UpdateConnection updates an existing connection

func (*OpenAPIHandlers) UpdateTrigger

UpdateTrigger updates an existing trigger

func (*OpenAPIHandlers) UpdateWorkerHeartbeat

UpdateWorkerHeartbeat updates a worker's heartbeat

func (*OpenAPIHandlers) UpdateWorkflow

UpdateWorkflow updates an existing workflow

func (*OpenAPIHandlers) UpdateWorkflowDraft

UpdateWorkflowDraft updates the draft of a workflow

func (*OpenAPIHandlers) UpdateWorkflowNode

UpdateWorkflowNode updates a workflow node

type PaginatedResponse

type PaginatedResponse struct {
	Data       any            `json:"data"`
	Pagination PaginationInfo `json:"pagination"`
}

type PaginationInfo

type PaginationInfo struct {
	Limit   int  `json:"limit"`
	Offset  int  `json:"offset"`
	Total   int  `json:"total"`
	HasMore bool `json:"has_more"`
}

type ParamSpec

type ParamSpec struct {
	// Default Default value
	Default *interface{} `json:"default,omitempty"`

	// Description Help text
	Description *string `json:"description,omitempty"`

	// Group UI grouping
	Group *string `json:"group,omitempty"`

	// Label User-facing label
	Label *string `json:"label,omitempty"`

	// Name Key name
	Name string `json:"name"`

	// Options Enum options
	Options *[]string `json:"options,omitempty"`

	// Required Must be provided
	Required *bool `json:"required,omitempty"`

	// Type Data type (e.g. "string", "number", "enum")
	Type string `json:"type"`

	// Validators Validation rules
	Validators *[]ValidatorSpec `json:"validators,omitempty"`

	// VisibilityCondition Conditional display expression
	VisibilityCondition *string `json:"visibility_condition,omitempty"`
}

ParamSpec defines model for ParamSpec.

type RegisterWorker201JSONResponse

type RegisterWorker201JSONResponse Worker

func (RegisterWorker201JSONResponse) VisitRegisterWorkerResponse

func (response RegisterWorker201JSONResponse) VisitRegisterWorkerResponse(w http.ResponseWriter) error

type RegisterWorker400JSONResponse

type RegisterWorker400JSONResponse Error

func (RegisterWorker400JSONResponse) VisitRegisterWorkerResponse

func (response RegisterWorker400JSONResponse) VisitRegisterWorkerResponse(w http.ResponseWriter) error

type RegisterWorker500JSONResponse

type RegisterWorker500JSONResponse Error

func (RegisterWorker500JSONResponse) VisitRegisterWorkerResponse

func (response RegisterWorker500JSONResponse) VisitRegisterWorkerResponse(w http.ResponseWriter) error

type RegisterWorkerJSONRequestBody

type RegisterWorkerJSONRequestBody = RegisterWorkerRequest

RegisterWorkerJSONRequestBody defines body for RegisterWorker for application/json ContentType.

type RegisterWorkerRequest

type RegisterWorkerRequest struct {
	Concurrency *int    `json:"concurrency,omitempty"`
	Id          string  `json:"id"`
	Name        *string `json:"name,omitempty"`
}

RegisterWorkerRequest defines model for RegisterWorkerRequest.

type RegisterWorkerRequestObject

type RegisterWorkerRequestObject struct {
	Body *RegisterWorkerJSONRequestBody
}

type RegisterWorkerResponseObject

type RegisterWorkerResponseObject interface {
	VisitRegisterWorkerResponse(w http.ResponseWriter) error
}

type RequiredHeaderError

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

func (*RequiredHeaderError) Error

func (e *RequiredHeaderError) Error() string

func (*RequiredHeaderError) Unwrap

func (e *RequiredHeaderError) Unwrap() error

type RequiredParamError

type RequiredParamError struct {
	ParamName string
}

func (*RequiredParamError) Error

func (e *RequiredParamError) Error() string

type ScheduleExecutor

type ScheduleExecutor struct{}

ScheduleExecutor emits a scheduled event with current timestamp and cron spec.

func (ScheduleExecutor) Execute

func (ScheduleExecutor) Execute(agentID string, node api.Node, input interface{}) (interface{}, error)

type ServerInterface

type ServerInterface interface {
	// Chat with AI assistant
	// (POST /api/assistant/chat)
	AssistantChat(w http.ResponseWriter, r *http.Request)
	// List connections
	// (GET /api/connections)
	ListConnections(w http.ResponseWriter, r *http.Request)
	// Create a connection
	// (POST /api/connections)
	CreateConnection(w http.ResponseWriter, r *http.Request)
	// Delete connection
	// (DELETE /api/connections/{id})
	DeleteConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Get connection by ID
	// (GET /api/connections/{id})
	GetConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Update connection
	// (PUT /api/connections/{id})
	UpdateConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// List credential type definitions
	// (GET /api/credential-types)
	ListCredentialTypes(w http.ResponseWriter, r *http.Request)
	// Get JSON schema for credential type
	// (GET /api/credential-types/{type}/schema)
	GetCredentialTypeSchema(w http.ResponseWriter, r *http.Request, pType string)
	// Test credentials for a specific type
	// (POST /api/credential-types/{type}/test)
	TestCredentials(w http.ResponseWriter, r *http.Request, pType string)
	// List credentials for selection in nodes
	// (GET /api/credentials)
	ListCredentials(w http.ResponseWriter, r *http.Request, params ListCredentialsParams)
	// List available extensions and plugins
	// (GET /api/extensions)
	ListExtensions(w http.ResponseWriter, r *http.Request)
	// Health check endpoint
	// (GET /api/health)
	GetHealth(w http.ResponseWriter, r *http.Request)
	// List available integrations
	// (GET /api/integrations)
	ListIntegrations(w http.ResponseWriter, r *http.Request)
	// List available node types
	// (GET /api/node-types)
	ListNodeTypes(w http.ResponseWriter, r *http.Request, params ListNodeTypesParams)
	// Get dynamic options for node parameters
	// (GET /api/node-types/{type}/parameters/{parameter}/options)
	GetNodeParameterOptions(w http.ResponseWriter, r *http.Request, pType string, parameter string, params GetNodeParameterOptionsParams)
	// List triggers
	// (GET /api/triggers)
	ListTriggers(w http.ResponseWriter, r *http.Request)
	// Create a trigger
	// (POST /api/triggers)
	CreateTrigger(w http.ResponseWriter, r *http.Request)
	// Delete trigger
	// (DELETE /api/triggers/{id})
	DeleteTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Get trigger by ID
	// (GET /api/triggers/{id})
	GetTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Update trigger
	// (PUT /api/triggers/{id})
	UpdateTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// List all workers
	// (GET /api/workers)
	ListWorkers(w http.ResponseWriter, r *http.Request)
	// Register a new worker
	// (POST /api/workers)
	RegisterWorker(w http.ResponseWriter, r *http.Request)
	// Unregister a worker
	// (DELETE /api/workers/{id})
	UnregisterWorker(w http.ResponseWriter, r *http.Request, id string)
	// Claim work items
	// (POST /api/workers/{id}/claim-work)
	ClaimWork(w http.ResponseWriter, r *http.Request, id string)
	// Complete a work item
	// (POST /api/workers/{id}/complete-work/{itemId})
	CompleteWork(w http.ResponseWriter, r *http.Request, id string, itemId string)
	// Update worker heartbeat
	// (PUT /api/workers/{id}/heartbeat)
	UpdateWorkerHeartbeat(w http.ResponseWriter, r *http.Request, id string)
	// List workflow runs
	// (GET /api/workflow-runs)
	ListWorkflowRuns(w http.ResponseWriter, r *http.Request, params ListWorkflowRunsParams)
	// Get workflow run details
	// (GET /api/workflow-runs/{id})
	GetWorkflowRun(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Get workflow run steps
	// (GET /api/workflow-runs/{id}/steps)
	GetWorkflowRunSteps(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// List all workflows
	// (GET /api/workflows)
	ListWorkflows(w http.ResponseWriter, r *http.Request, params ListWorkflowsParams)
	// Create a new workflow
	// (POST /api/workflows)
	CreateWorkflow(w http.ResponseWriter, r *http.Request)
	// Delete workflow
	// (DELETE /api/workflows/{id})
	DeleteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Get workflow by ID
	// (GET /api/workflows/{id})
	GetWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Update workflow
	// (PUT /api/workflows/{id})
	UpdateWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Execute a workflow
	// (POST /api/workflows/{id}/execute)
	ExecuteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
	// Get current draft for a workflow
	// (GET /api/workflows/{workflowId}/draft)
	GetWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Update workflow draft with auto-persistence
	// (PUT /api/workflows/{workflowId}/draft)
	UpdateWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Test a single node in draft context
	// (POST /api/workflows/{workflowId}/draft/nodes/{nodeId}/test)
	TestWorkflowDraftNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)
	// List all edges in a workflow
	// (GET /api/workflows/{workflowId}/edges)
	ListWorkflowEdges(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Create a new edge in workflow
	// (POST /api/workflows/{workflowId}/edges)
	CreateWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Delete workflow edge
	// (DELETE /api/workflows/{workflowId}/edges/{edgeId})
	DeleteWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, edgeId string)
	// Auto-layout workflow nodes
	// (POST /api/workflows/{workflowId}/layout)
	AutoLayoutWorkflow(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// List all nodes in a workflow
	// (GET /api/workflows/{workflowId}/nodes)
	ListWorkflowNodes(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Create a new node in workflow
	// (POST /api/workflows/{workflowId}/nodes)
	CreateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Delete workflow node
	// (DELETE /api/workflows/{workflowId}/nodes/{nodeId})
	DeleteWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)
	// Get specific workflow node
	// (GET /api/workflows/{workflowId}/nodes/{nodeId})
	GetWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)
	// Update workflow node
	// (PUT /api/workflows/{workflowId}/nodes/{nodeId})
	UpdateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)
	// List all versions of a workflow
	// (GET /api/workflows/{workflowId}/versions)
	ListWorkflowVersions(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, params ListWorkflowVersionsParams)
	// Create a new workflow version
	// (POST /api/workflows/{workflowId}/versions)
	CreateWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Get latest version of a workflow
	// (GET /api/workflows/{workflowId}/versions/latest)
	GetLatestWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
	// Deploy a specific workflow version
	// (POST /api/workflows/{workflowId}/versions/{versionNumber}/deploy)
	DeployWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, versionNumber int)
	// Webhook endpoint
	// (POST /webhooks/{token})
	HandleWebhook(w http.ResponseWriter, r *http.Request, token string)
}

ServerInterface represents all server handlers.

func NewStrictHandler

func NewStrictHandler(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc) ServerInterface

func NewStrictHandlerWithOptions

func NewStrictHandlerWithOptions(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc, options StrictHTTPServerOptions) ServerInterface

type ServerInterfaceWrapper

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) AssistantChat

func (siw *ServerInterfaceWrapper) AssistantChat(w http.ResponseWriter, r *http.Request)

AssistantChat operation middleware

func (*ServerInterfaceWrapper) AutoLayoutWorkflow

func (siw *ServerInterfaceWrapper) AutoLayoutWorkflow(w http.ResponseWriter, r *http.Request)

AutoLayoutWorkflow operation middleware

func (*ServerInterfaceWrapper) ClaimWork

func (siw *ServerInterfaceWrapper) ClaimWork(w http.ResponseWriter, r *http.Request)

ClaimWork operation middleware

func (*ServerInterfaceWrapper) CompleteWork

func (siw *ServerInterfaceWrapper) CompleteWork(w http.ResponseWriter, r *http.Request)

CompleteWork operation middleware

func (*ServerInterfaceWrapper) CreateConnection

func (siw *ServerInterfaceWrapper) CreateConnection(w http.ResponseWriter, r *http.Request)

CreateConnection operation middleware

func (*ServerInterfaceWrapper) CreateTrigger

func (siw *ServerInterfaceWrapper) CreateTrigger(w http.ResponseWriter, r *http.Request)

CreateTrigger operation middleware

func (*ServerInterfaceWrapper) CreateWorkflow

func (siw *ServerInterfaceWrapper) CreateWorkflow(w http.ResponseWriter, r *http.Request)

CreateWorkflow operation middleware

func (*ServerInterfaceWrapper) CreateWorkflowEdge

func (siw *ServerInterfaceWrapper) CreateWorkflowEdge(w http.ResponseWriter, r *http.Request)

CreateWorkflowEdge operation middleware

func (*ServerInterfaceWrapper) CreateWorkflowNode

func (siw *ServerInterfaceWrapper) CreateWorkflowNode(w http.ResponseWriter, r *http.Request)

CreateWorkflowNode operation middleware

func (*ServerInterfaceWrapper) CreateWorkflowVersion

func (siw *ServerInterfaceWrapper) CreateWorkflowVersion(w http.ResponseWriter, r *http.Request)

CreateWorkflowVersion operation middleware

func (*ServerInterfaceWrapper) DeleteConnection

func (siw *ServerInterfaceWrapper) DeleteConnection(w http.ResponseWriter, r *http.Request)

DeleteConnection operation middleware

func (*ServerInterfaceWrapper) DeleteTrigger

func (siw *ServerInterfaceWrapper) DeleteTrigger(w http.ResponseWriter, r *http.Request)

DeleteTrigger operation middleware

func (*ServerInterfaceWrapper) DeleteWorkflow

func (siw *ServerInterfaceWrapper) DeleteWorkflow(w http.ResponseWriter, r *http.Request)

DeleteWorkflow operation middleware

func (*ServerInterfaceWrapper) DeleteWorkflowEdge

func (siw *ServerInterfaceWrapper) DeleteWorkflowEdge(w http.ResponseWriter, r *http.Request)

DeleteWorkflowEdge operation middleware

func (*ServerInterfaceWrapper) DeleteWorkflowNode

func (siw *ServerInterfaceWrapper) DeleteWorkflowNode(w http.ResponseWriter, r *http.Request)

DeleteWorkflowNode operation middleware

func (*ServerInterfaceWrapper) DeployWorkflowVersion

func (siw *ServerInterfaceWrapper) DeployWorkflowVersion(w http.ResponseWriter, r *http.Request)

DeployWorkflowVersion operation middleware

func (*ServerInterfaceWrapper) ExecuteWorkflow

func (siw *ServerInterfaceWrapper) ExecuteWorkflow(w http.ResponseWriter, r *http.Request)

ExecuteWorkflow operation middleware

func (*ServerInterfaceWrapper) GetConnection

func (siw *ServerInterfaceWrapper) GetConnection(w http.ResponseWriter, r *http.Request)

GetConnection operation middleware

func (*ServerInterfaceWrapper) GetCredentialTypeSchema

func (siw *ServerInterfaceWrapper) GetCredentialTypeSchema(w http.ResponseWriter, r *http.Request)

GetCredentialTypeSchema operation middleware

func (*ServerInterfaceWrapper) GetHealth

func (siw *ServerInterfaceWrapper) GetHealth(w http.ResponseWriter, r *http.Request)

GetHealth operation middleware

func (*ServerInterfaceWrapper) GetLatestWorkflowVersion

func (siw *ServerInterfaceWrapper) GetLatestWorkflowVersion(w http.ResponseWriter, r *http.Request)

GetLatestWorkflowVersion operation middleware

func (*ServerInterfaceWrapper) GetNodeParameterOptions

func (siw *ServerInterfaceWrapper) GetNodeParameterOptions(w http.ResponseWriter, r *http.Request)

GetNodeParameterOptions operation middleware

func (*ServerInterfaceWrapper) GetTrigger

func (siw *ServerInterfaceWrapper) GetTrigger(w http.ResponseWriter, r *http.Request)

GetTrigger operation middleware

func (*ServerInterfaceWrapper) GetWorkflow

func (siw *ServerInterfaceWrapper) GetWorkflow(w http.ResponseWriter, r *http.Request)

GetWorkflow operation middleware

func (*ServerInterfaceWrapper) GetWorkflowDraft

func (siw *ServerInterfaceWrapper) GetWorkflowDraft(w http.ResponseWriter, r *http.Request)

GetWorkflowDraft operation middleware

func (*ServerInterfaceWrapper) GetWorkflowNode

func (siw *ServerInterfaceWrapper) GetWorkflowNode(w http.ResponseWriter, r *http.Request)

GetWorkflowNode operation middleware

func (*ServerInterfaceWrapper) GetWorkflowRun

func (siw *ServerInterfaceWrapper) GetWorkflowRun(w http.ResponseWriter, r *http.Request)

GetWorkflowRun operation middleware

func (*ServerInterfaceWrapper) GetWorkflowRunSteps

func (siw *ServerInterfaceWrapper) GetWorkflowRunSteps(w http.ResponseWriter, r *http.Request)

GetWorkflowRunSteps operation middleware

func (*ServerInterfaceWrapper) HandleWebhook

func (siw *ServerInterfaceWrapper) HandleWebhook(w http.ResponseWriter, r *http.Request)

HandleWebhook operation middleware

func (*ServerInterfaceWrapper) ListConnections

func (siw *ServerInterfaceWrapper) ListConnections(w http.ResponseWriter, r *http.Request)

ListConnections operation middleware

func (*ServerInterfaceWrapper) ListCredentialTypes

func (siw *ServerInterfaceWrapper) ListCredentialTypes(w http.ResponseWriter, r *http.Request)

ListCredentialTypes operation middleware

func (*ServerInterfaceWrapper) ListCredentials

func (siw *ServerInterfaceWrapper) ListCredentials(w http.ResponseWriter, r *http.Request)

ListCredentials operation middleware

func (*ServerInterfaceWrapper) ListExtensions

func (siw *ServerInterfaceWrapper) ListExtensions(w http.ResponseWriter, r *http.Request)

ListExtensions operation middleware

func (*ServerInterfaceWrapper) ListIntegrations

func (siw *ServerInterfaceWrapper) ListIntegrations(w http.ResponseWriter, r *http.Request)

ListIntegrations operation middleware

func (*ServerInterfaceWrapper) ListNodeTypes

func (siw *ServerInterfaceWrapper) ListNodeTypes(w http.ResponseWriter, r *http.Request)

ListNodeTypes operation middleware

func (*ServerInterfaceWrapper) ListTriggers

func (siw *ServerInterfaceWrapper) ListTriggers(w http.ResponseWriter, r *http.Request)

ListTriggers operation middleware

func (*ServerInterfaceWrapper) ListWorkers

func (siw *ServerInterfaceWrapper) ListWorkers(w http.ResponseWriter, r *http.Request)

ListWorkers operation middleware

func (*ServerInterfaceWrapper) ListWorkflowEdges

func (siw *ServerInterfaceWrapper) ListWorkflowEdges(w http.ResponseWriter, r *http.Request)

ListWorkflowEdges operation middleware

func (*ServerInterfaceWrapper) ListWorkflowNodes

func (siw *ServerInterfaceWrapper) ListWorkflowNodes(w http.ResponseWriter, r *http.Request)

ListWorkflowNodes operation middleware

func (*ServerInterfaceWrapper) ListWorkflowRuns

func (siw *ServerInterfaceWrapper) ListWorkflowRuns(w http.ResponseWriter, r *http.Request)

ListWorkflowRuns operation middleware

func (*ServerInterfaceWrapper) ListWorkflowVersions

func (siw *ServerInterfaceWrapper) ListWorkflowVersions(w http.ResponseWriter, r *http.Request)

ListWorkflowVersions operation middleware

func (*ServerInterfaceWrapper) ListWorkflows

func (siw *ServerInterfaceWrapper) ListWorkflows(w http.ResponseWriter, r *http.Request)

ListWorkflows operation middleware

func (*ServerInterfaceWrapper) RegisterWorker

func (siw *ServerInterfaceWrapper) RegisterWorker(w http.ResponseWriter, r *http.Request)

RegisterWorker operation middleware

func (*ServerInterfaceWrapper) TestCredentials

func (siw *ServerInterfaceWrapper) TestCredentials(w http.ResponseWriter, r *http.Request)

TestCredentials operation middleware

func (*ServerInterfaceWrapper) TestWorkflowDraftNode

func (siw *ServerInterfaceWrapper) TestWorkflowDraftNode(w http.ResponseWriter, r *http.Request)

TestWorkflowDraftNode operation middleware

func (*ServerInterfaceWrapper) UnregisterWorker

func (siw *ServerInterfaceWrapper) UnregisterWorker(w http.ResponseWriter, r *http.Request)

UnregisterWorker operation middleware

func (*ServerInterfaceWrapper) UpdateConnection

func (siw *ServerInterfaceWrapper) UpdateConnection(w http.ResponseWriter, r *http.Request)

UpdateConnection operation middleware

func (*ServerInterfaceWrapper) UpdateTrigger

func (siw *ServerInterfaceWrapper) UpdateTrigger(w http.ResponseWriter, r *http.Request)

UpdateTrigger operation middleware

func (*ServerInterfaceWrapper) UpdateWorkerHeartbeat

func (siw *ServerInterfaceWrapper) UpdateWorkerHeartbeat(w http.ResponseWriter, r *http.Request)

UpdateWorkerHeartbeat operation middleware

func (*ServerInterfaceWrapper) UpdateWorkflow

func (siw *ServerInterfaceWrapper) UpdateWorkflow(w http.ResponseWriter, r *http.Request)

UpdateWorkflow operation middleware

func (*ServerInterfaceWrapper) UpdateWorkflowDraft

func (siw *ServerInterfaceWrapper) UpdateWorkflowDraft(w http.ResponseWriter, r *http.Request)

UpdateWorkflowDraft operation middleware

func (*ServerInterfaceWrapper) UpdateWorkflowNode

func (siw *ServerInterfaceWrapper) UpdateWorkflowNode(w http.ResponseWriter, r *http.Request)

UpdateWorkflowNode operation middleware

type StrictHTTPServerOptions

type StrictHTTPServerOptions struct {
	RequestErrorHandlerFunc  func(w http.ResponseWriter, r *http.Request, err error)
	ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictServerInterface

type StrictServerInterface interface {
	// Chat with AI assistant
	// (POST /api/assistant/chat)
	AssistantChat(ctx context.Context, request AssistantChatRequestObject) (AssistantChatResponseObject, error)
	// List connections
	// (GET /api/connections)
	ListConnections(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)
	// Create a connection
	// (POST /api/connections)
	CreateConnection(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)
	// Delete connection
	// (DELETE /api/connections/{id})
	DeleteConnection(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)
	// Get connection by ID
	// (GET /api/connections/{id})
	GetConnection(ctx context.Context, request GetConnectionRequestObject) (GetConnectionResponseObject, error)
	// Update connection
	// (PUT /api/connections/{id})
	UpdateConnection(ctx context.Context, request UpdateConnectionRequestObject) (UpdateConnectionResponseObject, error)
	// List credential type definitions
	// (GET /api/credential-types)
	ListCredentialTypes(ctx context.Context, request ListCredentialTypesRequestObject) (ListCredentialTypesResponseObject, error)
	// Get JSON schema for credential type
	// (GET /api/credential-types/{type}/schema)
	GetCredentialTypeSchema(ctx context.Context, request GetCredentialTypeSchemaRequestObject) (GetCredentialTypeSchemaResponseObject, error)
	// Test credentials for a specific type
	// (POST /api/credential-types/{type}/test)
	TestCredentials(ctx context.Context, request TestCredentialsRequestObject) (TestCredentialsResponseObject, error)
	// List credentials for selection in nodes
	// (GET /api/credentials)
	ListCredentials(ctx context.Context, request ListCredentialsRequestObject) (ListCredentialsResponseObject, error)
	// List available extensions and plugins
	// (GET /api/extensions)
	ListExtensions(ctx context.Context, request ListExtensionsRequestObject) (ListExtensionsResponseObject, error)
	// Health check endpoint
	// (GET /api/health)
	GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
	// List available integrations
	// (GET /api/integrations)
	ListIntegrations(ctx context.Context, request ListIntegrationsRequestObject) (ListIntegrationsResponseObject, error)
	// List available node types
	// (GET /api/node-types)
	ListNodeTypes(ctx context.Context, request ListNodeTypesRequestObject) (ListNodeTypesResponseObject, error)
	// Get dynamic options for node parameters
	// (GET /api/node-types/{type}/parameters/{parameter}/options)
	GetNodeParameterOptions(ctx context.Context, request GetNodeParameterOptionsRequestObject) (GetNodeParameterOptionsResponseObject, error)
	// List triggers
	// (GET /api/triggers)
	ListTriggers(ctx context.Context, request ListTriggersRequestObject) (ListTriggersResponseObject, error)
	// Create a trigger
	// (POST /api/triggers)
	CreateTrigger(ctx context.Context, request CreateTriggerRequestObject) (CreateTriggerResponseObject, error)
	// Delete trigger
	// (DELETE /api/triggers/{id})
	DeleteTrigger(ctx context.Context, request DeleteTriggerRequestObject) (DeleteTriggerResponseObject, error)
	// Get trigger by ID
	// (GET /api/triggers/{id})
	GetTrigger(ctx context.Context, request GetTriggerRequestObject) (GetTriggerResponseObject, error)
	// Update trigger
	// (PUT /api/triggers/{id})
	UpdateTrigger(ctx context.Context, request UpdateTriggerRequestObject) (UpdateTriggerResponseObject, error)
	// List all workers
	// (GET /api/workers)
	ListWorkers(ctx context.Context, request ListWorkersRequestObject) (ListWorkersResponseObject, error)
	// Register a new worker
	// (POST /api/workers)
	RegisterWorker(ctx context.Context, request RegisterWorkerRequestObject) (RegisterWorkerResponseObject, error)
	// Unregister a worker
	// (DELETE /api/workers/{id})
	UnregisterWorker(ctx context.Context, request UnregisterWorkerRequestObject) (UnregisterWorkerResponseObject, error)
	// Claim work items
	// (POST /api/workers/{id}/claim-work)
	ClaimWork(ctx context.Context, request ClaimWorkRequestObject) (ClaimWorkResponseObject, error)
	// Complete a work item
	// (POST /api/workers/{id}/complete-work/{itemId})
	CompleteWork(ctx context.Context, request CompleteWorkRequestObject) (CompleteWorkResponseObject, error)
	// Update worker heartbeat
	// (PUT /api/workers/{id}/heartbeat)
	UpdateWorkerHeartbeat(ctx context.Context, request UpdateWorkerHeartbeatRequestObject) (UpdateWorkerHeartbeatResponseObject, error)
	// List workflow runs
	// (GET /api/workflow-runs)
	ListWorkflowRuns(ctx context.Context, request ListWorkflowRunsRequestObject) (ListWorkflowRunsResponseObject, error)
	// Get workflow run details
	// (GET /api/workflow-runs/{id})
	GetWorkflowRun(ctx context.Context, request GetWorkflowRunRequestObject) (GetWorkflowRunResponseObject, error)
	// Get workflow run steps
	// (GET /api/workflow-runs/{id}/steps)
	GetWorkflowRunSteps(ctx context.Context, request GetWorkflowRunStepsRequestObject) (GetWorkflowRunStepsResponseObject, error)
	// List all workflows
	// (GET /api/workflows)
	ListWorkflows(ctx context.Context, request ListWorkflowsRequestObject) (ListWorkflowsResponseObject, error)
	// Create a new workflow
	// (POST /api/workflows)
	CreateWorkflow(ctx context.Context, request CreateWorkflowRequestObject) (CreateWorkflowResponseObject, error)
	// Delete workflow
	// (DELETE /api/workflows/{id})
	DeleteWorkflow(ctx context.Context, request DeleteWorkflowRequestObject) (DeleteWorkflowResponseObject, error)
	// Get workflow by ID
	// (GET /api/workflows/{id})
	GetWorkflow(ctx context.Context, request GetWorkflowRequestObject) (GetWorkflowResponseObject, error)
	// Update workflow
	// (PUT /api/workflows/{id})
	UpdateWorkflow(ctx context.Context, request UpdateWorkflowRequestObject) (UpdateWorkflowResponseObject, error)
	// Execute a workflow
	// (POST /api/workflows/{id}/execute)
	ExecuteWorkflow(ctx context.Context, request ExecuteWorkflowRequestObject) (ExecuteWorkflowResponseObject, error)
	// Get current draft for a workflow
	// (GET /api/workflows/{workflowId}/draft)
	GetWorkflowDraft(ctx context.Context, request GetWorkflowDraftRequestObject) (GetWorkflowDraftResponseObject, error)
	// Update workflow draft with auto-persistence
	// (PUT /api/workflows/{workflowId}/draft)
	UpdateWorkflowDraft(ctx context.Context, request UpdateWorkflowDraftRequestObject) (UpdateWorkflowDraftResponseObject, error)
	// Test a single node in draft context
	// (POST /api/workflows/{workflowId}/draft/nodes/{nodeId}/test)
	TestWorkflowDraftNode(ctx context.Context, request TestWorkflowDraftNodeRequestObject) (TestWorkflowDraftNodeResponseObject, error)
	// List all edges in a workflow
	// (GET /api/workflows/{workflowId}/edges)
	ListWorkflowEdges(ctx context.Context, request ListWorkflowEdgesRequestObject) (ListWorkflowEdgesResponseObject, error)
	// Create a new edge in workflow
	// (POST /api/workflows/{workflowId}/edges)
	CreateWorkflowEdge(ctx context.Context, request CreateWorkflowEdgeRequestObject) (CreateWorkflowEdgeResponseObject, error)
	// Delete workflow edge
	// (DELETE /api/workflows/{workflowId}/edges/{edgeId})
	DeleteWorkflowEdge(ctx context.Context, request DeleteWorkflowEdgeRequestObject) (DeleteWorkflowEdgeResponseObject, error)
	// Auto-layout workflow nodes
	// (POST /api/workflows/{workflowId}/layout)
	AutoLayoutWorkflow(ctx context.Context, request AutoLayoutWorkflowRequestObject) (AutoLayoutWorkflowResponseObject, error)
	// List all nodes in a workflow
	// (GET /api/workflows/{workflowId}/nodes)
	ListWorkflowNodes(ctx context.Context, request ListWorkflowNodesRequestObject) (ListWorkflowNodesResponseObject, error)
	// Create a new node in workflow
	// (POST /api/workflows/{workflowId}/nodes)
	CreateWorkflowNode(ctx context.Context, request CreateWorkflowNodeRequestObject) (CreateWorkflowNodeResponseObject, error)
	// Delete workflow node
	// (DELETE /api/workflows/{workflowId}/nodes/{nodeId})
	DeleteWorkflowNode(ctx context.Context, request DeleteWorkflowNodeRequestObject) (DeleteWorkflowNodeResponseObject, error)
	// Get specific workflow node
	// (GET /api/workflows/{workflowId}/nodes/{nodeId})
	GetWorkflowNode(ctx context.Context, request GetWorkflowNodeRequestObject) (GetWorkflowNodeResponseObject, error)
	// Update workflow node
	// (PUT /api/workflows/{workflowId}/nodes/{nodeId})
	UpdateWorkflowNode(ctx context.Context, request UpdateWorkflowNodeRequestObject) (UpdateWorkflowNodeResponseObject, error)
	// List all versions of a workflow
	// (GET /api/workflows/{workflowId}/versions)
	ListWorkflowVersions(ctx context.Context, request ListWorkflowVersionsRequestObject) (ListWorkflowVersionsResponseObject, error)
	// Create a new workflow version
	// (POST /api/workflows/{workflowId}/versions)
	CreateWorkflowVersion(ctx context.Context, request CreateWorkflowVersionRequestObject) (CreateWorkflowVersionResponseObject, error)
	// Get latest version of a workflow
	// (GET /api/workflows/{workflowId}/versions/latest)
	GetLatestWorkflowVersion(ctx context.Context, request GetLatestWorkflowVersionRequestObject) (GetLatestWorkflowVersionResponseObject, error)
	// Deploy a specific workflow version
	// (POST /api/workflows/{workflowId}/versions/{versionNumber}/deploy)
	DeployWorkflowVersion(ctx context.Context, request DeployWorkflowVersionRequestObject) (DeployWorkflowVersionResponseObject, error)
	// Webhook endpoint
	// (POST /webhooks/{token})
	HandleWebhook(ctx context.Context, request HandleWebhookRequestObject) (HandleWebhookResponseObject, error)
}

StrictServerInterface represents all server handlers.

type TestCredentials200JSONResponse

type TestCredentials200JSONResponse CredentialTestResult

func (TestCredentials200JSONResponse) VisitTestCredentialsResponse

func (response TestCredentials200JSONResponse) VisitTestCredentialsResponse(w http.ResponseWriter) error

type TestCredentials400JSONResponse

type TestCredentials400JSONResponse Error

func (TestCredentials400JSONResponse) VisitTestCredentialsResponse

func (response TestCredentials400JSONResponse) VisitTestCredentialsResponse(w http.ResponseWriter) error

type TestCredentials404JSONResponse

type TestCredentials404JSONResponse Error

func (TestCredentials404JSONResponse) VisitTestCredentialsResponse

func (response TestCredentials404JSONResponse) VisitTestCredentialsResponse(w http.ResponseWriter) error

type TestCredentials500JSONResponse

type TestCredentials500JSONResponse Error

func (TestCredentials500JSONResponse) VisitTestCredentialsResponse

func (response TestCredentials500JSONResponse) VisitTestCredentialsResponse(w http.ResponseWriter) error

type TestCredentialsJSONBody

type TestCredentialsJSONBody struct {
	Credentials *map[string]interface{} `json:"credentials,omitempty"`
}

TestCredentialsJSONBody defines parameters for TestCredentials.

type TestCredentialsJSONRequestBody

type TestCredentialsJSONRequestBody TestCredentialsJSONBody

TestCredentialsJSONRequestBody defines body for TestCredentials for application/json ContentType.

type TestCredentialsRequestObject

type TestCredentialsRequestObject struct {
	Type string `json:"type"`
	Body *TestCredentialsJSONRequestBody
}

type TestCredentialsResponseObject

type TestCredentialsResponseObject interface {
	VisitTestCredentialsResponse(w http.ResponseWriter) error
}

type TestWorkflowDraftNode200JSONResponse

type TestWorkflowDraftNode200JSONResponse NodeTestResult

func (TestWorkflowDraftNode200JSONResponse) VisitTestWorkflowDraftNodeResponse

func (response TestWorkflowDraftNode200JSONResponse) VisitTestWorkflowDraftNodeResponse(w http.ResponseWriter) error

type TestWorkflowDraftNode400JSONResponse

type TestWorkflowDraftNode400JSONResponse Error

func (TestWorkflowDraftNode400JSONResponse) VisitTestWorkflowDraftNodeResponse

func (response TestWorkflowDraftNode400JSONResponse) VisitTestWorkflowDraftNodeResponse(w http.ResponseWriter) error

type TestWorkflowDraftNode404JSONResponse

type TestWorkflowDraftNode404JSONResponse Error

func (TestWorkflowDraftNode404JSONResponse) VisitTestWorkflowDraftNodeResponse

func (response TestWorkflowDraftNode404JSONResponse) VisitTestWorkflowDraftNodeResponse(w http.ResponseWriter) error

type TestWorkflowDraftNode500JSONResponse

type TestWorkflowDraftNode500JSONResponse Error

func (TestWorkflowDraftNode500JSONResponse) VisitTestWorkflowDraftNodeResponse

func (response TestWorkflowDraftNode500JSONResponse) VisitTestWorkflowDraftNodeResponse(w http.ResponseWriter) error

type TestWorkflowDraftNodeJSONRequestBody

type TestWorkflowDraftNodeJSONRequestBody = ExecuteWorkflowRequest

TestWorkflowDraftNodeJSONRequestBody defines body for TestWorkflowDraftNode for application/json ContentType.

type TestWorkflowDraftNodeRequestObject

type TestWorkflowDraftNodeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	NodeId     string             `json:"nodeId"`
	Body       *TestWorkflowDraftNodeJSONRequestBody
}

type TestWorkflowDraftNodeResponseObject

type TestWorkflowDraftNodeResponseObject interface {
	VisitTestWorkflowDraftNodeResponse(w http.ResponseWriter) error
}

type TimerExecutor

type TimerExecutor struct{}

TimerExecutor produces a timestamp payload for timer triggers.

func (TimerExecutor) Execute

func (TimerExecutor) Execute(agentID string, node api.Node, input interface{}) (interface{}, error)

type TooManyValuesForParamError

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

func (*TooManyValuesForParamError) Error

type Trigger

type Trigger struct {
	// Config Trigger configuration containing trigger-specific parameters and settings
	Config    *TriggerConfig      `json:"config,omitempty"`
	CreatedAt *time.Time          `json:"created_at,omitempty"`
	Enabled   *bool               `json:"enabled,omitempty"`
	Id        *openapi_types.UUID `json:"id,omitempty"`
	Name      *string             `json:"name,omitempty"`

	// Type Type of trigger
	Type       *TriggerType        `json:"type,omitempty"`
	UpdatedAt  *time.Time          `json:"updated_at,omitempty"`
	WorkflowId *openapi_types.UUID `json:"workflow_id,omitempty"`
}

Trigger defines model for Trigger.

type TriggerConfig

type TriggerConfig map[string]interface{}

TriggerConfig Trigger configuration containing trigger-specific parameters and settings

type TriggerType

type TriggerType string

TriggerType Type of trigger

const (
	Schedule TriggerType = "schedule"
	Webhook  TriggerType = "webhook"
)

Defines values for TriggerType.

type UnescapedCookieParamError

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

func (*UnescapedCookieParamError) Error

func (e *UnescapedCookieParamError) Error() string

func (*UnescapedCookieParamError) Unwrap

func (e *UnescapedCookieParamError) Unwrap() error

type Unimplemented

type Unimplemented struct{}

func (Unimplemented) AssistantChat

func (_ Unimplemented) AssistantChat(w http.ResponseWriter, r *http.Request)

Chat with AI assistant (POST /api/assistant/chat)

func (Unimplemented) AutoLayoutWorkflow

func (_ Unimplemented) AutoLayoutWorkflow(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Auto-layout workflow nodes (POST /api/workflows/{workflowId}/layout)

func (Unimplemented) ClaimWork

func (_ Unimplemented) ClaimWork(w http.ResponseWriter, r *http.Request, id string)

Claim work items (POST /api/workers/{id}/claim-work)

func (Unimplemented) CompleteWork

func (_ Unimplemented) CompleteWork(w http.ResponseWriter, r *http.Request, id string, itemId string)

Complete a work item (POST /api/workers/{id}/complete-work/{itemId})

func (Unimplemented) CreateConnection

func (_ Unimplemented) CreateConnection(w http.ResponseWriter, r *http.Request)

Create a connection (POST /api/connections)

func (Unimplemented) CreateTrigger

func (_ Unimplemented) CreateTrigger(w http.ResponseWriter, r *http.Request)

Create a trigger (POST /api/triggers)

func (Unimplemented) CreateWorkflow

func (_ Unimplemented) CreateWorkflow(w http.ResponseWriter, r *http.Request)

Create a new workflow (POST /api/workflows)

func (Unimplemented) CreateWorkflowEdge

func (_ Unimplemented) CreateWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Create a new edge in workflow (POST /api/workflows/{workflowId}/edges)

func (Unimplemented) CreateWorkflowNode

func (_ Unimplemented) CreateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Create a new node in workflow (POST /api/workflows/{workflowId}/nodes)

func (Unimplemented) CreateWorkflowVersion

func (_ Unimplemented) CreateWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Create a new workflow version (POST /api/workflows/{workflowId}/versions)

func (Unimplemented) DeleteConnection

func (_ Unimplemented) DeleteConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Delete connection (DELETE /api/connections/{id})

func (Unimplemented) DeleteTrigger

func (_ Unimplemented) DeleteTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Delete trigger (DELETE /api/triggers/{id})

func (Unimplemented) DeleteWorkflow

func (_ Unimplemented) DeleteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Delete workflow (DELETE /api/workflows/{id})

func (Unimplemented) DeleteWorkflowEdge

func (_ Unimplemented) DeleteWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, edgeId string)

Delete workflow edge (DELETE /api/workflows/{workflowId}/edges/{edgeId})

func (Unimplemented) DeleteWorkflowNode

func (_ Unimplemented) DeleteWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)

Delete workflow node (DELETE /api/workflows/{workflowId}/nodes/{nodeId})

func (Unimplemented) DeployWorkflowVersion

func (_ Unimplemented) DeployWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, versionNumber int)

Deploy a specific workflow version (POST /api/workflows/{workflowId}/versions/{versionNumber}/deploy)

func (Unimplemented) ExecuteWorkflow

func (_ Unimplemented) ExecuteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Execute a workflow (POST /api/workflows/{id}/execute)

func (Unimplemented) GetConnection

func (_ Unimplemented) GetConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Get connection by ID (GET /api/connections/{id})

func (Unimplemented) GetCredentialTypeSchema

func (_ Unimplemented) GetCredentialTypeSchema(w http.ResponseWriter, r *http.Request, pType string)

Get JSON schema for credential type (GET /api/credential-types/{type}/schema)

func (Unimplemented) GetHealth

func (_ Unimplemented) GetHealth(w http.ResponseWriter, r *http.Request)

Health check endpoint (GET /api/health)

func (Unimplemented) GetLatestWorkflowVersion

func (_ Unimplemented) GetLatestWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Get latest version of a workflow (GET /api/workflows/{workflowId}/versions/latest)

func (Unimplemented) GetNodeParameterOptions

func (_ Unimplemented) GetNodeParameterOptions(w http.ResponseWriter, r *http.Request, pType string, parameter string, params GetNodeParameterOptionsParams)

Get dynamic options for node parameters (GET /api/node-types/{type}/parameters/{parameter}/options)

func (Unimplemented) GetTrigger

Get trigger by ID (GET /api/triggers/{id})

func (Unimplemented) GetWorkflow

func (_ Unimplemented) GetWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Get workflow by ID (GET /api/workflows/{id})

func (Unimplemented) GetWorkflowDraft

func (_ Unimplemented) GetWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Get current draft for a workflow (GET /api/workflows/{workflowId}/draft)

func (Unimplemented) GetWorkflowNode

func (_ Unimplemented) GetWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)

Get specific workflow node (GET /api/workflows/{workflowId}/nodes/{nodeId})

func (Unimplemented) GetWorkflowRun

func (_ Unimplemented) GetWorkflowRun(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Get workflow run details (GET /api/workflow-runs/{id})

func (Unimplemented) GetWorkflowRunSteps

func (_ Unimplemented) GetWorkflowRunSteps(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Get workflow run steps (GET /api/workflow-runs/{id}/steps)

func (Unimplemented) HandleWebhook

func (_ Unimplemented) HandleWebhook(w http.ResponseWriter, r *http.Request, token string)

Webhook endpoint (POST /webhooks/{token})

func (Unimplemented) ListConnections

func (_ Unimplemented) ListConnections(w http.ResponseWriter, r *http.Request)

List connections (GET /api/connections)

func (Unimplemented) ListCredentialTypes

func (_ Unimplemented) ListCredentialTypes(w http.ResponseWriter, r *http.Request)

List credential type definitions (GET /api/credential-types)

func (Unimplemented) ListCredentials

func (_ Unimplemented) ListCredentials(w http.ResponseWriter, r *http.Request, params ListCredentialsParams)

List credentials for selection in nodes (GET /api/credentials)

func (Unimplemented) ListExtensions

func (_ Unimplemented) ListExtensions(w http.ResponseWriter, r *http.Request)

List available extensions and plugins (GET /api/extensions)

func (Unimplemented) ListIntegrations

func (_ Unimplemented) ListIntegrations(w http.ResponseWriter, r *http.Request)

List available integrations (GET /api/integrations)

func (Unimplemented) ListNodeTypes

func (_ Unimplemented) ListNodeTypes(w http.ResponseWriter, r *http.Request, params ListNodeTypesParams)

List available node types (GET /api/node-types)

func (Unimplemented) ListTriggers

func (_ Unimplemented) ListTriggers(w http.ResponseWriter, r *http.Request)

List triggers (GET /api/triggers)

func (Unimplemented) ListWorkers

func (_ Unimplemented) ListWorkers(w http.ResponseWriter, r *http.Request)

List all workers (GET /api/workers)

func (Unimplemented) ListWorkflowEdges

func (_ Unimplemented) ListWorkflowEdges(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

List all edges in a workflow (GET /api/workflows/{workflowId}/edges)

func (Unimplemented) ListWorkflowNodes

func (_ Unimplemented) ListWorkflowNodes(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

List all nodes in a workflow (GET /api/workflows/{workflowId}/nodes)

func (Unimplemented) ListWorkflowRuns

func (_ Unimplemented) ListWorkflowRuns(w http.ResponseWriter, r *http.Request, params ListWorkflowRunsParams)

List workflow runs (GET /api/workflow-runs)

func (Unimplemented) ListWorkflowVersions

func (_ Unimplemented) ListWorkflowVersions(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, params ListWorkflowVersionsParams)

List all versions of a workflow (GET /api/workflows/{workflowId}/versions)

func (Unimplemented) ListWorkflows

func (_ Unimplemented) ListWorkflows(w http.ResponseWriter, r *http.Request, params ListWorkflowsParams)

List all workflows (GET /api/workflows)

func (Unimplemented) RegisterWorker

func (_ Unimplemented) RegisterWorker(w http.ResponseWriter, r *http.Request)

Register a new worker (POST /api/workers)

func (Unimplemented) TestCredentials

func (_ Unimplemented) TestCredentials(w http.ResponseWriter, r *http.Request, pType string)

Test credentials for a specific type (POST /api/credential-types/{type}/test)

func (Unimplemented) TestWorkflowDraftNode

func (_ Unimplemented) TestWorkflowDraftNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)

Test a single node in draft context (POST /api/workflows/{workflowId}/draft/nodes/{nodeId}/test)

func (Unimplemented) UnregisterWorker

func (_ Unimplemented) UnregisterWorker(w http.ResponseWriter, r *http.Request, id string)

Unregister a worker (DELETE /api/workers/{id})

func (Unimplemented) UpdateConnection

func (_ Unimplemented) UpdateConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Update connection (PUT /api/connections/{id})

func (Unimplemented) UpdateTrigger

func (_ Unimplemented) UpdateTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Update trigger (PUT /api/triggers/{id})

func (Unimplemented) UpdateWorkerHeartbeat

func (_ Unimplemented) UpdateWorkerHeartbeat(w http.ResponseWriter, r *http.Request, id string)

Update worker heartbeat (PUT /api/workers/{id}/heartbeat)

func (Unimplemented) UpdateWorkflow

func (_ Unimplemented) UpdateWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)

Update workflow (PUT /api/workflows/{id})

func (Unimplemented) UpdateWorkflowDraft

func (_ Unimplemented) UpdateWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)

Update workflow draft with auto-persistence (PUT /api/workflows/{workflowId}/draft)

func (Unimplemented) UpdateWorkflowNode

func (_ Unimplemented) UpdateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, nodeId string)

Update workflow node (PUT /api/workflows/{workflowId}/nodes/{nodeId})

type UnmarshalingParamError

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

func (*UnmarshalingParamError) Error

func (e *UnmarshalingParamError) Error() string

func (*UnmarshalingParamError) Unwrap

func (e *UnmarshalingParamError) Unwrap() error

type UnregisterWorker204Response

type UnregisterWorker204Response struct {
}

func (UnregisterWorker204Response) VisitUnregisterWorkerResponse

func (response UnregisterWorker204Response) VisitUnregisterWorkerResponse(w http.ResponseWriter) error

type UnregisterWorker404JSONResponse

type UnregisterWorker404JSONResponse Error

func (UnregisterWorker404JSONResponse) VisitUnregisterWorkerResponse

func (response UnregisterWorker404JSONResponse) VisitUnregisterWorkerResponse(w http.ResponseWriter) error

type UnregisterWorker500JSONResponse

type UnregisterWorker500JSONResponse Error

func (UnregisterWorker500JSONResponse) VisitUnregisterWorkerResponse

func (response UnregisterWorker500JSONResponse) VisitUnregisterWorkerResponse(w http.ResponseWriter) error

type UnregisterWorkerRequestObject

type UnregisterWorkerRequestObject struct {
	Id string `json:"id"`
}

type UnregisterWorkerResponseObject

type UnregisterWorkerResponseObject interface {
	VisitUnregisterWorkerResponse(w http.ResponseWriter) error
}

type UpdateConnection200JSONResponse

type UpdateConnection200JSONResponse Connection

func (UpdateConnection200JSONResponse) VisitUpdateConnectionResponse

func (response UpdateConnection200JSONResponse) VisitUpdateConnectionResponse(w http.ResponseWriter) error

type UpdateConnection400JSONResponse

type UpdateConnection400JSONResponse Error

func (UpdateConnection400JSONResponse) VisitUpdateConnectionResponse

func (response UpdateConnection400JSONResponse) VisitUpdateConnectionResponse(w http.ResponseWriter) error

type UpdateConnection404JSONResponse

type UpdateConnection404JSONResponse Error

func (UpdateConnection404JSONResponse) VisitUpdateConnectionResponse

func (response UpdateConnection404JSONResponse) VisitUpdateConnectionResponse(w http.ResponseWriter) error

type UpdateConnection500JSONResponse

type UpdateConnection500JSONResponse Error

func (UpdateConnection500JSONResponse) VisitUpdateConnectionResponse

func (response UpdateConnection500JSONResponse) VisitUpdateConnectionResponse(w http.ResponseWriter) error

type UpdateConnectionJSONRequestBody

type UpdateConnectionJSONRequestBody = UpdateConnectionRequest

UpdateConnectionJSONRequestBody defines body for UpdateConnection for application/json ContentType.

type UpdateConnectionRequest

type UpdateConnectionRequest struct {
	// Config Connection configuration containing non-sensitive connection parameters
	Config    *ConnectionConfig `json:"config,omitempty"`
	IsDefault *bool             `json:"is_default,omitempty"`
	Name      *string           `json:"name,omitempty"`

	// Secret Connection secret configuration containing authentication credentials
	Secret *ConnectionSecret `json:"secret,omitempty"`

	// Status Status of a connection
	Status          *ConnectionStatus `json:"status,omitempty"`
	UsageLimitMonth *int              `json:"usage_limit_month,omitempty"`
}

UpdateConnectionRequest defines model for UpdateConnectionRequest.

type UpdateConnectionRequestObject

type UpdateConnectionRequestObject struct {
	Id   openapi_types.UUID `json:"id"`
	Body *UpdateConnectionJSONRequestBody
}

type UpdateConnectionResponseObject

type UpdateConnectionResponseObject interface {
	VisitUpdateConnectionResponse(w http.ResponseWriter) error
}

type UpdateTrigger200JSONResponse

type UpdateTrigger200JSONResponse Trigger

func (UpdateTrigger200JSONResponse) VisitUpdateTriggerResponse

func (response UpdateTrigger200JSONResponse) VisitUpdateTriggerResponse(w http.ResponseWriter) error

type UpdateTrigger400JSONResponse

type UpdateTrigger400JSONResponse Error

func (UpdateTrigger400JSONResponse) VisitUpdateTriggerResponse

func (response UpdateTrigger400JSONResponse) VisitUpdateTriggerResponse(w http.ResponseWriter) error

type UpdateTrigger404JSONResponse

type UpdateTrigger404JSONResponse Error

func (UpdateTrigger404JSONResponse) VisitUpdateTriggerResponse

func (response UpdateTrigger404JSONResponse) VisitUpdateTriggerResponse(w http.ResponseWriter) error

type UpdateTrigger500JSONResponse

type UpdateTrigger500JSONResponse Error

func (UpdateTrigger500JSONResponse) VisitUpdateTriggerResponse

func (response UpdateTrigger500JSONResponse) VisitUpdateTriggerResponse(w http.ResponseWriter) error

type UpdateTriggerJSONRequestBody

type UpdateTriggerJSONRequestBody = UpdateTriggerRequest

UpdateTriggerJSONRequestBody defines body for UpdateTrigger for application/json ContentType.

type UpdateTriggerRequest

type UpdateTriggerRequest struct {
	// Config Trigger configuration containing trigger-specific parameters and settings
	Config  *TriggerConfig `json:"config,omitempty"`
	Enabled *bool          `json:"enabled,omitempty"`
	Name    *string        `json:"name,omitempty"`
}

UpdateTriggerRequest defines model for UpdateTriggerRequest.

type UpdateTriggerRequestObject

type UpdateTriggerRequestObject struct {
	Id   openapi_types.UUID `json:"id"`
	Body *UpdateTriggerJSONRequestBody
}

type UpdateTriggerResponseObject

type UpdateTriggerResponseObject interface {
	VisitUpdateTriggerResponse(w http.ResponseWriter) error
}

type UpdateWorkerHeartbeat200Response

type UpdateWorkerHeartbeat200Response struct {
}

func (UpdateWorkerHeartbeat200Response) VisitUpdateWorkerHeartbeatResponse

func (response UpdateWorkerHeartbeat200Response) VisitUpdateWorkerHeartbeatResponse(w http.ResponseWriter) error

type UpdateWorkerHeartbeat404JSONResponse

type UpdateWorkerHeartbeat404JSONResponse Error

func (UpdateWorkerHeartbeat404JSONResponse) VisitUpdateWorkerHeartbeatResponse

func (response UpdateWorkerHeartbeat404JSONResponse) VisitUpdateWorkerHeartbeatResponse(w http.ResponseWriter) error

type UpdateWorkerHeartbeat500JSONResponse

type UpdateWorkerHeartbeat500JSONResponse Error

func (UpdateWorkerHeartbeat500JSONResponse) VisitUpdateWorkerHeartbeatResponse

func (response UpdateWorkerHeartbeat500JSONResponse) VisitUpdateWorkerHeartbeatResponse(w http.ResponseWriter) error

type UpdateWorkerHeartbeatRequestObject

type UpdateWorkerHeartbeatRequestObject struct {
	Id string `json:"id"`
}

type UpdateWorkerHeartbeatResponseObject

type UpdateWorkerHeartbeatResponseObject interface {
	VisitUpdateWorkerHeartbeatResponse(w http.ResponseWriter) error
}

type UpdateWorkflow200JSONResponse

type UpdateWorkflow200JSONResponse Workflow

func (UpdateWorkflow200JSONResponse) VisitUpdateWorkflowResponse

func (response UpdateWorkflow200JSONResponse) VisitUpdateWorkflowResponse(w http.ResponseWriter) error

type UpdateWorkflow400JSONResponse

type UpdateWorkflow400JSONResponse Error

func (UpdateWorkflow400JSONResponse) VisitUpdateWorkflowResponse

func (response UpdateWorkflow400JSONResponse) VisitUpdateWorkflowResponse(w http.ResponseWriter) error

type UpdateWorkflow404JSONResponse

type UpdateWorkflow404JSONResponse Error

func (UpdateWorkflow404JSONResponse) VisitUpdateWorkflowResponse

func (response UpdateWorkflow404JSONResponse) VisitUpdateWorkflowResponse(w http.ResponseWriter) error

type UpdateWorkflow500JSONResponse

type UpdateWorkflow500JSONResponse Error

func (UpdateWorkflow500JSONResponse) VisitUpdateWorkflowResponse

func (response UpdateWorkflow500JSONResponse) VisitUpdateWorkflowResponse(w http.ResponseWriter) error

type UpdateWorkflowDraft200JSONResponse

type UpdateWorkflowDraft200JSONResponse WorkflowDraft

func (UpdateWorkflowDraft200JSONResponse) VisitUpdateWorkflowDraftResponse

func (response UpdateWorkflowDraft200JSONResponse) VisitUpdateWorkflowDraftResponse(w http.ResponseWriter) error

type UpdateWorkflowDraft400JSONResponse

type UpdateWorkflowDraft400JSONResponse Error

func (UpdateWorkflowDraft400JSONResponse) VisitUpdateWorkflowDraftResponse

func (response UpdateWorkflowDraft400JSONResponse) VisitUpdateWorkflowDraftResponse(w http.ResponseWriter) error

type UpdateWorkflowDraft404JSONResponse

type UpdateWorkflowDraft404JSONResponse Error

func (UpdateWorkflowDraft404JSONResponse) VisitUpdateWorkflowDraftResponse

func (response UpdateWorkflowDraft404JSONResponse) VisitUpdateWorkflowDraftResponse(w http.ResponseWriter) error

type UpdateWorkflowDraft500JSONResponse

type UpdateWorkflowDraft500JSONResponse Error

func (UpdateWorkflowDraft500JSONResponse) VisitUpdateWorkflowDraftResponse

func (response UpdateWorkflowDraft500JSONResponse) VisitUpdateWorkflowDraftResponse(w http.ResponseWriter) error

type UpdateWorkflowDraftJSONRequestBody

type UpdateWorkflowDraftJSONRequestBody = UpdateWorkflowDraftRequest

UpdateWorkflowDraftJSONRequestBody defines body for UpdateWorkflowDraft for application/json ContentType.

type UpdateWorkflowDraftRequest

type UpdateWorkflowDraftRequest struct {
	Definition *WorkflowDefinition `json:"definition,omitempty"`
}

UpdateWorkflowDraftRequest defines model for UpdateWorkflowDraftRequest.

type UpdateWorkflowDraftRequestObject

type UpdateWorkflowDraftRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	Body       *UpdateWorkflowDraftJSONRequestBody
}

type UpdateWorkflowDraftResponseObject

type UpdateWorkflowDraftResponseObject interface {
	VisitUpdateWorkflowDraftResponse(w http.ResponseWriter) error
}

type UpdateWorkflowJSONRequestBody

type UpdateWorkflowJSONRequestBody = UpdateWorkflowRequest

UpdateWorkflowJSONRequestBody defines body for UpdateWorkflow for application/json ContentType.

type UpdateWorkflowNode200JSONResponse

type UpdateWorkflowNode200JSONResponse WorkflowNode

func (UpdateWorkflowNode200JSONResponse) VisitUpdateWorkflowNodeResponse

func (response UpdateWorkflowNode200JSONResponse) VisitUpdateWorkflowNodeResponse(w http.ResponseWriter) error

type UpdateWorkflowNode400JSONResponse

type UpdateWorkflowNode400JSONResponse Error

func (UpdateWorkflowNode400JSONResponse) VisitUpdateWorkflowNodeResponse

func (response UpdateWorkflowNode400JSONResponse) VisitUpdateWorkflowNodeResponse(w http.ResponseWriter) error

type UpdateWorkflowNode404JSONResponse

type UpdateWorkflowNode404JSONResponse Error

func (UpdateWorkflowNode404JSONResponse) VisitUpdateWorkflowNodeResponse

func (response UpdateWorkflowNode404JSONResponse) VisitUpdateWorkflowNodeResponse(w http.ResponseWriter) error

type UpdateWorkflowNode500JSONResponse

type UpdateWorkflowNode500JSONResponse Error

func (UpdateWorkflowNode500JSONResponse) VisitUpdateWorkflowNodeResponse

func (response UpdateWorkflowNode500JSONResponse) VisitUpdateWorkflowNodeResponse(w http.ResponseWriter) error

type UpdateWorkflowNodeJSONRequestBody

type UpdateWorkflowNodeJSONRequestBody = UpdateWorkflowNodeRequest

UpdateWorkflowNodeJSONRequestBody defines body for UpdateWorkflowNode for application/json ContentType.

type UpdateWorkflowNodeRequest

type UpdateWorkflowNodeRequest struct {
	// Config Node configuration containing node-specific parameters and settings
	Config *NodeConfig `json:"config,omitempty"`
	Name   *string     `json:"name,omitempty"`

	// Position Node position coordinates in the workflow canvas
	Position *NodePosition `json:"position,omitempty"`
}

UpdateWorkflowNodeRequest defines model for UpdateWorkflowNodeRequest.

type UpdateWorkflowNodeRequestObject

type UpdateWorkflowNodeRequestObject struct {
	WorkflowId openapi_types.UUID `json:"workflowId"`
	NodeId     string             `json:"nodeId"`
	Body       *UpdateWorkflowNodeJSONRequestBody
}

type UpdateWorkflowNodeResponseObject

type UpdateWorkflowNodeResponseObject interface {
	VisitUpdateWorkflowNodeResponse(w http.ResponseWriter) error
}

type UpdateWorkflowRequest

type UpdateWorkflowRequest struct {
	Definition  *WorkflowDefinition `json:"definition,omitempty"`
	Description *string             `json:"description,omitempty"`
	Name        *string             `json:"name,omitempty"`
}

UpdateWorkflowRequest defines model for UpdateWorkflowRequest.

type UpdateWorkflowRequestObject

type UpdateWorkflowRequestObject struct {
	Id   openapi_types.UUID `json:"id"`
	Body *UpdateWorkflowJSONRequestBody
}

type UpdateWorkflowResponseObject

type UpdateWorkflowResponseObject interface {
	VisitUpdateWorkflowResponse(w http.ResponseWriter) error
}

type ValidatorSpec

type ValidatorSpec struct {
	// Params Parameters for the validator
	Params *map[string]interface{} `json:"params,omitempty"`

	// Type Validator type (e.g. "notEmpty", "regex")
	Type string `json:"type"`
}

ValidatorSpec defines model for ValidatorSpec.

type WebhookPayload

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

WebhookPayload Any valid JSON payload for webhook

func (WebhookPayload) AsWebhookPayload0

func (t WebhookPayload) AsWebhookPayload0() (WebhookPayload0, error)

AsWebhookPayload0 returns the union data inside the WebhookPayload as a WebhookPayload0

func (WebhookPayload) AsWebhookPayload1

func (t WebhookPayload) AsWebhookPayload1() (WebhookPayload1, error)

AsWebhookPayload1 returns the union data inside the WebhookPayload as a WebhookPayload1

func (WebhookPayload) AsWebhookPayload2

func (t WebhookPayload) AsWebhookPayload2() (WebhookPayload2, error)

AsWebhookPayload2 returns the union data inside the WebhookPayload as a WebhookPayload2

func (WebhookPayload) AsWebhookPayload3

func (t WebhookPayload) AsWebhookPayload3() (WebhookPayload3, error)

AsWebhookPayload3 returns the union data inside the WebhookPayload as a WebhookPayload3

func (WebhookPayload) AsWebhookPayload4

func (t WebhookPayload) AsWebhookPayload4() (WebhookPayload4, error)

AsWebhookPayload4 returns the union data inside the WebhookPayload as a WebhookPayload4

func (WebhookPayload) AsWebhookPayload5

func (t WebhookPayload) AsWebhookPayload5() (WebhookPayload5, error)

AsWebhookPayload5 returns the union data inside the WebhookPayload as a WebhookPayload5

func (*WebhookPayload) FromWebhookPayload0

func (t *WebhookPayload) FromWebhookPayload0(v WebhookPayload0) error

FromWebhookPayload0 overwrites any union data inside the WebhookPayload as the provided WebhookPayload0

func (*WebhookPayload) FromWebhookPayload1

func (t *WebhookPayload) FromWebhookPayload1(v WebhookPayload1) error

FromWebhookPayload1 overwrites any union data inside the WebhookPayload as the provided WebhookPayload1

func (*WebhookPayload) FromWebhookPayload2

func (t *WebhookPayload) FromWebhookPayload2(v WebhookPayload2) error

FromWebhookPayload2 overwrites any union data inside the WebhookPayload as the provided WebhookPayload2

func (*WebhookPayload) FromWebhookPayload3

func (t *WebhookPayload) FromWebhookPayload3(v WebhookPayload3) error

FromWebhookPayload3 overwrites any union data inside the WebhookPayload as the provided WebhookPayload3

func (*WebhookPayload) FromWebhookPayload4

func (t *WebhookPayload) FromWebhookPayload4(v WebhookPayload4) error

FromWebhookPayload4 overwrites any union data inside the WebhookPayload as the provided WebhookPayload4

func (*WebhookPayload) FromWebhookPayload5

func (t *WebhookPayload) FromWebhookPayload5(v WebhookPayload5) error

FromWebhookPayload5 overwrites any union data inside the WebhookPayload as the provided WebhookPayload5

func (WebhookPayload) MarshalJSON

func (t WebhookPayload) MarshalJSON() ([]byte, error)

func (*WebhookPayload) MergeWebhookPayload0

func (t *WebhookPayload) MergeWebhookPayload0(v WebhookPayload0) error

MergeWebhookPayload0 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload0

func (*WebhookPayload) MergeWebhookPayload1

func (t *WebhookPayload) MergeWebhookPayload1(v WebhookPayload1) error

MergeWebhookPayload1 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload1

func (*WebhookPayload) MergeWebhookPayload2

func (t *WebhookPayload) MergeWebhookPayload2(v WebhookPayload2) error

MergeWebhookPayload2 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload2

func (*WebhookPayload) MergeWebhookPayload3

func (t *WebhookPayload) MergeWebhookPayload3(v WebhookPayload3) error

MergeWebhookPayload3 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload3

func (*WebhookPayload) MergeWebhookPayload4

func (t *WebhookPayload) MergeWebhookPayload4(v WebhookPayload4) error

MergeWebhookPayload4 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload4

func (*WebhookPayload) MergeWebhookPayload5

func (t *WebhookPayload) MergeWebhookPayload5(v WebhookPayload5) error

MergeWebhookPayload5 performs a merge with any union data inside the WebhookPayload, using the provided WebhookPayload5

func (*WebhookPayload) UnmarshalJSON

func (t *WebhookPayload) UnmarshalJSON(b []byte) error

type WebhookPayload0

type WebhookPayload0 map[string]interface{}

WebhookPayload0 JSON object with any properties

type WebhookPayload1

type WebhookPayload1 = []WebhookPayload_1_Item

WebhookPayload1 JSON array containing any valid JSON values

type WebhookPayload2

type WebhookPayload2 = string

WebhookPayload2 JSON string value

type WebhookPayload3

type WebhookPayload3 = float32

WebhookPayload3 JSON number (including decimals)

type WebhookPayload4

type WebhookPayload4 = int

WebhookPayload4 JSON integer value

type WebhookPayload5

type WebhookPayload5 = bool

WebhookPayload5 JSON boolean (true/false)

type WebhookPayload10

type WebhookPayload10 map[string]interface{}

WebhookPayload10 defines model for .

type WebhookPayload11

type WebhookPayload11 = []interface{}

WebhookPayload11 defines model for .

type WebhookPayload12

type WebhookPayload12 = string

WebhookPayload12 defines model for .

type WebhookPayload13

type WebhookPayload13 = float32

WebhookPayload13 defines model for .

type WebhookPayload14

type WebhookPayload14 = int

WebhookPayload14 defines model for .

type WebhookPayload15

type WebhookPayload15 = bool

WebhookPayload15 defines model for .

type WebhookPayload_1_Item

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

WebhookPayload_1_Item defines model for WebhookPayload.1.Item.

func (WebhookPayload_1_Item) AsWebhookPayload10

func (t WebhookPayload_1_Item) AsWebhookPayload10() (WebhookPayload10, error)

AsWebhookPayload10 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload10

func (WebhookPayload_1_Item) AsWebhookPayload11

func (t WebhookPayload_1_Item) AsWebhookPayload11() (WebhookPayload11, error)

AsWebhookPayload11 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload11

func (WebhookPayload_1_Item) AsWebhookPayload12

func (t WebhookPayload_1_Item) AsWebhookPayload12() (WebhookPayload12, error)

AsWebhookPayload12 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload12

func (WebhookPayload_1_Item) AsWebhookPayload13

func (t WebhookPayload_1_Item) AsWebhookPayload13() (WebhookPayload13, error)

AsWebhookPayload13 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload13

func (WebhookPayload_1_Item) AsWebhookPayload14

func (t WebhookPayload_1_Item) AsWebhookPayload14() (WebhookPayload14, error)

AsWebhookPayload14 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload14

func (WebhookPayload_1_Item) AsWebhookPayload15

func (t WebhookPayload_1_Item) AsWebhookPayload15() (WebhookPayload15, error)

AsWebhookPayload15 returns the union data inside the WebhookPayload_1_Item as a WebhookPayload15

func (*WebhookPayload_1_Item) FromWebhookPayload10

func (t *WebhookPayload_1_Item) FromWebhookPayload10(v WebhookPayload10) error

FromWebhookPayload10 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload10

func (*WebhookPayload_1_Item) FromWebhookPayload11

func (t *WebhookPayload_1_Item) FromWebhookPayload11(v WebhookPayload11) error

FromWebhookPayload11 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload11

func (*WebhookPayload_1_Item) FromWebhookPayload12

func (t *WebhookPayload_1_Item) FromWebhookPayload12(v WebhookPayload12) error

FromWebhookPayload12 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload12

func (*WebhookPayload_1_Item) FromWebhookPayload13

func (t *WebhookPayload_1_Item) FromWebhookPayload13(v WebhookPayload13) error

FromWebhookPayload13 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload13

func (*WebhookPayload_1_Item) FromWebhookPayload14

func (t *WebhookPayload_1_Item) FromWebhookPayload14(v WebhookPayload14) error

FromWebhookPayload14 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload14

func (*WebhookPayload_1_Item) FromWebhookPayload15

func (t *WebhookPayload_1_Item) FromWebhookPayload15(v WebhookPayload15) error

FromWebhookPayload15 overwrites any union data inside the WebhookPayload_1_Item as the provided WebhookPayload15

func (WebhookPayload_1_Item) MarshalJSON

func (t WebhookPayload_1_Item) MarshalJSON() ([]byte, error)

func (*WebhookPayload_1_Item) MergeWebhookPayload10

func (t *WebhookPayload_1_Item) MergeWebhookPayload10(v WebhookPayload10) error

MergeWebhookPayload10 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload10

func (*WebhookPayload_1_Item) MergeWebhookPayload11

func (t *WebhookPayload_1_Item) MergeWebhookPayload11(v WebhookPayload11) error

MergeWebhookPayload11 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload11

func (*WebhookPayload_1_Item) MergeWebhookPayload12

func (t *WebhookPayload_1_Item) MergeWebhookPayload12(v WebhookPayload12) error

MergeWebhookPayload12 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload12

func (*WebhookPayload_1_Item) MergeWebhookPayload13

func (t *WebhookPayload_1_Item) MergeWebhookPayload13(v WebhookPayload13) error

MergeWebhookPayload13 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload13

func (*WebhookPayload_1_Item) MergeWebhookPayload14

func (t *WebhookPayload_1_Item) MergeWebhookPayload14(v WebhookPayload14) error

MergeWebhookPayload14 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload14

func (*WebhookPayload_1_Item) MergeWebhookPayload15

func (t *WebhookPayload_1_Item) MergeWebhookPayload15(v WebhookPayload15) error

MergeWebhookPayload15 performs a merge with any union data inside the WebhookPayload_1_Item, using the provided WebhookPayload15

func (*WebhookPayload_1_Item) UnmarshalJSON

func (t *WebhookPayload_1_Item) UnmarshalJSON(b []byte) error

type WorkItem

type WorkItem struct {
	CreatedAt *time.Time `json:"created_at,omitempty"`
	Id        *string    `json:"id,omitempty"`

	// Payload Generic payload object containing arbitrary data
	Payload *GenericPayload `json:"payload,omitempty"`
	Type    *string         `json:"type,omitempty"`
}

WorkItem defines model for WorkItem.

type Worker

type Worker struct {
	Concurrency   *int       `json:"concurrency,omitempty"`
	Id            *string    `json:"id,omitempty"`
	LastHeartbeat *time.Time `json:"last_heartbeat,omitempty"`
	Name          *string    `json:"name,omitempty"`
	RegisteredAt  *time.Time `json:"registered_at,omitempty"`

	// Status Status of a worker
	Status *WorkerStatus `json:"status,omitempty"`
}

Worker defines model for Worker.

type WorkerStatus

type WorkerStatus string

WorkerStatus Status of a worker

const (
	WorkerStatusActive   WorkerStatus = "active"
	WorkerStatusInactive WorkerStatus = "inactive"
)

Defines values for WorkerStatus.

type Workflow

type Workflow struct {
	CreatedAt   time.Time           `json:"created_at"`
	Definition  *WorkflowDefinition `json:"definition,omitempty"`
	Description *string             `json:"description,omitempty"`
	Id          openapi_types.UUID  `json:"id"`
	Name        string              `json:"name"`
	UpdatedAt   time.Time           `json:"updated_at"`
}

Workflow defines model for Workflow.

type WorkflowCheckpoint

type WorkflowCheckpoint struct {
	ID               uuid.UUID      `json:"id"`
	StepID           uuid.UUID      `json:"step_id"`
	CheckpointType   string         `json:"checkpoint_type"`
	CreatedAt        time.Time      `json:"created_at"`
	ExecutionContext map[string]any `json:"execution_context,omitempty"`
}

type WorkflowDefinition

type WorkflowDefinition struct {
	Edges []WorkflowEdge `json:"edges"`
	Nodes []WorkflowNode `json:"nodes"`
}

WorkflowDefinition defines model for WorkflowDefinition.

type WorkflowDraft

type WorkflowDraft struct {
	Definition *WorkflowDefinition `json:"definition,omitempty"`
	UpdatedAt  *time.Time          `json:"updated_at,omitempty"`
	WorkflowId *openapi_types.UUID `json:"workflow_id,omitempty"`
}

WorkflowDraft defines model for WorkflowDraft.

type WorkflowEdge

type WorkflowEdge struct {
	Id           string  `json:"id"`
	Source       string  `json:"source"`
	SourceOutput *string `json:"sourceOutput,omitempty"`
	Target       string  `json:"target"`
	TargetInput  *string `json:"targetInput,omitempty"`
}

WorkflowEdge defines model for WorkflowEdge.

type WorkflowExecution

type WorkflowExecution struct {
	CompletedAt *time.Time              `json:"completed_at,omitempty"`
	Error       *string                 `json:"error,omitempty"`
	Id          *openapi_types.UUID     `json:"id,omitempty"`
	Result      *map[string]interface{} `json:"result,omitempty"`
	StartedAt   *time.Time              `json:"started_at,omitempty"`

	// Status Status of a workflow run
	Status     *WorkflowRunStatus  `json:"status,omitempty"`
	WorkflowId *openapi_types.UUID `json:"workflow_id,omitempty"`
}

WorkflowExecution defines model for WorkflowExecution.

type WorkflowLayoutResult

type WorkflowLayoutResult struct {
	Nodes *[]struct {
		Id       *string `json:"id,omitempty"`
		Position *struct {
			X *float32 `json:"x,omitempty"`
			Y *float32 `json:"y,omitempty"`
		} `json:"position,omitempty"`
	} `json:"nodes,omitempty"`
}

WorkflowLayoutResult defines model for WorkflowLayoutResult.

type WorkflowList

type WorkflowList struct {
	Limit     int        `json:"limit"`
	Page      int        `json:"page"`
	Total     int        `json:"total"`
	Workflows []Workflow `json:"workflows"`
}

WorkflowList defines model for WorkflowList.

type WorkflowNode

type WorkflowNode struct {
	// Config Node configuration containing node-specific parameters and settings
	Config NodeConfig `json:"config"`
	Id     string     `json:"id"`
	Name   string     `json:"name"`
	Type   string     `json:"type"`
}

WorkflowNode defines model for WorkflowNode.

type WorkflowRun

type WorkflowRun struct {
	CompletedAt *time.Time              `json:"completed_at,omitempty"`
	Context     *map[string]interface{} `json:"context,omitempty"`
	Error       *string                 `json:"error,omitempty"`
	Id          *openapi_types.UUID     `json:"id,omitempty"`
	StartedAt   *time.Time              `json:"started_at,omitempty"`

	// Status Status of a workflow run
	Status     *WorkflowRunStatus  `json:"status,omitempty"`
	WorkflowId *openapi_types.UUID `json:"workflow_id,omitempty"`
}

WorkflowRun defines model for WorkflowRun.

type WorkflowRunDetails

type WorkflowRunDetails struct {
	WorkflowRunSummary
	AgentName   *string               `json:"agent_name,omitempty"`
	InputData   map[string]any        `json:"input_data,omitempty"`
	OutputData  map[string]any        `json:"output_data,omitempty"`
	ErrorData   map[string]any        `json:"error_data,omitempty"`
	Steps       []WorkflowStepDetails `json:"steps,omitempty"`
	Checkpoints []WorkflowCheckpoint  `json:"checkpoints,omitempty"`
}

type WorkflowRunList

type WorkflowRunList struct {
	Limit int           `json:"limit"`
	Page  int           `json:"page"`
	Runs  []WorkflowRun `json:"runs"`
	Total int           `json:"total"`
}

WorkflowRunList defines model for WorkflowRunList.

type WorkflowRunStatus

type WorkflowRunStatus string

WorkflowRunStatus Status of a workflow run

const (
	WorkflowRunStatusCompleted WorkflowRunStatus = "completed"
	WorkflowRunStatusFailed    WorkflowRunStatus = "failed"
	WorkflowRunStatusPending   WorkflowRunStatus = "pending"
	WorkflowRunStatusRunning   WorkflowRunStatus = "running"
)

Defines values for WorkflowRunStatus.

type WorkflowRunSummary

type WorkflowRunSummary struct {
	ID                 uuid.UUID  `json:"id"`
	AgentID            uuid.UUID  `json:"agent_id"`
	Status             string     `json:"status"`
	CreatedAt          time.Time  `json:"created_at"`
	StartedAt          *time.Time `json:"started_at,omitempty"`
	CompletedAt        *time.Time `json:"completed_at,omitempty"`
	TotalSteps         int        `json:"total_steps"`
	CompletedSteps     int        `json:"completed_steps"`
	FailedSteps        int        `json:"failed_steps"`
	DurationSeconds    float64    `json:"duration_seconds"`
	ProgressPercentage float64    `json:"progress_percentage"`
}

type WorkflowRunsHandler

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

WorkflowRunsHandler handles workflow execution API endpoints

func NewWorkflowRunsHandler

func NewWorkflowRunsHandler(db *sql.DB, engine execution.ExecutionEngine) *WorkflowRunsHandler

NewWorkflowRunsHandler creates a new workflow runs handler

type WorkflowStep

type WorkflowStep struct {
	CompletedAt *time.Time          `json:"completed_at,omitempty"`
	Error       *string             `json:"error,omitempty"`
	Id          *openapi_types.UUID `json:"id,omitempty"`

	// Input Generic input object containing arbitrary input data
	Input  *GenericInput `json:"input,omitempty"`
	NodeId *string       `json:"node_id,omitempty"`

	// Output Generic output object containing arbitrary output data
	Output    *GenericOutput      `json:"output,omitempty"`
	RunId     *openapi_types.UUID `json:"run_id,omitempty"`
	StartedAt *time.Time          `json:"started_at,omitempty"`

	// Status Status of a workflow step
	Status *WorkflowStepStatus `json:"status,omitempty"`
}

WorkflowStep defines model for WorkflowStep.

type WorkflowStepDetails

type WorkflowStepDetails struct {
	ID           uuid.UUID      `json:"id"`
	NodeID       string         `json:"node_id"`
	NodeType     string         `json:"node_type"`
	Status       string         `json:"status"`
	StepNumber   int            `json:"step_number"`
	AttemptCount int            `json:"attempt_count"`
	MaxAttempts  int            `json:"max_attempts"`
	CreatedAt    time.Time      `json:"created_at"`
	StartedAt    *time.Time     `json:"started_at,omitempty"`
	CompletedAt  *time.Time     `json:"completed_at,omitempty"`
	NextRetryAt  *time.Time     `json:"next_retry_at,omitempty"`
	NodeConfig   map[string]any `json:"node_config,omitempty"`
	ErrorDetails map[string]any `json:"error_details,omitempty"`
	DurationMs   *float64       `json:"duration_ms,omitempty"`
}

type WorkflowStepStatus

type WorkflowStepStatus string

WorkflowStepStatus Status of a workflow step

const (
	WorkflowStepStatusCompleted WorkflowStepStatus = "completed"
	WorkflowStepStatusFailed    WorkflowStepStatus = "failed"
	WorkflowStepStatusPending   WorkflowStepStatus = "pending"
	WorkflowStepStatusRunning   WorkflowStepStatus = "running"
	WorkflowStepStatusSkipped   WorkflowStepStatus = "skipped"
)

Defines values for WorkflowStepStatus.

type WorkflowVersion

type WorkflowVersion struct {
	CreatedAt     *time.Time          `json:"created_at,omitempty"`
	Definition    *WorkflowDefinition `json:"definition,omitempty"`
	Description   *string             `json:"description,omitempty"`
	Id            *openapi_types.UUID `json:"id,omitempty"`
	IsCurrent     *bool               `json:"is_current,omitempty"`
	Name          *string             `json:"name,omitempty"`
	VersionNumber *int                `json:"version_number,omitempty"`
	WorkflowId    *openapi_types.UUID `json:"workflow_id,omitempty"`
}

WorkflowVersion defines model for WorkflowVersion.

type WorkflowVersionList

type WorkflowVersionList struct {
	Total    int               `json:"total"`
	Versions []WorkflowVersion `json:"versions"`
}

WorkflowVersionList defines model for WorkflowVersionList.

Jump to

Keyboard shortcuts

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