database

Sep 20, 2023

Changes in this version

type DesignService

+ GetDesignCodeRevision func(userId string, designId string) (openapi.CodeApiResponse, error)

Jun 5, 2023

Changes in this version

type JobService

+ GetJobsByCompute func(computeId string) ([]openapi.JobStatus, error)

Nov 16, 2022

Changes in this version

type ComputeService

+ UpdateDeploymentStatus func(computeId string, jobId string, agentStatuses map[string]openapi.AgentState) error

type DesignService

+ DeleteDesign func(userId string, designId string) error

+ DeleteDesignCode func(userId string, designId string, version string) error

+ DeleteDesignSchema func(userId string, designId string, version string) error

Sep 1, 2022

Changes in this version

+ type ComputeService interface

+ GetComputeById func(string) (openapi.ComputeSpec, error)

+ GetComputeIdsByRegion func(string) ([]string, error)

+ RegisterCompute func(openapi.ComputeSpec) (openapi.ComputeStatus, error)

type JobService

+ GetTasksInfoGeneric func(string, string, int32, bool, bool) ([]openapi.TaskInfo, error)

Apr 26, 2022

Changes in this version

type JobService

+ GetTaskInfo func(string, string, string) (openapi.TaskInfo, error)

Apr 5, 2022

Changes in this version

+ type DBService interface

+ func NewDBService(uri string) (DBService, error)

+ type DatasetService interface

+ CreateDataset func(string, openapi.DatasetInfo) (string, error)

+ GetDatasetById func(string) (openapi.DatasetInfo, error)

+ GetDatasets func(string, int32) ([]openapi.DatasetInfo, error)

+ type DesignService interface

+ CreateDesign func(userId string, info openapi.Design) error

+ CreateDesignCode func(userId string, designId string, fileName string, fileVer string, ...) error

+ CreateDesignSchema func(userId string, designId string, info openapi.DesignSchema) error

+ GetDesign func(userId string, designId string) (openapi.Design, error)

+ GetDesignCode func(userId string, designId string, version string) ([]byte, error)

+ GetDesignSchema func(userId string, designId string, version string) (openapi.DesignSchema, error)

+ GetDesignSchemas func(userId string, designId string) ([]openapi.DesignSchema, error)

+ GetDesigns func(userId string, limit int32) ([]openapi.DesignInfo, error)

+ UpdateDesignSchema func(userId string, designId string, version string, info openapi.DesignSchema) error

+ type JobService interface

+ CreateJob func(string, openapi.JobSpec) (openapi.JobStatus, error)

+ DeleteJob func(string, string) error

+ GetJob func(string, string) (openapi.JobSpec, error)

+ GetJobById func(string) (openapi.JobSpec, error)

+ GetJobStatus func(string, string) (openapi.JobStatus, error)

+ GetJobs func(string, int32) ([]openapi.JobStatus, error)

+ GetTasksInfo func(string, string, int32, bool) ([]openapi.TaskInfo, error)

+ UpdateJob func(string, string, openapi.JobSpec) error

+ UpdateJobStatus func(string, string, openapi.JobStatus) error

+ type TaskService interface

+ CreateTasks func([]objects.Task, bool) error

+ DeleteTasks func(string, bool) error

+ GetTask func(string, string, string) (map[string][]byte, error)

+ IsOneTaskInState func(string, openapi.JobState) bool

+ IsOneTaskInStateWithRole func(string, openapi.JobState, string) bool

+ MonitorTasks func(string) (chan openapi.TaskInfo, chan error, context.CancelFunc, error)

+ SetTaskDirtyFlag func(string, bool) error

+ UpdateTaskStateByFilter func(string, openapi.JobState, map[string]interface{}) error

+ UpdateTaskStatus func(string, string, openapi.TaskStatus) error