get service and revision based on name parameter

go.mod

@@ -28,6 +28,7 @@ require (
 	github.com/spf13/cobra v0.0.3
 	github.com/spf13/pflag v1.0.3
 	github.com/spf13/viper v1.3.1
+	github.com/stretchr/testify v1.3.0
 	golang.org/x/net v0.0.0-20190514140710-3ec191127204 // indirect
 	golang.org/x/oauth2 v0.0.0-20190517181255-950ef44c6e07 // indirect
 	golang.org/x/time v0.0.0-20190308202827-9d24e82272b4 // indirect

go.sum

@@ -35,6 +35,7 @@ github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3Ee
 github.com/cpuguy83/go-md2man v1.0.10 h1:BSKMNlYxDvnunlTymqtgONjNnaRV1sTpcovwwjF22jk=
 github.com/cpuguy83/go-md2man v1.0.10/go.mod h1:SmD6nW6nTyfqj6ABTjUi3V3JVMnlJmwcJI5acqYI6dE=
 github.com/davecgh/go-spew v0.0.0-20151105211317-5215b55f46b2/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/eapache/go-resiliency v1.1.0/go.mod h1:kFI+JgMyC7bLPUVY133qvEBtVayf5mFgVsvEsIPBvNs=
@@ -228,10 +229,13 @@ github.com/spf13/pflag v1.0.3 h1:zPAT6CGy6wXeQ7NtTnaTerfKOsV6V6F8agHXFiazDkg=
 github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
 github.com/spf13/viper v1.3.1 h1:5+8j8FTpnFV4nEImW/ofkzEt8VoOiLXxdYIDsB73T38=
 github.com/spf13/viper v1.3.1/go.mod h1:ZiWeW+zYFKm7srdB9IoDzzZXaJaI5eL9QjNiN/DMA2s=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v0.0.0-20151208002404-e3a8ff8ce365/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.2.2 h1:bSDNvY7ZPG5RlJ8otE/7V6gMiyenm9RtJ7IUVIAoJ1w=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8/go.mod h1:VFNgLljTbGfSG7qAOspJ7OScBnGdDN/yBr0sguwnwf0=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
 go.opencensus.io v0.20.1/go.mod h1:6WKK9ahsWS3RSO+PY9ZHZUfv2irvY6gN279GOPZjmmk=

hack/generate-docs.go

@@ -29,9 +29,9 @@ func main() {
 	if len(os.Args) > 1 {
 		dir = os.Args[1]
 	}
-	err := doc.GenMarkdownTree(rootCmd, dir + "/docs/cmd/")
+	err := doc.GenMarkdownTree(rootCmd, dir+"/docs/cmd/")
 	if err != nil {
 		fmt.Fprintln(os.Stderr, err)
 		os.Exit(1)
 	}
-}
+}

pkg/kn/commands/revision_get.go

