Skip to content

Commit

Permalink
Add machine readable output (-o flag) to kn source apiserver describe (
Browse files Browse the repository at this point in the history
…#1146)

Signed-off-by: Arghya Sadhu <[email protected]>
  • Loading branch information
arghya88 authored Nov 26, 2020
1 parent 2941816 commit b8bce53
Show file tree
Hide file tree
Showing 5 changed files with 65 additions and 14 deletions.
4 changes: 4 additions & 0 deletions CHANGELOG.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,10 @@
|===
| | Description | PR

| 🐛
| Add machine readable output (-o flag) to kn source apiserver describe
| https://github.com/knative/client/pull/1146[#1146]

| 🐛
| Fix a race condition when using Kubernetes watches
| https://github.com/knative/client/pull/1113[#1113]
Expand Down
14 changes: 10 additions & 4 deletions docs/cmd/kn_source_apiserver_describe.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,16 +14,22 @@ kn source apiserver describe NAME

```
# Describe an ApiServer source with name 'k8sevents'
# Describe an api-server source with name 'k8sevents'
kn source apiserver describe k8sevents
# Describe an api-server source with name 'k8sevents' in YAML format
kn source apiserver describe k8sevents -o yaml
```

### Options

```
-h, --help help for describe
-n, --namespace string Specify the namespace to operate in.
-v, --verbose More output.
--allow-missing-template-keys If true, ignore any errors in templates when a field or map key is missing in the template. Only applies to golang and jsonpath output formats. (default true)
-h, --help help for describe
-n, --namespace string Specify the namespace to operate in.
-o, --output string Output format. One of: json|yaml|name|go-template|go-template-file|template|templatefile|jsonpath|jsonpath-file.
--template string Template string or path to template file to use when -o=go-template, -o=go-template-file. The template format is golang templates [http://golang.org/pkg/text/template/#pkg-overview].
-v, --verbose More output.
```

### Options inherited from parent commands
Expand Down
39 changes: 30 additions & 9 deletions pkg/kn/commands/source/apiserver/describe.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,23 +18,34 @@ import (
"errors"
"fmt"
"sort"
"strings"

"github.com/spf13/cobra"
"k8s.io/cli-runtime/pkg/genericclioptions"
v1alpha2 "knative.dev/eventing/pkg/apis/sources/v1alpha2"

"knative.dev/client/lib/printing"
"knative.dev/client/pkg/kn/commands"
"knative.dev/client/pkg/printers"
)

var describeExample = `
# Describe an api-server source with name 'k8sevents'
kn source apiserver describe k8sevents
# Describe an api-server source with name 'k8sevents' in YAML format
kn source apiserver describe k8sevents -o yaml`

// NewAPIServerDescribeCommand to describe an ApiServer source object
func NewAPIServerDescribeCommand(p *commands.KnParams) *cobra.Command {
apiServerDescribe := &cobra.Command{
Use: "describe NAME",
Short: "Show details of an api-server source",
Example: `
# Describe an ApiServer source with name 'k8sevents'
kn source apiserver describe k8sevents`,

// For machine readable output
machineReadablePrintFlags := genericclioptions.NewPrintFlags("")

command := &cobra.Command{
Use: "describe NAME",
Short: "Show details of an api-server source",
Example: describeExample,
RunE: func(cmd *cobra.Command, args []string) error {
if len(args) != 1 {
return errors.New("'kn source apiserver describe' requires name of the source as single argument")
Expand All @@ -52,6 +63,15 @@ func NewAPIServerDescribeCommand(p *commands.KnParams) *cobra.Command {
}

out := cmd.OutOrStdout()

// Print out machine readable output if requested
if machineReadablePrintFlags.OutputFlagSpecified() {
printer, err := machineReadablePrintFlags.ToPrinter()
if err != nil {
return err
}
return printer.PrintObj(apiSource, out)
}
dw := printers.NewPrefixWriter(out)

printDetails, err := cmd.Flags().GetBool("verbose")
Expand Down Expand Up @@ -90,11 +110,12 @@ func NewAPIServerDescribeCommand(p *commands.KnParams) *cobra.Command {
return nil
},
}
flags := apiServerDescribe.Flags()
flags := command.Flags()
commands.AddNamespaceFlags(flags, false)
flags.BoolP("verbose", "v", false, "More output.")

return apiServerDescribe
machineReadablePrintFlags.AddFlags(command)
command.Flag("output").Usage = fmt.Sprintf("Output format. One of: %s.", strings.Join(machineReadablePrintFlags.AllowedFormats(), "|"))
return command
}

func writeResources(dw printers.PrefixWriter, apiVersionKindSelectors []v1alpha2.APIVersionKindSelector) {
Expand Down
17 changes: 17 additions & 0 deletions pkg/kn/commands/source/apiserver/describe_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,23 @@ func TestSimpleDescribe(t *testing.T) {
apiServerRecorder.Validate()
}

func TestDescribeMachineReadable(t *testing.T) {
apiServerClient := v1alpha2.NewMockKnAPIServerSourceClient(t, "mynamespace")

apiServerRecorder := apiServerClient.Recorder()
sampleSource := createAPIServerSource("testsource", "Event", "v1", "testsa", "Reference", map[string]string{"foo": "bar"}, createSinkv1("testsvc", "default"))
sampleSource.APIVersion = "sources.knative.dev/v1"
sampleSource.Kind = "ApiServerSource"
sampleSource.Namespace = "mynamespace"
apiServerRecorder.GetAPIServerSource("testsource", sampleSource, nil)

out, err := executeAPIServerSourceCommand(apiServerClient, nil, "describe", "testsource", "-o", "yaml")
assert.NilError(t, err)
assert.Assert(t, util.ContainsAll(out, "kind: ApiServerSource", "spec:", "status:", "metadata:"))

apiServerRecorder.Validate()
}

func TestDescribeError(t *testing.T) {
apiServerClient := v1alpha2.NewMockKnAPIServerSourceClient(t, "mynamespace")

Expand Down
5 changes: 4 additions & 1 deletion pkg/sources/v1alpha2/apiserver_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,10 @@ func (c *apiServerSourcesClient) GetAPIServerSource(name string) (*v1alpha2.ApiS
if err != nil {
return nil, knerrors.GetError(err)
}

err = updateSourceGVK(apiSource)
if err != nil {
return nil, err
}
return apiSource, nil
}

Expand Down

0 comments on commit b8bce53

Please sign in to comment.