Documentation
¶
Index ¶
- type API
- func (api *API) CompleteWorkflowRun(id string, success bool) error
- func (api *API) GetWorkflow(id string) (*config.Workflow, error)
- func (api *API) GetWorkflowFromWorkflowRunID(workflowRunID string) (*config.Workflow, error)
- func (api *API) GetWorkflows() (map[string]config.Workflow, error)
- func (api *API) Handler() http.Handler
- func (api *API) PreviewDataset(id string) ([]interface{}, error)
- func (api *API) ReadDataConnection(id string) (*config.DataConnection, error)
- func (api *API) ScheduleTask(workflowRunID string, workflowTaskID string, input map[string]interface{}) error
- func (api *API) StartWorkflow(id string, workflowInput map[string]interface{}) error
- func (api *API) StoreDataConnection(connection config.DataConnection) error
- func (api *API) StoreDataset(dataset config.Dataset) error
- func (api *API) StoreWorkflow(workflow config.Workflow) error
- type DataConnection
- type Response
- type Task
- type TaskResult
- type TaskRun
- type WorkflowRun
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type API ¶
type API struct {
// contains filtered or unexported fields
}
func (*API) CompleteWorkflowRun ¶
func (*API) GetWorkflowFromWorkflowRunID ¶
func (*API) PreviewDataset ¶
func (*API) ReadDataConnection ¶
func (api *API) ReadDataConnection(id string) (*config.DataConnection, error)
func (*API) ScheduleTask ¶
func (*API) StartWorkflow ¶
func (*API) StoreDataConnection ¶
func (api *API) StoreDataConnection(connection config.DataConnection) error
type DataConnection ¶
type Response ¶
type Response struct {
OK bool `json:"ok"`
Status int `json:"-"`
Error string `json:"error,omitempty"`
Response interface{} `json:"response,omitempty"`
// contains filtered or unexported fields
}
func CustomResponse ¶
func CustomResponse() Response
type TaskResult ¶
type TaskRun ¶
type TaskRun struct {
ID string `json:"id"`
WorkflowRunID string `json:"workflow_run_id"`
WorkflowTaskID string `json:"workflow_task_id"`
Input json.RawMessage `json:"input"`
Output json.RawMessage `json:"output"`
CreatedAt time.Time `json:"created_at"`
StartedAt *time.Time `json:"started_at"`
TimeoutAt *time.Time `json:"timeout_at"`
CompletedAt *time.Time `json:"completed_at"`
AttemptsLeft int `json:"attempts_left"`
Stdout *string `json:"stdout"`
Stderr *string `json:"stderr"`
Success *bool `json:"success"`
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.