@@ -17,8 +17,11 @@ package commands
 import (
 	"fmt"
 
+	serving "github.com/knative/serving/pkg/client/clientset/versioned/typed/serving/v1alpha1"
+
 	"github.com/spf13/cobra"
 	"k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
@@ -27,8 +30,20 @@ func NewRevisionGetCommand(p *KnParams) *cobra.Command {
 	revisionGetFlags := NewRevisionGetFlags()
 
 	revisionGetCommand := &cobra.Command{
-		Use:   "get",
+		Use:   "get NAME",
 		Short: "Get available revisions.",
+		Example: `
+  # List a all revisions.
+  kn revision get
+
+  # List a all revisions in JSON output format.
+  kn revision get -o json
+
+  # List a single revisions with specified NAME.
+  kn revision get web
+
+  # List a single revisions in YAML output format.
+  kn revision get web -o yaml`,
 		RunE: func(cmd *cobra.Command, args []string) error {
 			client, err := p.ServingFactory()
 			if err != nil {
@@ -38,23 +53,18 @@ func NewRevisionGetCommand(p *KnParams) *cobra.Command {
 			if err != nil {
 				return err
 			}
-			revision, err := client.Revisions(namespace).List(v1.ListOptions{})
-			if err != nil {
+
+			revResp, err := getRevisionInfo(args, namespace, client, cmd)
+			value, ok := revResp.(runtime.Object)
+			if err != nil || !ok {
 				return err
 			}
-			if len(revision.Items) == 0 {
-				fmt.Fprintf(cmd.OutOrStdout(), "No resources found.\n")
-				return nil
-			}
-			revision.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
-				Group:   "knative.dev",
-				Version: "v1alpha1",
-				Kind:    "revision"})
+
 			printer, err := revisionGetFlags.ToPrinter()
 			if err != nil {
 				return err
 			}
-			err = printer.PrintObj(revision, cmd.OutOrStdout())
+			err = printer.PrintObj(value, cmd.OutOrStdout())
 			if err != nil {
 				return err
 			}
@@ -65,3 +75,38 @@ func NewRevisionGetCommand(p *KnParams) *cobra.Command {
 	revisionGetFlags.AddFlags(revisionGetCommand)
 	return revisionGetCommand
 }
+
+func getRevisionInfo(args []string, namespace string, client serving.ServingV1alpha1Interface, cmd *cobra.Command) (interface{}, error) {
+
+	switch len(args) {
+	case 0:
+		revision, err := client.Revisions(namespace).List(v1.ListOptions{})
+		if err != nil {
+			return nil, err
+		}
+		if len(revision.Items) == 0 {
+			fmt.Fprintf(cmd.OutOrStdout(), "No resources found.\n")
+			return nil, nil
+		}
+		revision.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
+			Group:   "knative.dev",
+			Version: "v1alpha1",
+			Kind:    "revision"})
+		return revision, nil
+
+	case 1:
+		revision, err := client.Revisions(namespace).Get(args[0], v1.GetOptions{})
+		if err != nil {
+			return nil, err
+		}
+
+		revision.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
+			Group:   "serving.knative.dev",
+			Version: "v1alpha1",
+			Kind:    "revision"})
+
+		return revision, nil
+	default:
+		return nil, fmt.Errorf("'revision get' only accepts no arguments or a single revision name, not %d arguments as given", len(args))
+	}
+}

pkg/kn/commands/revision_get_test.go

@@ -16,6 +16,7 @@ package commands
 
 import (
 	"bytes"
+	"github.com/stretchr/testify/assert"
 	"strings"
 	"testing"
 
@@ -28,7 +29,16 @@ import (
 	client_testing "k8s.io/client-go/testing"
 )
 
-func fakeRevisionGet(args []string, response *v1alpha1.RevisionList) (action client_testing.Action, output []string, err error) {
+func fakeRevisionGet(args []string, response interface{}) (action client_testing.Action, output []string, err error) {
+	var (
+		resp runtime.Object
+		ok   bool
+	)
+
+	if resp, ok = response.(runtime.Object); !ok {
+		return
+	}
+
 	buf := new(bytes.Buffer)
 	fakeServing := &fake.FakeServingV1alpha1{&client_testing.Fake{}}
 	cmd := NewKnCommand(KnParams{
@@ -38,8 +48,9 @@ func fakeRevisionGet(args []string, response *v1alpha1.RevisionList) (action cli
 	fakeServing.AddReactor("*", "*",
 		func(a client_testing.Action) (bool, runtime.Object, error) {
 			action = a
-			return true, response, nil
+			return true, resp, nil
 		})
+
 	cmd.SetArgs(args)
 	err = cmd.Execute()
 	if err != nil {
@@ -49,7 +60,7 @@ func fakeRevisionGet(args []string, response *v1alpha1.RevisionList) (action cli
 	return
 }
 
-func TestRevisionGetEmpty(t *testing.T) {
+func TestRevisionListEmpty(t *testing.T) {
 	action, output, err := fakeRevisionGet([]string{"revision", "get"}, &v1alpha1.RevisionList{})
 	if err != nil {
 		t.Error(err)
@@ -64,9 +75,22 @@ func TestRevisionGetEmpty(t *testing.T) {
 	}
 }
 
+func TestRevisionGetEmpty(t *testing.T) {
+	action, _, err := fakeRevisionGet([]string{"revision", "get", "name"}, &v1alpha1.Revision{})
+	if err != nil {
+		t.Error(err)
+		return
+	}
+	if action == nil {
+		t.Errorf("No action")
+	} else if !action.Matches("get", "revisions") {
+		t.Errorf("Bad action %v", action)
+	}
+}
+
 func TestRevisionGetDefaultOutput(t *testing.T) {
-	revision1 := createMockRevisionWithParams("foo-abcd", "foo")
-	revision2 := createMockRevisionWithParams("bar-wxyz", "bar")
+	revision1 := createMockRevisionWithParams("foo-abcd", "foo", false)
+	revision2 := createMockRevisionWithParams("bar-wxyz", "bar", false)
 	RevisionList := &v1alpha1.RevisionList{Items: []v1alpha1.Revision{*revision1, *revision2}}
 	action, output, err := fakeRevisionGet([]string{"revision", "get"}, RevisionList)
 	if err != nil {
@@ -82,11 +106,69 @@ func TestRevisionGetDefaultOutput(t *testing.T) {
 	testContains(t, output[2], []string{"bar", "bar-wxyz"}, "value")
 }
 
-func createMockRevisionWithParams(name, svcName string) *v1alpha1.Revision {
+func TestRevisionGetOneOutput(t *testing.T) {
+	revision := createMockRevisionWithParams("foo-abcd", "foo", true)
+	action, output, err := fakeRevisionGet([]string{"revision", "get", "foo-abcd"}, revision)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if action == nil {
+		t.Errorf("No action")
+	} else if !action.Matches("get", "revisions") {
+		t.Errorf("Bad action %v", action)
+	}
+	testContains(t, output[0], []string{"SERVICE", "NAME", "AGE", "CONDITIONS", "READY", "REASON"}, "column header")
+	testContains(t, output[1], []string{"foo", "foo-abcd"}, "value")
+}
+
+func TestRevisionGetOutputWithTwoRevName(t *testing.T) {
+	t.Log("create a first revision name foo")
+	revision := createMockRevisionWithParams("foo-abcd", "foo", true)
+	action, output, err := fakeRevisionGet([]string{"revision", "get", "foo-abcd"}, revision)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if action == nil {
+		t.Errorf("No action")
+	} else if !action.Matches("get", "revisions") {
+		t.Errorf("Bad action %v", action)
+	}
+	testContains(t, output[0], []string{"SERVICE", "NAME", "AGE", "CONDITIONS", "READY", "REASON"}, "column header")
+	testContains(t, output[1], []string{"foo", "foo-abcd"}, "value")
+
+	t.Log("create a second revision name bar")
+	revision = createMockRevisionWithParams("bar-abcd", "bar", true)
+	action, output, err = fakeRevisionGet([]string{"revision", "get", "bar-abcd"}, revision)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if action == nil {
+		t.Errorf("No action")
+	} else if !action.Matches("get", "revisions") {
+		t.Errorf("Bad action %v", action)
+	}
+	testContains(t, output[0], []string{"SERVICE", "NAME", "AGE", "CONDITIONS", "READY", "REASON"}, "column header")
+	testContains(t, output[1], []string{"bar", "bar-abcd"}, "value")
+
+	t.Log("verify by passing two revision name to get command")
+	_, output, err = fakeRevisionGet([]string{"revision", "get", "foo-abcd", "bar-abcd"}, revision)
+	assert.NotNil(t, err)
+	assert.Empty(t, output)
+
+}
+
+func createMockRevisionWithParams(name, svcName string, version bool) *v1alpha1.Revision {
+	var apiVersion string
+	if version {
+		apiVersion = "serving.knative.dev/v1alpha1"
+	} else {
+		apiVersion = "knative.dev/v1alpha1"
+	}
+
 	revision := &v1alpha1.Revision{
 		TypeMeta: metav1.TypeMeta{
 			Kind:       "Revision",
-			APIVersion: "knative.dev/v1alpha1",
+			APIVersion: apiVersion,
 		},
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      name,

pkg/kn/commands/service_get.go

@@ -17,8 +17,11 @@ package commands
 import (
 	"fmt"
 
+	serving "github.com/knative/serving/pkg/client/clientset/versioned/typed/serving/v1alpha1"
+
 	"github.com/spf13/cobra"
 	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
@@ -27,8 +30,20 @@ func NewServiceGetCommand(p *KnParams) *cobra.Command {
 	serviceGetFlags := NewServiceGetFlags()
 
 	serviceGetCommand := &cobra.Command{
-		Use:   "get",
+		Use:   "get NAME",
 		Short: "Get available services.",
+		Example: `
+  # List a all services.
+  kn service get
+
+  # List a all services in JSON output format.
+  kn service get -o json
+
+  # List a single service with specified NAME.
+  kn service get web
+
+  # List a single service in YAML output format.
+  kn service get web -o yaml`,
 		RunE: func(cmd *cobra.Command, args []string) error {
 			client, err := p.ServingFactory()
 			if err != nil {
@@ -38,25 +53,19 @@ func NewServiceGetCommand(p *KnParams) *cobra.Command {
 			if err != nil {
 				return err
 			}
-			service, err := client.Services(namespace).List(v1.ListOptions{})
-			if err != nil {
+
+			srvResp, err := getServiceInfo(args, namespace, client, cmd)
+			value, ok := srvResp.(runtime.Object)
+			if err != nil || !ok {
 				return err
 			}
-			if len(service.Items) == 0 {
-				fmt.Fprintf(cmd.OutOrStdout(), "No resources found.\n")
-				return nil
-			}
-			service.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
-				Group:   "knative.dev",
-				Version: "v1alpha1",
-				Kind:    "Service"})
 
 			printer, err := serviceGetFlags.ToPrinter()
 			if err != nil {
 				return err
 			}
 
-			err = printer.PrintObj(service, cmd.OutOrStdout())
+			err = printer.PrintObj(value, cmd.OutOrStdout())
 			if err != nil {
 				return err
 			}
@@ -67,3 +76,38 @@ func NewServiceGetCommand(p *KnParams) *cobra.Command {
 	serviceGetFlags.AddFlags(serviceGetCommand)
 	return serviceGetCommand
 }
+
+func getServiceInfo(args []string, namespace string, client serving.ServingV1alpha1Interface, cmd *cobra.Command) (interface{}, error) {
+
+	switch len(args) {
+	case 0:
+		service, err := client.Services(namespace).List(v1.ListOptions{})
+		if err != nil {
+			return nil, err
+		}
+		if len(service.Items) == 0 {
+			fmt.Fprintf(cmd.OutOrStdout(), "No resources found.\n")
+			return nil, nil
+		}
+		service.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
+			Group:   "knative.dev",
+			Version: "v1alpha1",
+			Kind:    "Service"})
+
+		return service, nil
+	case 1:
+		service, err := client.Services(namespace).Get(args[0], v1.GetOptions{})
+		if err != nil {
+			return nil, err
+		}
+
+		service.GetObjectKind().SetGroupVersionKind(schema.GroupVersionKind{
+			Group:   "serving.knative.dev",
+			Version: "v1alpha1",
+			Kind:    "Service"})
+
+		return service, nil
+	default:
+		return nil, fmt.Errorf("'service get' only accepts no arguments or a single service name, not %d arguments as given", len(args))
+	}
+}