Skip to content

Commit 8485c90

Browse files
authored
Merge pull request #152 from JimmyYang20/fixbug
IL: LC supports to recover job when restart
2 parents ce08694 + bf39a7c commit 8485c90

File tree

2 files changed

+332
-209
lines changed

2 files changed

+332
-209
lines changed

pkg/localcontroller/db/db.go

+13
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ package db
1818

1919
import (
2020
"encoding/json"
21+
"fmt"
2122
"os"
2223
"path/filepath"
2324

@@ -77,6 +78,18 @@ func SaveResource(name string, typeMeta, objectMeta, spec interface{}) error {
7778
return nil
7879
}
7980

81+
// GetResource gets resource info in db
82+
func GetResource(name string) (*Resource, error) {
83+
r := Resource{}
84+
85+
queryResult := dbClient.Where("name = ?", name).First(&r)
86+
if queryResult.RowsAffected == 0 {
87+
return nil, fmt.Errorf("resource(name=%s) not in db", name)
88+
}
89+
90+
return &r, nil
91+
}
92+
8093
// DeleteResource deletes resource info in db
8194
func DeleteResource(name string) error {
8295
var err error

0 commit comments

Comments
 (0)