IL: lc supports to recover job when restart

Signed-off-by: JimmyYang20 <[email protected]>
kubeedge · Aug 9, 2021 · 2cfe1b9 · 2cfe1b9
1 parent 44609f0
commit 2cfe1b9
Show file tree

Hide file tree

Showing 2 changed files with 333 additions and 207 deletions.
diff --git a/pkg/localcontroller/db/db.go b/pkg/localcontroller/db/db.go
@@ -77,6 +77,19 @@ func SaveResource(name string, typeMeta, objectMeta, spec interface{}) error {
 	return nil
 }
 
+// GetResource gets resource info in db
+func GetResource(name string) *Resource {
+	r := Resource{}
+
+	queryResult := dbClient.Where("name = ?", name).First(&r)
+	if queryResult.RowsAffected == 0 {
+		klog.Warningf("resource(name=%s) not in db", name)
+		return nil
+	}
+
+	return &r
+}
+
 // DeleteResource deletes resource info in db
 func DeleteResource(name string) error {
 	var err error