Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| baf36dbaf8 | |||
| 64190a500d |
3
main.go
3
main.go
@@ -121,6 +121,8 @@ func main() {
|
||||
die.If(err)
|
||||
}
|
||||
|
||||
log.Infoln("nlink is starting")
|
||||
|
||||
log.Debugf("loading config file %s\n", configFile)
|
||||
if err := config.LoadFile(configFile); err != nil {
|
||||
log.Fatal(err)
|
||||
@@ -153,6 +155,7 @@ func main() {
|
||||
defer db.Close()
|
||||
|
||||
feeds := splitFeeds()
|
||||
|
||||
if markOnly {
|
||||
log.Info("marking database")
|
||||
for _, feed := range feeds {
|
||||
|
||||
10
storage.go
10
storage.go
@@ -30,6 +30,7 @@ func connectMinio() (err error) {
|
||||
}
|
||||
|
||||
func restoreDatabase(path string) error {
|
||||
log.Debugln("restoring database from minio")
|
||||
if minioClient == nil {
|
||||
if err := connectMinio(); err != nil {
|
||||
return err
|
||||
@@ -58,7 +59,12 @@ func restoreDatabase(path string) error {
|
||||
defer dbFile.Close()
|
||||
|
||||
_, err = io.Copy(dbFile, obj)
|
||||
return err
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
log.Debugln("database restored from minio")
|
||||
return nil
|
||||
}
|
||||
|
||||
func saveDatabase(path string) error {
|
||||
@@ -91,5 +97,7 @@ func saveDatabase(path string) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
log.Debugln("database saved to minio")
|
||||
return nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user