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
- func Handler(si ServerInterface) http.Handler
- func HandlerFromMux(si ServerInterface, r chi.Router) http.Handler
- func HandlerFromMuxWithBaseURL(si ServerInterface, r chi.Router, baseURL string) http.Handler
- func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler
- func NewCombinedRouter(database *sql.DB, engine execution.ExecutionEngine) http.Handler
- func NewOpenAPIRouter(database *sql.DB, engine execution.ExecutionEngine) http.Handler
- type AssistantChat200JSONResponse
- type AssistantChat400JSONResponse
- type AssistantChat500JSONResponse
- type AssistantChatJSONRequestBody
- type AssistantChatRequest
- type AssistantChatRequestObject
- type AssistantChatResponse
- type AssistantChatResponseObject
- type AutoLayoutWorkflow200JSONResponse
- type AutoLayoutWorkflow404JSONResponse
- type AutoLayoutWorkflow500JSONResponse
- type AutoLayoutWorkflowRequestObject
- type AutoLayoutWorkflowResponseObject
- type ChatChoice
- type ChatFinishReason
- type ChatMessage
- type ChatMessageRole
- type ChatUsage
- type ChiServerOptions
- type ClaimWork200JSONResponse
- type ClaimWorkJSONRequestBody
- type ClaimWorkRequest
- type ClaimWorkRequestObject
- type ClaimWorkResponseObject
- type CompleteWork200Response
- type CompleteWorkJSONRequestBody
- type CompleteWorkRequest
- type CompleteWorkRequestObject
- type CompleteWorkResponseObject
- type Connection
- type ConnectionConfig
- type ConnectionSecret
- type ConnectionStatus
- type ControlWorkflowRunRequest
- type CreateConnection201JSONResponse
- type CreateConnection400JSONResponse
- type CreateConnection500JSONResponse
- type CreateConnectionJSONRequestBody
- type CreateConnectionRequest
- type CreateConnectionRequestObject
- type CreateConnectionResponseObject
- type CreateTrigger201JSONResponse
- type CreateTrigger400JSONResponse
- type CreateTrigger500JSONResponse
- type CreateTriggerJSONRequestBody
- type CreateTriggerRequest
- type CreateTriggerRequestObject
- type CreateTriggerResponseObject
- type CreateWorkflow201JSONResponse
- type CreateWorkflow400JSONResponse
- type CreateWorkflow500JSONResponse
- type CreateWorkflowEdge201JSONResponse
- type CreateWorkflowEdge400JSONResponse
- type CreateWorkflowEdge404JSONResponse
- type CreateWorkflowEdge500JSONResponse
- type CreateWorkflowEdgeJSONRequestBody
- type CreateWorkflowEdgeRequest
- type CreateWorkflowEdgeRequestObject
- type CreateWorkflowEdgeResponseObject
- type CreateWorkflowJSONRequestBody
- type CreateWorkflowNode201JSONResponse
- type CreateWorkflowNode400JSONResponse
- type CreateWorkflowNode404JSONResponse
- type CreateWorkflowNode500JSONResponse
- type CreateWorkflowNodeJSONRequestBody
- type CreateWorkflowNodeRequest
- type CreateWorkflowNodeRequestObject
- type CreateWorkflowNodeResponseObject
- type CreateWorkflowRequest
- type CreateWorkflowRequestObject
- type CreateWorkflowResponseObject
- type CreateWorkflowRunRequest
- type CreateWorkflowVersion201JSONResponse
- type CreateWorkflowVersion400JSONResponse
- type CreateWorkflowVersion404JSONResponse
- type CreateWorkflowVersion500JSONResponse
- type CreateWorkflowVersionJSONRequestBody
- type CreateWorkflowVersionRequest
- type CreateWorkflowVersionRequestObject
- type CreateWorkflowVersionResponseObject
- type Credential
- type CredentialStatus
- type CredentialTestResult
- type CredentialType
- type CredentialTypeSchema
- type DefaultExecutor
- type DeleteConnection204Response
- type DeleteConnection404JSONResponse
- type DeleteConnection500JSONResponse
- type DeleteConnectionRequestObject
- type DeleteConnectionResponseObject
- type DeleteTrigger204Response
- type DeleteTrigger404JSONResponse
- type DeleteTrigger500JSONResponse
- type DeleteTriggerRequestObject
- type DeleteTriggerResponseObject
- type DeleteWorkflow204Response
- type DeleteWorkflow404JSONResponse
- type DeleteWorkflow500JSONResponse
- type DeleteWorkflowEdge204Response
- type DeleteWorkflowEdge404JSONResponse
- type DeleteWorkflowEdge500JSONResponse
- type DeleteWorkflowEdgeRequestObject
- type DeleteWorkflowEdgeResponseObject
- type DeleteWorkflowNode204Response
- type DeleteWorkflowNode404JSONResponse
- type DeleteWorkflowNode500JSONResponse
- type DeleteWorkflowNodeRequestObject
- type DeleteWorkflowNodeResponseObject
- type DeleteWorkflowRequestObject
- type DeleteWorkflowResponseObject
- type DeployWorkflowVersion200JSONResponse
- type DeployWorkflowVersion404JSONResponse
- type DeployWorkflowVersion500JSONResponse
- type DeployWorkflowVersionRequestObject
- type DeployWorkflowVersionResponseObject
- type Error
- type ExecuteWorkflow200JSONResponse
- type ExecuteWorkflow400JSONResponse
- type ExecuteWorkflow404JSONResponse
- type ExecuteWorkflow500JSONResponse
- type ExecuteWorkflowJSONBody
- type ExecuteWorkflowJSONRequestBody
- type ExecuteWorkflowRequest
- type ExecuteWorkflowRequestObject
- type ExecuteWorkflowResponseObject
- type Extension
- type FunctionCall
- type GenericInput
- type GenericOutput
- type GenericPayload
- type GenericResult
- type GetConnection200JSONResponse
- type GetConnection404JSONResponse
- type GetConnection500JSONResponse
- type GetConnectionRequestObject
- type GetConnectionResponseObject
- type GetCredentialTypeSchema200JSONResponse
- type GetCredentialTypeSchema404JSONResponse
- type GetCredentialTypeSchema500JSONResponse
- type GetCredentialTypeSchemaRequestObject
- type GetCredentialTypeSchemaResponseObject
- type GetHealth200JSONResponse
- type GetHealth503JSONResponse
- type GetHealthRequestObject
- type GetHealthResponseObject
- type GetLatestWorkflowVersion200JSONResponse
- type GetLatestWorkflowVersion404JSONResponse
- type GetLatestWorkflowVersion500JSONResponse
- type GetLatestWorkflowVersionRequestObject
- type GetLatestWorkflowVersionResponseObject
- type GetNodeParameterOptions200JSONResponse
- type GetNodeParameterOptions404JSONResponse
- type GetNodeParameterOptions500JSONResponse
- type GetNodeParameterOptionsParams
- type GetNodeParameterOptionsRequestObject
- type GetNodeParameterOptionsResponseObject
- type GetTrigger200JSONResponse
- type GetTrigger404JSONResponse
- type GetTrigger500JSONResponse
- type GetTriggerRequestObject
- type GetTriggerResponseObject
- type GetWorkflow200JSONResponse
- type GetWorkflow404JSONResponse
- type GetWorkflow500JSONResponse
- type GetWorkflowDraft200JSONResponse
- type GetWorkflowDraft404JSONResponse
- type GetWorkflowDraft500JSONResponse
- type GetWorkflowDraftRequestObject
- type GetWorkflowDraftResponseObject
- type GetWorkflowNode200JSONResponse
- type GetWorkflowNode404JSONResponse
- type GetWorkflowNode500JSONResponse
- type GetWorkflowNodeRequestObject
- type GetWorkflowNodeResponseObject
- type GetWorkflowRequestObject
- type GetWorkflowResponseObject
- type GetWorkflowRun200JSONResponse
- type GetWorkflowRun404JSONResponse
- type GetWorkflowRun500JSONResponse
- type GetWorkflowRunRequestObject
- type GetWorkflowRunResponseObject
- type GetWorkflowRunSteps200JSONResponse
- type GetWorkflowRunSteps404JSONResponse
- type GetWorkflowRunSteps500JSONResponse
- type GetWorkflowRunStepsRequestObject
- type GetWorkflowRunStepsResponseObject
- type HTTPRequestExecutor
- type HandleWebhook200Response
- type HandleWebhook404JSONResponse
- type HandleWebhook500JSONResponse
- type HandleWebhookJSONRequestBody
- type HandleWebhookRequestObject
- type HandleWebhookResponseObject
- type Hub
- type IfExecutor
- type Integration
- type IntegrationStatus
- type InvalidParamFormatError
- type ListConnections200JSONResponse
- type ListConnections500JSONResponse
- type ListConnectionsRequestObject
- type ListConnectionsResponseObject
- type ListCredentialTypes200JSONResponse
- type ListCredentialTypes500JSONResponse
- type ListCredentialTypesRequestObject
- type ListCredentialTypesResponseObject
- type ListCredentials200JSONResponse
- type ListCredentials500JSONResponse
- type ListCredentialsParams
- type ListCredentialsRequestObject
- type ListCredentialsResponseObject
- type ListExtensions200JSONResponse
- type ListExtensions500JSONResponse
- type ListExtensionsRequestObject
- type ListExtensionsResponseObject
- type ListIntegrations200JSONResponse
- type ListIntegrations500JSONResponse
- type ListIntegrationsRequestObject
- type ListIntegrationsResponseObject
- type ListNodeTypes200JSONResponse
- type ListNodeTypesParams
- type ListNodeTypesRequestObject
- type ListNodeTypesResponseObject
- type ListTriggers200JSONResponse
- type ListTriggers500JSONResponse
- type ListTriggersRequestObject
- type ListTriggersResponseObject
- type ListWorkers200JSONResponse
- type ListWorkers500JSONResponse
- type ListWorkersRequestObject
- type ListWorkersResponseObject
- type ListWorkflowEdges200JSONResponse
- type ListWorkflowEdges404JSONResponse
- type ListWorkflowEdges500JSONResponse
- type ListWorkflowEdgesRequestObject
- type ListWorkflowEdgesResponseObject
- type ListWorkflowNodes200JSONResponse
- type ListWorkflowNodes404JSONResponse
- type ListWorkflowNodes500JSONResponse
- type ListWorkflowNodesRequestObject
- type ListWorkflowNodesResponseObject
- type ListWorkflowRuns200JSONResponse
- type ListWorkflowRuns500JSONResponse
- type ListWorkflowRunsParams
- type ListWorkflowRunsRequestObject
- type ListWorkflowRunsResponseObject
- type ListWorkflowVersions200JSONResponse
- type ListWorkflowVersions404JSONResponse
- type ListWorkflowVersions500JSONResponse
- type ListWorkflowVersionsParams
- type ListWorkflowVersionsRequestObject
- type ListWorkflowVersionsResponseObject
- type ListWorkflows200JSONResponse
- type ListWorkflows500JSONResponse
- type ListWorkflowsParams
- type ListWorkflowsRequestObject
- type ListWorkflowsResponseObject
- type MiddlewareFunc
- type NodeConfig
- type NodeExecutor
- type NodeInput
- type NodeKind
- type NodeOutput
- type NodeParameterOptions
- type NodePosition
- type NodeTestResult
- type NodeType
- type OpenAPIHandlers
- func (h *OpenAPIHandlers) AssistantChat(ctx context.Context, request AssistantChatRequestObject) (AssistantChatResponseObject, error)
- func (h *OpenAPIHandlers) AutoLayoutWorkflow(ctx context.Context, request AutoLayoutWorkflowRequestObject) (AutoLayoutWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) ClaimWork(ctx context.Context, request ClaimWorkRequestObject) (ClaimWorkResponseObject, error)
- func (h *OpenAPIHandlers) CompleteWork(ctx context.Context, request CompleteWorkRequestObject) (CompleteWorkResponseObject, error)
- func (h *OpenAPIHandlers) CreateConnection(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)
- func (h *OpenAPIHandlers) CreateTrigger(ctx context.Context, request CreateTriggerRequestObject) (CreateTriggerResponseObject, error)
- func (h *OpenAPIHandlers) CreateWorkflow(ctx context.Context, request CreateWorkflowRequestObject) (CreateWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) CreateWorkflowEdge(ctx context.Context, request CreateWorkflowEdgeRequestObject) (CreateWorkflowEdgeResponseObject, error)
- func (h *OpenAPIHandlers) CreateWorkflowNode(ctx context.Context, request CreateWorkflowNodeRequestObject) (CreateWorkflowNodeResponseObject, error)
- func (h *OpenAPIHandlers) CreateWorkflowVersion(ctx context.Context, request CreateWorkflowVersionRequestObject) (CreateWorkflowVersionResponseObject, error)
- func (h *OpenAPIHandlers) DeleteConnection(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)
- func (h *OpenAPIHandlers) DeleteTrigger(ctx context.Context, request DeleteTriggerRequestObject) (DeleteTriggerResponseObject, error)
- func (h *OpenAPIHandlers) DeleteWorkflow(ctx context.Context, request DeleteWorkflowRequestObject) (DeleteWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) DeleteWorkflowEdge(ctx context.Context, request DeleteWorkflowEdgeRequestObject) (DeleteWorkflowEdgeResponseObject, error)
- func (h *OpenAPIHandlers) DeleteWorkflowNode(ctx context.Context, request DeleteWorkflowNodeRequestObject) (DeleteWorkflowNodeResponseObject, error)
- func (h *OpenAPIHandlers) DeployWorkflowVersion(ctx context.Context, request DeployWorkflowVersionRequestObject) (DeployWorkflowVersionResponseObject, error)
- func (h *OpenAPIHandlers) ExecuteWorkflow(ctx context.Context, request ExecuteWorkflowRequestObject) (ExecuteWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) GetConnection(ctx context.Context, request GetConnectionRequestObject) (GetConnectionResponseObject, error)
- func (h *OpenAPIHandlers) GetCredentialTypeSchema(ctx context.Context, request GetCredentialTypeSchemaRequestObject) (GetCredentialTypeSchemaResponseObject, error)
- func (h *OpenAPIHandlers) GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
- func (h *OpenAPIHandlers) GetLatestWorkflowVersion(ctx context.Context, request GetLatestWorkflowVersionRequestObject) (GetLatestWorkflowVersionResponseObject, error)
- func (h *OpenAPIHandlers) GetNodeParameterOptions(ctx context.Context, request GetNodeParameterOptionsRequestObject) (GetNodeParameterOptionsResponseObject, error)
- func (h *OpenAPIHandlers) GetTrigger(ctx context.Context, request GetTriggerRequestObject) (GetTriggerResponseObject, error)
- func (h *OpenAPIHandlers) GetWorkflow(ctx context.Context, request GetWorkflowRequestObject) (GetWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) GetWorkflowDraft(ctx context.Context, request GetWorkflowDraftRequestObject) (GetWorkflowDraftResponseObject, error)
- func (h *OpenAPIHandlers) GetWorkflowNode(ctx context.Context, request GetWorkflowNodeRequestObject) (GetWorkflowNodeResponseObject, error)
- func (h *OpenAPIHandlers) GetWorkflowRun(ctx context.Context, request GetWorkflowRunRequestObject) (GetWorkflowRunResponseObject, error)
- func (h *OpenAPIHandlers) GetWorkflowRunSteps(ctx context.Context, request GetWorkflowRunStepsRequestObject) (GetWorkflowRunStepsResponseObject, error)
- func (h *OpenAPIHandlers) HandleWebhook(ctx context.Context, request HandleWebhookRequestObject) (HandleWebhookResponseObject, error)
- func (h *OpenAPIHandlers) ListConnections(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)
- func (h *OpenAPIHandlers) ListCredentialTypes(ctx context.Context, request ListCredentialTypesRequestObject) (ListCredentialTypesResponseObject, error)
- func (h *OpenAPIHandlers) ListCredentials(ctx context.Context, request ListCredentialsRequestObject) (ListCredentialsResponseObject, error)
- func (h *OpenAPIHandlers) ListExtensions(ctx context.Context, request ListExtensionsRequestObject) (ListExtensionsResponseObject, error)
- func (h *OpenAPIHandlers) ListIntegrations(ctx context.Context, request ListIntegrationsRequestObject) (ListIntegrationsResponseObject, error)
- func (h *OpenAPIHandlers) ListNodeTypes(ctx context.Context, request ListNodeTypesRequestObject) (ListNodeTypesResponseObject, error)
- func (h *OpenAPIHandlers) ListTriggers(ctx context.Context, request ListTriggersRequestObject) (ListTriggersResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkers(ctx context.Context, request ListWorkersRequestObject) (ListWorkersResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkflowEdges(ctx context.Context, request ListWorkflowEdgesRequestObject) (ListWorkflowEdgesResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkflowNodes(ctx context.Context, request ListWorkflowNodesRequestObject) (ListWorkflowNodesResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkflowRuns(ctx context.Context, request ListWorkflowRunsRequestObject) (ListWorkflowRunsResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkflowVersions(ctx context.Context, request ListWorkflowVersionsRequestObject) (ListWorkflowVersionsResponseObject, error)
- func (h *OpenAPIHandlers) ListWorkflows(ctx context.Context, request ListWorkflowsRequestObject) (ListWorkflowsResponseObject, error)
- func (h *OpenAPIHandlers) RegisterWorker(ctx context.Context, request RegisterWorkerRequestObject) (RegisterWorkerResponseObject, error)
- func (h *OpenAPIHandlers) TestCredentials(ctx context.Context, request TestCredentialsRequestObject) (TestCredentialsResponseObject, error)
- func (h *OpenAPIHandlers) TestWorkflowDraftNode(ctx context.Context, request TestWorkflowDraftNodeRequestObject) (TestWorkflowDraftNodeResponseObject, error)
- func (h *OpenAPIHandlers) UnregisterWorker(ctx context.Context, request UnregisterWorkerRequestObject) (UnregisterWorkerResponseObject, error)
- func (h *OpenAPIHandlers) UpdateConnection(ctx context.Context, request UpdateConnectionRequestObject) (UpdateConnectionResponseObject, error)
- func (h *OpenAPIHandlers) UpdateTrigger(ctx context.Context, request UpdateTriggerRequestObject) (UpdateTriggerResponseObject, error)
- func (h *OpenAPIHandlers) UpdateWorkerHeartbeat(ctx context.Context, request UpdateWorkerHeartbeatRequestObject) (UpdateWorkerHeartbeatResponseObject, error)
- func (h *OpenAPIHandlers) UpdateWorkflow(ctx context.Context, request UpdateWorkflowRequestObject) (UpdateWorkflowResponseObject, error)
- func (h *OpenAPIHandlers) UpdateWorkflowDraft(ctx context.Context, request UpdateWorkflowDraftRequestObject) (UpdateWorkflowDraftResponseObject, error)
- func (h *OpenAPIHandlers) UpdateWorkflowNode(ctx context.Context, request UpdateWorkflowNodeRequestObject) (UpdateWorkflowNodeResponseObject, error)
- type PaginatedResponse
- type PaginationInfo
- type ParamSpec
- type RegisterWorker201JSONResponse
- type RegisterWorker400JSONResponse
- type RegisterWorker500JSONResponse
- type RegisterWorkerJSONRequestBody
- type RegisterWorkerRequest
- type RegisterWorkerRequestObject
- type RegisterWorkerResponseObject
- type RequiredHeaderError
- type RequiredParamError
- type ScheduleExecutor
- type ServerInterface
- type ServerInterfaceWrapper
- func (siw *ServerInterfaceWrapper) AssistantChat(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) AutoLayoutWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ClaimWork(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CompleteWork(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateConnection(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateTrigger(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateWorkflowEdge(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateWorkflowNode(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CreateWorkflowVersion(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeleteConnection(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeleteTrigger(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeleteWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeleteWorkflowEdge(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeleteWorkflowNode(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) DeployWorkflowVersion(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ExecuteWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetConnection(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetCredentialTypeSchema(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetHealth(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetLatestWorkflowVersion(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetNodeParameterOptions(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetTrigger(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetWorkflowDraft(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetWorkflowNode(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetWorkflowRun(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetWorkflowRunSteps(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) HandleWebhook(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListConnections(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListCredentialTypes(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListCredentials(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListExtensions(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListIntegrations(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListNodeTypes(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListTriggers(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkers(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkflowEdges(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkflowNodes(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkflowRuns(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkflowVersions(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListWorkflows(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) RegisterWorker(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) TestCredentials(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) TestWorkflowDraftNode(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UnregisterWorker(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateConnection(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateTrigger(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateWorkerHeartbeat(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateWorkflow(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateWorkflowDraft(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpdateWorkflowNode(w http.ResponseWriter, r *http.Request)
- type StrictHTTPServerOptions
- type StrictHandlerFunc
- type StrictMiddlewareFunc
- type StrictServerInterface
- type TestCredentials200JSONResponse
- type TestCredentials400JSONResponse
- type TestCredentials404JSONResponse
- type TestCredentials500JSONResponse
- type TestCredentialsJSONBody
- type TestCredentialsJSONRequestBody
- type TestCredentialsRequestObject
- type TestCredentialsResponseObject
- type TestWorkflowDraftNode200JSONResponse
- type TestWorkflowDraftNode400JSONResponse
- type TestWorkflowDraftNode404JSONResponse
- type TestWorkflowDraftNode500JSONResponse
- type TestWorkflowDraftNodeJSONRequestBody
- type TestWorkflowDraftNodeRequestObject
- type TestWorkflowDraftNodeResponseObject
- type TimerExecutor
- type TooManyValuesForParamError
- type Trigger
- type TriggerConfig
- type TriggerType
- type UnescapedCookieParamError
- type Unimplemented
- func (_ Unimplemented) AssistantChat(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) AutoLayoutWorkflow(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) ClaimWork(w http.ResponseWriter, r *http.Request, id string)
- func (_ Unimplemented) CompleteWork(w http.ResponseWriter, r *http.Request, id string, itemId string)
- func (_ Unimplemented) CreateConnection(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) CreateTrigger(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) CreateWorkflow(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) CreateWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) CreateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) CreateWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) DeleteConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) DeleteTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) DeleteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) DeleteWorkflowEdge(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) DeleteWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) DeployWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) ExecuteWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) GetConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) GetCredentialTypeSchema(w http.ResponseWriter, r *http.Request, pType string)
- func (_ Unimplemented) GetHealth(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) GetLatestWorkflowVersion(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) GetNodeParameterOptions(w http.ResponseWriter, r *http.Request, pType string, parameter string, ...)
- func (_ Unimplemented) GetTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) GetWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) GetWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) GetWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) GetWorkflowRun(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) GetWorkflowRunSteps(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) HandleWebhook(w http.ResponseWriter, r *http.Request, token string)
- func (_ Unimplemented) ListConnections(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListCredentialTypes(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListCredentials(w http.ResponseWriter, r *http.Request, params ListCredentialsParams)
- func (_ Unimplemented) ListExtensions(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListIntegrations(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListNodeTypes(w http.ResponseWriter, r *http.Request, params ListNodeTypesParams)
- func (_ Unimplemented) ListTriggers(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListWorkers(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) ListWorkflowEdges(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) ListWorkflowNodes(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) ListWorkflowRuns(w http.ResponseWriter, r *http.Request, params ListWorkflowRunsParams)
- func (_ Unimplemented) ListWorkflowVersions(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) ListWorkflows(w http.ResponseWriter, r *http.Request, params ListWorkflowsParams)
- func (_ Unimplemented) RegisterWorker(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) TestCredentials(w http.ResponseWriter, r *http.Request, pType string)
- func (_ Unimplemented) TestWorkflowDraftNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- func (_ Unimplemented) UnregisterWorker(w http.ResponseWriter, r *http.Request, id string)
- func (_ Unimplemented) UpdateConnection(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) UpdateTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) UpdateWorkerHeartbeat(w http.ResponseWriter, r *http.Request, id string)
- func (_ Unimplemented) UpdateWorkflow(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
- func (_ Unimplemented) UpdateWorkflowDraft(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID)
- func (_ Unimplemented) UpdateWorkflowNode(w http.ResponseWriter, r *http.Request, workflowId openapi_types.UUID, ...)
- type UnmarshalingParamError
- type UnregisterWorker204Response
- type UnregisterWorker404JSONResponse
- type UnregisterWorker500JSONResponse
- type UnregisterWorkerRequestObject
- type UnregisterWorkerResponseObject
- type UpdateConnection200JSONResponse
- type UpdateConnection400JSONResponse
- type UpdateConnection404JSONResponse
- type UpdateConnection500JSONResponse
- type UpdateConnectionJSONRequestBody
- type UpdateConnectionRequest
- type UpdateConnectionRequestObject
- type UpdateConnectionResponseObject
- type UpdateTrigger200JSONResponse
- type UpdateTrigger400JSONResponse
- type UpdateTrigger404JSONResponse
- type UpdateTrigger500JSONResponse
- type UpdateTriggerJSONRequestBody
- type UpdateTriggerRequest
- type UpdateTriggerRequestObject
- type UpdateTriggerResponseObject
- type UpdateWorkerHeartbeat200Response
- type UpdateWorkerHeartbeat404JSONResponse
- type UpdateWorkerHeartbeat500JSONResponse
- type UpdateWorkerHeartbeatRequestObject
- type UpdateWorkerHeartbeatResponseObject
- type UpdateWorkflow200JSONResponse
- type UpdateWorkflow400JSONResponse
- type UpdateWorkflow404JSONResponse
- type UpdateWorkflow500JSONResponse
- type UpdateWorkflowDraft200JSONResponse
- type UpdateWorkflowDraft400JSONResponse
- type UpdateWorkflowDraft404JSONResponse
- type UpdateWorkflowDraft500JSONResponse
- type UpdateWorkflowDraftJSONRequestBody
- type UpdateWorkflowDraftRequest
- type UpdateWorkflowDraftRequestObject
- type UpdateWorkflowDraftResponseObject
- type UpdateWorkflowJSONRequestBody
- type UpdateWorkflowNode200JSONResponse
- type UpdateWorkflowNode400JSONResponse
- type UpdateWorkflowNode404JSONResponse
- type UpdateWorkflowNode500JSONResponse
- type UpdateWorkflowNodeJSONRequestBody
- type UpdateWorkflowNodeRequest
- type UpdateWorkflowNodeRequestObject
- type UpdateWorkflowNodeResponseObject
- type UpdateWorkflowRequest
- type UpdateWorkflowRequestObject
- type UpdateWorkflowResponseObject
- type ValidatorSpec
- type WebhookPayload
- func (t WebhookPayload) AsWebhookPayload0() (WebhookPayload0, error)
- func (t WebhookPayload) AsWebhookPayload1() (WebhookPayload1, error)
- func (t WebhookPayload) AsWebhookPayload2() (WebhookPayload2, error)
- func (t WebhookPayload) AsWebhookPayload3() (WebhookPayload3, error)
- func (t WebhookPayload) AsWebhookPayload4() (WebhookPayload4, error)
- func (t WebhookPayload) AsWebhookPayload5() (WebhookPayload5, error)
- func (t *WebhookPayload) FromWebhookPayload0(v WebhookPayload0) error
- func (t *WebhookPayload) FromWebhookPayload1(v WebhookPayload1) error
- func (t *WebhookPayload) FromWebhookPayload2(v WebhookPayload2) error
- func (t *WebhookPayload) FromWebhookPayload3(v WebhookPayload3) error
- func (t *WebhookPayload) FromWebhookPayload4(v WebhookPayload4) error
- func (t *WebhookPayload) FromWebhookPayload5(v WebhookPayload5) error
- func (t WebhookPayload) MarshalJSON() ([]byte, error)
- func (t *WebhookPayload) MergeWebhookPayload0(v WebhookPayload0) error
- func (t *WebhookPayload) MergeWebhookPayload1(v WebhookPayload1) error
- func (t *WebhookPayload) MergeWebhookPayload2(v WebhookPayload2) error
- func (t *WebhookPayload) MergeWebhookPayload3(v WebhookPayload3) error
- func (t *WebhookPayload) MergeWebhookPayload4(v WebhookPayload4) error
- func (t *WebhookPayload) MergeWebhookPayload5(v WebhookPayload5) error
- func (t *WebhookPayload) UnmarshalJSON(b []byte) error
- type WebhookPayload0
- type WebhookPayload1
- type WebhookPayload2
- type WebhookPayload3
- type WebhookPayload4
- type WebhookPayload5
- type WebhookPayload10
- type WebhookPayload11
- type WebhookPayload12
- type WebhookPayload13
- type WebhookPayload14
- type WebhookPayload15
- type WebhookPayload_1_Item
- func (t WebhookPayload_1_Item) AsWebhookPayload10() (WebhookPayload10, error)
- func (t WebhookPayload_1_Item) AsWebhookPayload11() (WebhookPayload11, error)
- func (t WebhookPayload_1_Item) AsWebhookPayload12() (WebhookPayload12, error)
- func (t WebhookPayload_1_Item) AsWebhookPayload13() (WebhookPayload13, error)
- func (t WebhookPayload_1_Item) AsWebhookPayload14() (WebhookPayload14, error)
- func (t WebhookPayload_1_Item) AsWebhookPayload15() (WebhookPayload15, error)
- func (t *WebhookPayload_1_Item) FromWebhookPayload10(v WebhookPayload10) error
- func (t *WebhookPayload_1_Item) FromWebhookPayload11(v WebhookPayload11) error
- func (t *WebhookPayload_1_Item) FromWebhookPayload12(v WebhookPayload12) error
- func (t *WebhookPayload_1_Item) FromWebhookPayload13(v WebhookPayload13) error
- func (t *WebhookPayload_1_Item) FromWebhookPayload14(v WebhookPayload14) error
- func (t *WebhookPayload_1_Item) FromWebhookPayload15(v WebhookPayload15) error
- func (t WebhookPayload_1_Item) MarshalJSON() ([]byte, error)
- func (t *WebhookPayload_1_Item) MergeWebhookPayload10(v WebhookPayload10) error
- func (t *WebhookPayload_1_Item) MergeWebhookPayload11(v WebhookPayload11) error
- func (t *WebhookPayload_1_Item) MergeWebhookPayload12(v WebhookPayload12) error
- func (t *WebhookPayload_1_Item) MergeWebhookPayload13(v WebhookPayload13) error
- func (t *WebhookPayload_1_Item) MergeWebhookPayload14(v WebhookPayload14) error
- func (t *WebhookPayload_1_Item) MergeWebhookPayload15(v WebhookPayload15) error
- func (t *WebhookPayload_1_Item) UnmarshalJSON(b []byte) error
- type WorkItem
- type Worker
- type WorkerStatus
- type Workflow
- type WorkflowCheckpoint
- type WorkflowDefinition
- type WorkflowDraft
- type WorkflowEdge
- type WorkflowExecution
- type WorkflowLayoutResult
- type WorkflowList
- type WorkflowNode
- type WorkflowRun
- type WorkflowRunDetails
- type WorkflowRunList
- type WorkflowRunStatus
- type WorkflowRunSummary
- type WorkflowRunsHandler
- type WorkflowStep
- type WorkflowStepDetails
- type WorkflowStepStatus
- type WorkflowVersion
- type WorkflowVersionList
Constants ¶
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 HandlerWithOptions ¶
func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler
HandlerWithOptions creates http.Handler with additional options
func NewCombinedRouter ¶
NewCombinedRouter creates a router that combines OpenAPI handlers with essential legacy endpoints
func NewOpenAPIRouter ¶
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.
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.
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.
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 ¶
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 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 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 ¶
func (h *OpenAPIHandlers) AssistantChat(ctx context.Context, request AssistantChatRequestObject) (AssistantChatResponseObject, error)
AssistantChat provides AI-powered assistance for workflow building
func (*OpenAPIHandlers) AutoLayoutWorkflow ¶
func (h *OpenAPIHandlers) AutoLayoutWorkflow(ctx context.Context, request AutoLayoutWorkflowRequestObject) (AutoLayoutWorkflowResponseObject, error)
AutoLayoutWorkflow auto-layouts workflow nodes
func (*OpenAPIHandlers) ClaimWork ¶
func (h *OpenAPIHandlers) ClaimWork(ctx context.Context, request ClaimWorkRequestObject) (ClaimWorkResponseObject, error)
ClaimWork allows a worker to claim work items
func (*OpenAPIHandlers) CompleteWork ¶
func (h *OpenAPIHandlers) CompleteWork(ctx context.Context, request CompleteWorkRequestObject) (CompleteWorkResponseObject, error)
CompleteWork marks a work item as completed
func (*OpenAPIHandlers) CreateConnection ¶
func (h *OpenAPIHandlers) CreateConnection(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)
CreateConnection creates a new connection
func (*OpenAPIHandlers) CreateTrigger ¶
func (h *OpenAPIHandlers) CreateTrigger(ctx context.Context, request CreateTriggerRequestObject) (CreateTriggerResponseObject, error)
CreateTrigger creates a new trigger
func (*OpenAPIHandlers) CreateWorkflow ¶
func (h *OpenAPIHandlers) CreateWorkflow(ctx context.Context, request CreateWorkflowRequestObject) (CreateWorkflowResponseObject, error)
CreateWorkflow creates a new workflow
func (*OpenAPIHandlers) CreateWorkflowEdge ¶
func (h *OpenAPIHandlers) CreateWorkflowEdge(ctx context.Context, request CreateWorkflowEdgeRequestObject) (CreateWorkflowEdgeResponseObject, error)
CreateWorkflowEdge creates a new edge in workflow
func (*OpenAPIHandlers) CreateWorkflowNode ¶
func (h *OpenAPIHandlers) CreateWorkflowNode(ctx context.Context, request CreateWorkflowNodeRequestObject) (CreateWorkflowNodeResponseObject, error)
CreateWorkflowNode creates a new node in workflow
func (*OpenAPIHandlers) CreateWorkflowVersion ¶
func (h *OpenAPIHandlers) CreateWorkflowVersion(ctx context.Context, request CreateWorkflowVersionRequestObject) (CreateWorkflowVersionResponseObject, error)
CreateWorkflowVersion creates a new version of a workflow
func (*OpenAPIHandlers) DeleteConnection ¶
func (h *OpenAPIHandlers) DeleteConnection(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)
DeleteConnection removes a connection
func (*OpenAPIHandlers) DeleteTrigger ¶
func (h *OpenAPIHandlers) DeleteTrigger(ctx context.Context, request DeleteTriggerRequestObject) (DeleteTriggerResponseObject, error)
DeleteTrigger removes a trigger
func (*OpenAPIHandlers) DeleteWorkflow ¶
func (h *OpenAPIHandlers) DeleteWorkflow(ctx context.Context, request DeleteWorkflowRequestObject) (DeleteWorkflowResponseObject, error)
DeleteWorkflow removes a workflow
func (*OpenAPIHandlers) DeleteWorkflowEdge ¶
func (h *OpenAPIHandlers) DeleteWorkflowEdge(ctx context.Context, request DeleteWorkflowEdgeRequestObject) (DeleteWorkflowEdgeResponseObject, error)
DeleteWorkflowEdge deletes a workflow edge
func (*OpenAPIHandlers) DeleteWorkflowNode ¶
func (h *OpenAPIHandlers) DeleteWorkflowNode(ctx context.Context, request DeleteWorkflowNodeRequestObject) (DeleteWorkflowNodeResponseObject, error)
DeleteWorkflowNode deletes a workflow node
func (*OpenAPIHandlers) DeployWorkflowVersion ¶
func (h *OpenAPIHandlers) DeployWorkflowVersion(ctx context.Context, request DeployWorkflowVersionRequestObject) (DeployWorkflowVersionResponseObject, error)
DeployWorkflowVersion deploys a specific version of a workflow (makes it current)
func (*OpenAPIHandlers) ExecuteWorkflow ¶
func (h *OpenAPIHandlers) ExecuteWorkflow(ctx context.Context, request ExecuteWorkflowRequestObject) (ExecuteWorkflowResponseObject, error)
ExecuteWorkflow executes a workflow
func (*OpenAPIHandlers) GetConnection ¶
func (h *OpenAPIHandlers) GetConnection(ctx context.Context, request GetConnectionRequestObject) (GetConnectionResponseObject, error)
GetConnection retrieves a single connection by ID
func (*OpenAPIHandlers) GetCredentialTypeSchema ¶
func (h *OpenAPIHandlers) GetCredentialTypeSchema(ctx context.Context, request GetCredentialTypeSchemaRequestObject) (GetCredentialTypeSchemaResponseObject, error)
GetCredentialTypeSchema gets JSON schema for credential type
func (*OpenAPIHandlers) GetHealth ¶
func (h *OpenAPIHandlers) GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
GetHealth implements the health check endpoint
func (*OpenAPIHandlers) GetLatestWorkflowVersion ¶
func (h *OpenAPIHandlers) GetLatestWorkflowVersion(ctx context.Context, request GetLatestWorkflowVersionRequestObject) (GetLatestWorkflowVersionResponseObject, error)
GetLatestWorkflowVersion gets the latest version of a workflow
func (*OpenAPIHandlers) GetNodeParameterOptions ¶
func (h *OpenAPIHandlers) GetNodeParameterOptions(ctx context.Context, request GetNodeParameterOptionsRequestObject) (GetNodeParameterOptionsResponseObject, error)
GetNodeParameterOptions gets dynamic options for node parameters
func (*OpenAPIHandlers) GetTrigger ¶
func (h *OpenAPIHandlers) GetTrigger(ctx context.Context, request GetTriggerRequestObject) (GetTriggerResponseObject, error)
GetTrigger retrieves a single trigger by ID
func (*OpenAPIHandlers) GetWorkflow ¶
func (h *OpenAPIHandlers) GetWorkflow(ctx context.Context, request GetWorkflowRequestObject) (GetWorkflowResponseObject, error)
GetWorkflow retrieves a single workflow by ID
func (*OpenAPIHandlers) GetWorkflowDraft ¶
func (h *OpenAPIHandlers) GetWorkflowDraft(ctx context.Context, request GetWorkflowDraftRequestObject) (GetWorkflowDraftResponseObject, error)
GetWorkflowDraft gets the current draft of a workflow
func (*OpenAPIHandlers) GetWorkflowNode ¶
func (h *OpenAPIHandlers) GetWorkflowNode(ctx context.Context, request GetWorkflowNodeRequestObject) (GetWorkflowNodeResponseObject, error)
GetWorkflowNode retrieves a specific workflow node
func (*OpenAPIHandlers) GetWorkflowRun ¶
func (h *OpenAPIHandlers) GetWorkflowRun(ctx context.Context, request GetWorkflowRunRequestObject) (GetWorkflowRunResponseObject, error)
GetWorkflowRun retrieves a single workflow run by ID
func (*OpenAPIHandlers) GetWorkflowRunSteps ¶
func (h *OpenAPIHandlers) GetWorkflowRunSteps(ctx context.Context, request GetWorkflowRunStepsRequestObject) (GetWorkflowRunStepsResponseObject, error)
GetWorkflowRunSteps retrieves steps for a workflow run
func (*OpenAPIHandlers) HandleWebhook ¶
func (h *OpenAPIHandlers) HandleWebhook(ctx context.Context, request HandleWebhookRequestObject) (HandleWebhookResponseObject, error)
HandleWebhook processes incoming webhook requests
func (*OpenAPIHandlers) ListConnections ¶
func (h *OpenAPIHandlers) ListConnections(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)
ListConnections retrieves all connections
func (*OpenAPIHandlers) ListCredentialTypes ¶
func (h *OpenAPIHandlers) ListCredentialTypes(ctx context.Context, request ListCredentialTypesRequestObject) (ListCredentialTypesResponseObject, error)
ListCredentialTypes lists credential type definitions
func (*OpenAPIHandlers) ListCredentials ¶
func (h *OpenAPIHandlers) ListCredentials(ctx context.Context, request ListCredentialsRequestObject) (ListCredentialsResponseObject, error)
ListCredentials lists credentials for selection in nodes
func (*OpenAPIHandlers) ListExtensions ¶
func (h *OpenAPIHandlers) ListExtensions(ctx context.Context, request ListExtensionsRequestObject) (ListExtensionsResponseObject, error)
ListExtensions implements the listExtensions operation.
func (*OpenAPIHandlers) ListIntegrations ¶
func (h *OpenAPIHandlers) ListIntegrations(ctx context.Context, request ListIntegrationsRequestObject) (ListIntegrationsResponseObject, error)
ListIntegrations lists available integrations
func (*OpenAPIHandlers) ListNodeTypes ¶
func (h *OpenAPIHandlers) ListNodeTypes(ctx context.Context, request ListNodeTypesRequestObject) (ListNodeTypesResponseObject, error)
ListNodeTypes returns all registered node type metadata
func (*OpenAPIHandlers) ListTriggers ¶
func (h *OpenAPIHandlers) ListTriggers(ctx context.Context, request ListTriggersRequestObject) (ListTriggersResponseObject, error)
ListTriggers retrieves all triggers
func (*OpenAPIHandlers) ListWorkers ¶
func (h *OpenAPIHandlers) ListWorkers(ctx context.Context, request ListWorkersRequestObject) (ListWorkersResponseObject, error)
ListWorkers retrieves all workers
func (*OpenAPIHandlers) ListWorkflowEdges ¶
func (h *OpenAPIHandlers) ListWorkflowEdges(ctx context.Context, request ListWorkflowEdgesRequestObject) (ListWorkflowEdgesResponseObject, error)
ListWorkflowEdges lists all edges in a workflow
func (*OpenAPIHandlers) ListWorkflowNodes ¶
func (h *OpenAPIHandlers) ListWorkflowNodes(ctx context.Context, request ListWorkflowNodesRequestObject) (ListWorkflowNodesResponseObject, error)
ListWorkflowNodes lists all nodes in a workflow
func (*OpenAPIHandlers) ListWorkflowRuns ¶
func (h *OpenAPIHandlers) ListWorkflowRuns(ctx context.Context, request ListWorkflowRunsRequestObject) (ListWorkflowRunsResponseObject, error)
ListWorkflowRuns retrieves workflow runs with optional filtering
func (*OpenAPIHandlers) ListWorkflowVersions ¶
func (h *OpenAPIHandlers) ListWorkflowVersions(ctx context.Context, request ListWorkflowVersionsRequestObject) (ListWorkflowVersionsResponseObject, error)
ListWorkflowVersions lists all versions of a workflow
func (*OpenAPIHandlers) ListWorkflows ¶
func (h *OpenAPIHandlers) ListWorkflows(ctx context.Context, request ListWorkflowsRequestObject) (ListWorkflowsResponseObject, error)
ListWorkflows retrieves all workflows with pagination
func (*OpenAPIHandlers) RegisterWorker ¶
func (h *OpenAPIHandlers) RegisterWorker(ctx context.Context, request RegisterWorkerRequestObject) (RegisterWorkerResponseObject, error)
RegisterWorker registers a new worker
func (*OpenAPIHandlers) TestCredentials ¶
func (h *OpenAPIHandlers) TestCredentials(ctx context.Context, request TestCredentialsRequestObject) (TestCredentialsResponseObject, error)
TestCredentials tests credentials for a specific type
func (*OpenAPIHandlers) TestWorkflowDraftNode ¶
func (h *OpenAPIHandlers) TestWorkflowDraftNode(ctx context.Context, request TestWorkflowDraftNodeRequestObject) (TestWorkflowDraftNodeResponseObject, error)
TestWorkflowDraftNode tests a single node in the workflow draft
func (*OpenAPIHandlers) UnregisterWorker ¶
func (h *OpenAPIHandlers) UnregisterWorker(ctx context.Context, request UnregisterWorkerRequestObject) (UnregisterWorkerResponseObject, error)
UnregisterWorker removes a worker
func (*OpenAPIHandlers) UpdateConnection ¶
func (h *OpenAPIHandlers) UpdateConnection(ctx context.Context, request UpdateConnectionRequestObject) (UpdateConnectionResponseObject, error)
UpdateConnection updates an existing connection
func (*OpenAPIHandlers) UpdateTrigger ¶
func (h *OpenAPIHandlers) UpdateTrigger(ctx context.Context, request UpdateTriggerRequestObject) (UpdateTriggerResponseObject, error)
UpdateTrigger updates an existing trigger
func (*OpenAPIHandlers) UpdateWorkerHeartbeat ¶
func (h *OpenAPIHandlers) UpdateWorkerHeartbeat(ctx context.Context, request UpdateWorkerHeartbeatRequestObject) (UpdateWorkerHeartbeatResponseObject, error)
UpdateWorkerHeartbeat updates a worker's heartbeat
func (*OpenAPIHandlers) UpdateWorkflow ¶
func (h *OpenAPIHandlers) UpdateWorkflow(ctx context.Context, request UpdateWorkflowRequestObject) (UpdateWorkflowResponseObject, error)
UpdateWorkflow updates an existing workflow
func (*OpenAPIHandlers) UpdateWorkflowDraft ¶
func (h *OpenAPIHandlers) UpdateWorkflowDraft(ctx context.Context, request UpdateWorkflowDraftRequestObject) (UpdateWorkflowDraftResponseObject, error)
UpdateWorkflowDraft updates the draft of a workflow
func (*OpenAPIHandlers) UpdateWorkflowNode ¶
func (h *OpenAPIHandlers) UpdateWorkflowNode(ctx context.Context, request UpdateWorkflowNodeRequestObject) (UpdateWorkflowNodeResponseObject, error)
UpdateWorkflowNode updates a workflow node
type PaginatedResponse ¶
type PaginatedResponse struct {
Data any `json:"data"`
Pagination PaginationInfo `json:"pagination"`
}
type PaginationInfo ¶
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 ¶
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.
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 StrictHandlerFunc ¶
type StrictHandlerFunc = strictnethttp.StrictHTTPHandlerFunc
type StrictMiddlewareFunc ¶
type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc
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.
type TooManyValuesForParamError ¶
func (*TooManyValuesForParamError) Error ¶
func (e *TooManyValuesForParamError) Error() string
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 ¶
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 ¶
func (_ Unimplemented) GetTrigger(w http.ResponseWriter, r *http.Request, id openapi_types.UUID)
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 ¶
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 WebhookPayload3 ¶
type WebhookPayload3 = float32
WebhookPayload3 JSON number (including decimals)
type WebhookPayload10 ¶
type WebhookPayload10 map[string]interface{}
WebhookPayload10 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 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.
Source Files
¶
- assistant.go
- essential_handlers.go
- executors.go
- generate.go
- handlers_assistant.go
- handlers_connections.go
- handlers_credential_types.go
- handlers_credentials.go
- handlers_extensions.go
- handlers_integrations.go
- handlers_system.go
- handlers_triggers.go
- handlers_webhooks.go
- handlers_workers.go
- handlers_workflow_runs.go
- handlers_workflows.go
- openapi_router.go
- openapi_server.go
- server.gen.go
- workflow_runs.go
- ws.go