Unverified Commit bd62da13 authored by Hussein Galal's avatar Hussein Galal Committed by GitHub

Fix cluster reset (#3650)

parent e45dea3b
...@@ -63,17 +63,18 @@ func (c *Cluster) start(ctx context.Context) error { ...@@ -63,17 +63,18 @@ func (c *Cluster) start(ctx context.Context) error {
rebootstrap := func() error { rebootstrap := func() error {
return c.storageBootstrap(ctx) return c.storageBootstrap(ctx)
} }
if err := c.managedDB.Reset(ctx, rebootstrap); err != nil { return c.managedDB.Reset(ctx, rebootstrap)
return err
}
case c.config.ClusterReset: case c.config.ClusterReset:
if _, err := os.Stat(resetFile); err != nil { if _, err := os.Stat(resetFile); err != nil {
if !os.IsNotExist(err) { if !os.IsNotExist(err) {
return err return err
} }
} else { rebootstrap := func() error {
return fmt.Errorf("cluster-reset was successfully performed, please remove the cluster-reset flag and start %s normally, if you need to perform another cluster reset, you must first manually delete the %s file", version.Program, resetFile) return c.storageBootstrap(ctx)
}
return c.managedDB.Reset(ctx, rebootstrap)
} }
return fmt.Errorf("cluster-reset was successfully performed, please remove the cluster-reset flag and start %s normally, if you need to perform another cluster reset, you must first manually delete the %s file", version.Program, resetFile)
} }
if _, err := os.Stat(resetFile); err == nil { if _, err := os.Stat(resetFile); err == nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment