Commit 77caab3c authored by Brian Downs's avatar Brian Downs

update retention

parent b3e84c88
...@@ -144,11 +144,13 @@ func (s *s3) download(ctx context.Context) error { ...@@ -144,11 +144,13 @@ func (s *s3) download(ctx context.Context) error {
// snapshotPrefix returns the prefix used in the // snapshotPrefix returns the prefix used in the
// naming of the snapshots. // naming of the snapshots.
func (s *s3) snapshotPrefix() string { func (s *s3) snapshotPrefix() string {
nodeName := os.Getenv("NODE_NAME")
fullSnapshotPrefix := snapshotPrefix + nodeName
var prefix string var prefix string
if s.config.EtcdS3Folder != "" { if s.config.EtcdS3Folder != "" {
prefix = filepath.Join(s.config.EtcdS3Folder, snapshotPrefix) prefix = filepath.Join(s.config.EtcdS3Folder, fullSnapshotPrefix)
} else { } else {
prefix = snapshotPrefix prefix = fullSnapshotPrefix
} }
return prefix return prefix
} }
......
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