update node name in s3 files

Signed-off-by: Brian Downs <brian.downs@gmail.com>

update node name in s3 files
a6f64cc7 · Brian Downs · 10f0a790 · a6f64cc7
Commit a6f64cc7 authored Apr 27, 2021 by Brian Downs
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

etcd.go pkg/etcd/etcd.go +3 -1

No files found.
--- a/pkg/etcd/etcd.go
+++ b/pkg/etcd/etcd.go
@@ -938,10 +938,12 @@ func (e *ETCD) listSnapshots(ctx context.Context, snapshotDir string) ([]snapsho
 		return nil, err
 	}

+	nodeName := os.Getenv("NODE_NAME")
+
 	for _, f := range files {
 		snapshots = append(snapshots, snapshotFile{
 			Name:      filepath.Join(snapshotDir, f.Name()),
-			NodeName:  "",
+			NodeName:  nodeName,
 			CreatedAt: f.ModTime().String(),
 			Size:      f.Size(),
 		})