Use port from AppBinding (#120) (#125)

/cherry-pick Signed-off-by: Emruz Hossain <[email protected]> Ref: stashed/stash#1272
stashed · Dec 17, 2020 · 42458b3 · 42458b3
1 parent 70d872d
commit 42458b3
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/pkg/backup.go b/pkg/backup.go
@@ -222,6 +222,10 @@ func (opt *perconaOptions) backupPerconaXtraDB(targetRef api_v1beta1.TargetRef)
 				"-h", appBinding.Spec.ClientConfig.Service.Name,
 			},
 		}
+		// if port is specified, append port in the arguments
+		if appBinding.Spec.ClientConfig.Service.Port != 0 {
+			opt.backupOptions.StdinPipeCommand.Args = append(opt.backupOptions.StdinPipeCommand.Args, fmt.Sprintf("--port=%d", appBinding.Spec.ClientConfig.Service.Port))
+		}
 		for _, arg := range strings.Fields(opt.xtradbArgs) {
 			opt.backupOptions.StdinPipeCommand.Args = append(opt.backupOptions.StdinPipeCommand.Args, arg)
 		}

diff --git a/pkg/restore.go b/pkg/restore.go
@@ -18,6 +18,7 @@ package pkg
 
 import (
 	"context"
+	"fmt"
 	"path/filepath"
 	"strings"
 
@@ -185,6 +186,10 @@ func (opt *perconaOptions) restorePerconaXtraDB(targetRef api_v1beta1.TargetRef)
 				"-h", appBinding.Spec.ClientConfig.Service.Name,
 			},
 		}
+		// if port is specified, append port in the arguments
+		if appBinding.Spec.ClientConfig.Service.Port != 0 {
+			opt.dumpOptions.StdoutPipeCommand.Args = append(opt.dumpOptions.StdoutPipeCommand.Args, fmt.Sprintf("--port=%d", appBinding.Spec.ClientConfig.Service.Port))
+		}
 		for _, arg := range strings.Fields(opt.xtradbArgs) {
 			opt.dumpOptions.StdoutPipeCommand.Args = append(opt.dumpOptions.StdoutPipeCommand.Args, arg)
 		}