add Get command to Kanx

pkg/kando/process_client.go

@@ -28,6 +28,7 @@ func newProcessClientCommand() *cobra.Command {
 		Short: "Send commands to the process server",
 	}
 	cmd.AddCommand(newProcessClientCreateCommand())
+	cmd.AddCommand(newProcessClientGetCommand())
 	cmd.AddCommand(newProcessClientListCommand())
 	cmd.AddCommand(newProcessClientOutputCommand())
 	cmd.PersistentFlags().BoolP(processAsJSONFlagName, "j", false, "Display output as json")

pkg/kando/process_client_get.go

@@ -0,0 +1,64 @@
+// Copyright 2020 The Kanister Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package kando
+
+import (
+	"os"
+
+	"context"
+	"fmt"
+	"github.com/kanisterio/kanister/pkg/kanx"
+	"github.com/spf13/cobra"
+	"google.golang.org/protobuf/encoding/protojson"
+	"strconv"
+)
+
+func newProcessClientGetCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "get",
+		Short: "get",
+		RunE:  runProcessClientGet,
+	}
+	return cmd
+}
+
+func runProcessClientGet(cmd *cobra.Command, args []string) error {
+	cmd.SetContext(context.Background())
+	pid, err := strconv.Atoi(args[0])
+	if err != nil {
+		return err
+	}
+	addr, err := processAddressFlagValue(cmd)
+	if err != nil {
+		return err
+	}
+	asJSON := processAsJSONFlagValue(cmd)
+	cmd.SilenceUsage = true
+	p, err := kanx.GetProcess(cmd.Context(), addr, int64(pid))
+	if err != nil {
+		return err
+	}
+	out := os.Stdout
+	if asJSON {
+		buf, err := protojson.Marshal(p)
+		if err != nil {
+			return err
+		}
+		fmt.Fprintln(out, string(buf))
+	} else {
+		fmt.Fprintln(out, "Process: ", p.String())
+	}
+	return nil
+}

pkg/kanx/client.go

@@ -37,7 +37,23 @@ func CreateProcess(ctx context.Context, addr string, name string, args []string)
 		Name: name,
 		Args: args,
 	}
-	return c.CreateProcesses(ctx, in)
+	return c.CreateProcess(ctx, in)
+}
+
+func GetProcess(ctx context.Context, addr string, pid int64) (*Process, error) {
+	conn, err := newGRPCConnection(addr)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close() //nolint:errcheck
+	c := NewProcessServiceClient(conn)
+	wpc, err := c.GetProcess(ctx, &ProcessPidRequest{
+		Pid: pid,
+	})
+	if err != nil {
+		return nil, err
+	}
+	return wpc, nil
 }
 
 func ListProcesses(ctx context.Context, addr string) ([]*Process, error) {
@@ -71,7 +87,7 @@ func Stdout(ctx context.Context, addr string, pid int64, out io.Writer) error {
 	}
 	defer conn.Close() //nolint:errcheck
 	c := NewProcessServiceClient(conn)
-	in := &ProcessOutputRequest{
+	in := &ProcessPidRequest{
 		Pid: pid,
 	}
 	sc, err := c.Stdout(ctx, in)
@@ -88,7 +104,7 @@ func Stderr(ctx context.Context, addr string, pid int64, out io.Writer) error {
 	}
 	defer conn.Close() //nolint:errcheck
 	c := NewProcessServiceClient(conn)
-	in := &ProcessOutputRequest{
+	in := &ProcessPidRequest{
 		Pid: pid,
 	}
 	sc, err := c.Stderr(ctx, in)