-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
pb-4872: Added change to support ignore file option for kdmp snapshot.
- Added KDMP_EXCLUDE_FILE_LIST configmap parameter to kdmp-config configmap for used to specify the ignore file list for kdmp snapshot. - Added set policy command execution in kopiabackup executor for setting ignore file list to kopia.
- Loading branch information
sivakumar subraani
committed
Nov 20, 2023
1 parent
fdf611b
commit 705ac31
Showing
7 changed files
with
247 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,88 @@ | ||
| package kopia | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "fmt" | ||
| "os" | ||
| "os/exec" | ||
|
|
||
| cmdexec "github.com/portworx/kdmp/pkg/executor" | ||
| "github.com/sirupsen/logrus" | ||
| ) | ||
|
|
||
| type excludeFileListExecutor struct { | ||
| cmd *Command | ||
| execCmd *exec.Cmd | ||
| outBuf *bytes.Buffer | ||
| errBuf *bytes.Buffer | ||
| lastError error | ||
| isRunning bool | ||
| } | ||
|
|
||
| // GetExcludeFileListCommand returns a wrapper over the kopia policy set | ||
| func GetExcludeFileListCommand(path, excludeFileList string) (*Command, error) { | ||
| if path == "" { | ||
| return nil, fmt.Errorf("path name cannot be empty") | ||
| } | ||
| return &Command{ | ||
| Name: "policy", | ||
| Path: path, | ||
| ExcludeFileList: excludeFileList, | ||
| }, nil | ||
| } | ||
|
|
||
| // NewExcludeFileListExecutor returns an instance of Executor that can be used for | ||
| // running a kopia policy set command for setting exclude dir list | ||
| func NewExcludeFileListExecutor(cmd *Command) Executor { | ||
| return &excludeFileListExecutor{ | ||
| cmd: cmd, | ||
| outBuf: new(bytes.Buffer), | ||
| errBuf: new(bytes.Buffer), | ||
| } | ||
| } | ||
|
|
||
| func (c *excludeFileListExecutor) Run() error { | ||
| c.execCmd = c.cmd.ExcludeFileListCmd() | ||
| c.execCmd.Stdout = c.outBuf | ||
| c.execCmd.Stderr = c.errBuf | ||
|
|
||
| if err := c.execCmd.Start(); err != nil { | ||
| c.lastError = err | ||
| return err | ||
| } | ||
| c.isRunning = true | ||
| go func() { | ||
| err := c.execCmd.Wait() | ||
| if err != nil { | ||
| c.lastError = fmt.Errorf("failed to run the kopia exclude file list setting command: %v"+ | ||
| " stdout: %v stderr: %v", err, c.outBuf.String(), c.errBuf.String()) | ||
| logrus.Errorf("%v", c.lastError) | ||
| return | ||
| } | ||
| c.isRunning = false | ||
| }() | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (c *excludeFileListExecutor) Status() (*cmdexec.Status, error) { | ||
| if c.lastError != nil { | ||
| fmt.Fprintln(os.Stderr, c.errBuf.String()) | ||
| return &cmdexec.Status{ | ||
| LastKnownError: c.lastError, | ||
| Done: true, | ||
| }, nil | ||
| } | ||
|
|
||
| if c.isRunning { | ||
| return &cmdexec.Status{ | ||
| Done: false, | ||
| LastKnownError: nil, | ||
| }, nil | ||
| } | ||
|
|
||
| return &cmdexec.Status{ | ||
| Done: true, | ||
| }, nil | ||
|
|
||
| } |