-
Couldn't load subscription status.
- Fork 109
PBM-88 PBM-162 Added storage pkg #182
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Added a new storage pkg and tests to handle different kinds of storages in PBM
- Added storage pkg - Modified client to use the storage - Updated tests - Fixed error in backup writer (missing close pipe upon finishing) - New reader pkg - Minio support
| StorageName: bm.GetStorageName(), | ||
| } | ||
| source.Client.restoreBackup(msg) | ||
| source.Client.RestoreBackup(msg) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Error return value of source.Client.RestoreBackup is not checked (from errcheck)
| str := strings.Repeat("a", int(chunkSize)) | ||
| size := int64(0) | ||
| for { | ||
| bw.Write([]byte(str)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Error return value of bw.Write is not checked (from errcheck)
| return | ||
| } | ||
| buf := make([]byte, 16*1024*1024) | ||
| br.bytesRead, err = io.CopyBuffer(pw, result.Body, buf) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ineffectual assignment to err (from ineffassign)
|
|
||
| rs1OplogFilename := fmt.Sprintf("%s_rs1.oplog", backupNamePrefix) | ||
| rs1LocalFilename := path.Join(os.TempDir(), rs1OplogFilename) | ||
| rs1File, err := os.Create(rs1LocalFilename) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ineffectual assignment to err (from ineffassign)
|
|
||
| rs2OplogFilename := fmt.Sprintf("%s_rs2.oplog", backupNamePrefix) | ||
| rs2LocalFilename := path.Join(os.TempDir(), rs2OplogFilename) | ||
| rs2File, err := os.Create(rs2LocalFilename) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ineffectual assignment to err (from ineffassign)
Added a new storage pkg and tests to handle different kinds of storages
in PBM