fix remote API for multiple pod replicas

Signed-off-by: Oleksandr Krutko <alexander.krutko@gmail.com>

Author: arsenalzp

cmd/podman/kube/play.go

@@ -181,6 +181,9 @@ func playFlags(cmd *cobra.Command) {
 	noPodPrefix := "no-pod-prefix"
 	flags.BoolVar(&playOptions.NoPodPrefix, noPodPrefix, false, "Do not prefix container name with pod name")
 
+	replicas := "replicas"
+	flags.BoolVar(&playOptions.Replicas, replicas, false, "Replicas allows multiple Pods creation")
+
 	if !registry.IsRemote() {
 		certDirFlagName := "cert-dir"
 		flags.StringVar(&playOptions.CertDir, certDirFlagName, "", "`Pathname` of a directory containing TLS certificates and keys")
@@ -210,9 +213,6 @@ func playFlags(cmd *cobra.Command) {
 		exitFlagName := "service-exit-code-propagation"
 		flags.StringVar(&playOptions.ExitCodePropagation, exitFlagName, "", "Exit-code propagation of the service container")
 		_ = flags.MarkHidden(exitFlagName)
-
-		replicas := "replicas"
-		flags.BoolVar(&playOptions.Replicas, replicas, false, "Replicas allows multiple Pods creation")
 	}
 }
 

pkg/api/handlers/libpod/kube.go

@@ -124,6 +124,7 @@ func KubePlay(w http.ResponseWriter, r *http.Request) {
 		Wait             bool              `schema:"wait"`
 		Build            bool              `schema:"build"`
 		NoPodPrefix      bool              `schema:"noPodPrefix"`
+		Replicas         bool              `schema:"replicas"`
 	}{
 		TLSVerify: true,
 		Start:     true,
@@ -200,6 +201,7 @@ func KubePlay(w http.ResponseWriter, r *http.Request) {
 		Wait:               query.Wait,
 		ContextDir:         contextDirectory,
 		NoPodPrefix:        query.NoPodPrefix,
+		Replicas:           query.Replicas,
 	}
 	if _, found := r.URL.Query()["build"]; found {
 		options.Build = types.NewOptionalBool(query.Build)

pkg/bindings/kube/types.go

@@ -64,6 +64,8 @@ type PlayOptions struct {
 	Wait             *bool
 	ServiceContainer *bool
 	NoPodPrefix      *bool
+	// Replicas allows multiple Pods creation
+	Replicas *bool
 }
 
 // ApplyOptions are optional options for applying kube YAML files to a k8s cluster

pkg/bindings/kube/types_play_options.go

@@ -76,6 +76,7 @@ func (ic *ContainerEngine) PlayKube(_ context.Context, body io.Reader, opts enti
 	options.WithPublishAllPorts(opts.PublishAllPorts)
 	options.WithNoTrunc(opts.UseLongAnnotations)
 	options.WithNoPodPrefix(opts.NoPodPrefix)
+	options.WithReplicas(opts.Replicas)
 	return play.KubeWithBody(ic.ClientCtx, body, options)
 }