database

Documentation

Index

• type DBService
  • func NewDBService(uri string) (DBService, error)
• type DatasetService
• type DesignService
• type JobService
• type TaskService

Types

type DBService

type DBService interface {
	DatasetService
	DesignService
	JobService
	TaskService
}

DBService defines a total set of collections for the application

func NewDBService

func NewDBService(uri string) (DBService, error)

type DatasetService

type DatasetService interface {
	CreateDataset(string, openapi.DatasetInfo) (string, error)
	GetDatasets(string, int32) ([]openapi.DatasetInfo, error)
	GetDatasetById(string) (openapi.DatasetInfo, error)
}

DatasetService is an interface that defines a collection of APIs related to dataset

type DesignService

type DesignService interface {
	CreateDesign(userId string, info openapi.Design) error
	GetDesign(userId string, designId string) (openapi.Design, error)
	GetDesigns(userId string, limit int32) ([]openapi.DesignInfo, error)

	CreateDesignSchema(userId string, designId string, info openapi.DesignSchema) error
	GetDesignSchema(userId string, designId string, version string) (openapi.DesignSchema, error)
	GetDesignSchemas(userId string, designId string) ([]openapi.DesignSchema, error)
	UpdateDesignSchema(userId string, designId string, version string, info openapi.DesignSchema) error

	CreateDesignCode(userId string, designId string, fileName string, fileVer string, fileData *os.File) error
	GetDesignCode(userId string, designId string, version string) ([]byte, error)
}

DesignService is an interface that defines a collection of APIs related to design

type JobService

type JobService interface {
	CreateJob(string, openapi.JobSpec) (openapi.JobStatus, error)
	DeleteJob(string, string) error
	GetJob(string, string) (openapi.JobSpec, error)
	GetJobById(string) (openapi.JobSpec, error)
	GetJobStatus(string, string) (openapi.JobStatus, error)
	GetJobs(string, int32) ([]openapi.JobStatus, error)
	UpdateJob(string, string, openapi.JobSpec) error
	UpdateJobStatus(string, string, openapi.JobStatus) error
	GetTasksInfo(string, string, int32, bool) ([]openapi.TaskInfo, error)
}

JobService is an interface that defines a collection of APIs related to job

type TaskService

type TaskService interface {
	CreateTasks([]objects.Task, bool) error
	DeleteTasks(string, bool) error
	GetTask(string, string, string) (map[string][]byte, error)
	IsOneTaskInState(string, openapi.JobState) bool
	IsOneTaskInStateWithRole(string, openapi.JobState, string) bool
	MonitorTasks(string) (chan openapi.TaskInfo, chan error, context.CancelFunc, error)
	SetTaskDirtyFlag(string, bool) error
	UpdateTaskStateByFilter(string, openapi.JobState, map[string]interface{}) error
	UpdateTaskStatus(string, string, openapi.TaskStatus) error
}

TaskService is an interface that defines a collection of APIs related to task