sqlstore

type NodeSqlStore interface {
	GetNodeById(id string) (*models.Node, error)
	GetNodes(query *models.NodeQueryCmd) error
	ExistNode(name string) (bool, error)
	CreateNode(cmd *models.CreateNewNodeCmd) error
	UpdateNode(cmd *models.UpdateNodeCmd) error
	DeleteNode(id string) error
}

type SqlStore struct {
	// contains filtered or unexported fields
}

type SqlStoreInterface interface {
	NodeSqlStore
	TaskSqlStore
	GetDB() *gorm.DB
}

type TaskSqlStore interface {
	GetTaskById(id string) (*models.TaskDto, error)
	GetTasks(query *models.TaskQueryCmd) error
	ExistTask(name string) (bool, error)
	CreateTask(taskCreate *models.TaskCreateCommand) error
	UpdateTask(taskUpdate *models.TaskUpdateCommand) error
	UpdateTaskStatus(id, status, result, errMsg string, retriedTimes int) error
	DeleteTask(id string) error
}