Versions in this module Expand all Collapse all v0 v0.2.3 Feb 8, 2022 v0.2.2 Feb 8, 2022 Changes in this version type API + func (api *API) LatestConfigHash() (string, error) + func (api *API) LoadConfig() error + func (api *API) ReadDatasets() ([]config.Dataset, error) + func (api *API) Tick(now time.Time) error + type GitHubContentResponse struct + Content string + Encoding string + Name string + Path string type WorkflowRun + ConfigHash string v0.2.1 Jan 26, 2022 Changes in this version + type StatusSummary struct + RecentTaskFailures []SummaryTaskRun + RecentTaskRuns []SummaryTaskRun + TotalConnections int + TotalDatasets int + TotalTasksCompleted int + TotalWorkflows int + type SummaryTaskRun struct + CompletedAt *time.Time + CreatedAt time.Time + ID string + StartedAt *time.Time + Success *bool + WorkflowID string + WorkflowRunID string + WorkflowTaskID string v0.2.0 Jan 18, 2022 Changes in this version + type API struct + func NewAPI(db *sql.DB, conf *config.Config, dataDir string) (*API, error) + 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 struct + ConnectionString string + ID string + Path string + Type string + type Response struct + Error string + OK bool + Response interface{} + Status int + func CustomResponse() Response + type Task struct + Datasets []string + Env map[string]string + ID string + Image string + Input map[string]interface{} + Script string + type TaskResult struct + ID string + OK bool + Output map[string]interface{} + Stderr string + Stdout string + type TaskRun struct + AttemptsLeft int + CompletedAt *time.Time + CreatedAt time.Time + ID string + Input json.RawMessage + Output json.RawMessage + StartedAt *time.Time + Stderr *string + Stdout *string + Success *bool + TimeoutAt *time.Time + WorkflowRunID string + WorkflowTaskID string + type WorkflowRun struct + CompletedAt *time.Time + ID string + StartedAt *time.Time + Success *bool + WorkflowID string