openapi

README

Sampling New OpenAPI Data

This document describes how to fetch OpenAPI data from a particular kubernetes version number.

Fetching the Schema

In this directory, fetch the openapi schema for the kubernetes api:

make nuke
make kubernetesapi/swagger.json

You can specify a specific version with the "API_VERSION" parameter. The default version is v1.19.1. Here is an example for fetching the data for v1.14.1.

make kubernetesapi/swagger.json API_VERSION=v1.14.1

This will update the OpenAPI schema.

Generating Swagger.go

In this directory, generate the swagger.go files.

make

Run all tests

At the top of the repository, run the tests.

make prow-presubmit-check >& /tmp/k.txt; echo $?
# The exit code should be zero; if not examine /tmp/k.txt

Documentation

Overview

Example

package main

import (
	"fmt"

	"sigs.k8s.io/kustomize/kyaml/openapi"
	"sigs.k8s.io/kustomize/kyaml/yaml"
)

func main() {
	s := openapi.SchemaForResourceType(yaml.TypeMeta{APIVersion: "apps/v1", Kind: "Deployment"})

	f := s.Lookup("spec", "replicas")
	fmt.Println(f.Schema.Description[:70] + "...")
	fmt.Println(f.Schema.Type)

}

Output:

Number of desired pods. This is a pointer to distinguish between expli...
[integer]

Example (ArrayElement)

package main

import (
	"fmt"

	"sigs.k8s.io/kustomize/kyaml/openapi"
	"sigs.k8s.io/kustomize/kyaml/yaml"
)

func main() {
	s := openapi.SchemaForResourceType(yaml.TypeMeta{APIVersion: "apps/v1", Kind: "Deployment"})

	f := s.Lookup("spec", "template", "spec", "containers",
		openapi.Elements, "ports", openapi.Elements, "containerPort")
	fmt.Println(f.Schema.Description[:70] + "...")
	fmt.Println(f.Schema.Type)

}

Output:

Number of port to expose on the pod's IP address. This must be a valid...
[integer]

Example (ArrayMerge)

package main

import (
	"fmt"

	"sigs.k8s.io/kustomize/kyaml/openapi"
	"sigs.k8s.io/kustomize/kyaml/yaml"
)

func main() {
	s := openapi.SchemaForResourceType(yaml.TypeMeta{APIVersion: "apps/v1", Kind: "Deployment"})

	f := s.Lookup("spec", "template", "spec", "containers")
	fmt.Println(f.Schema.Description[:70] + "...")
	fmt.Println(f.Schema.Type)
	fmt.Println(f.PatchStrategyAndKey()) // merge patch strategy on name

}

Output:

List of containers belonging to the pod. Containers cannot currently b...
[array]
merge name

Example (ArrayReplace)

package main

import (
	"fmt"

	"sigs.k8s.io/kustomize/kyaml/openapi"
	"sigs.k8s.io/kustomize/kyaml/yaml"
)

func main() {
	s := openapi.SchemaForResourceType(yaml.TypeMeta{APIVersion: "apps/v1", Kind: "Deployment"})

	f := s.Lookup("spec", "template", "spec", "containers", openapi.Elements, "args")
	fmt.Println(f.Schema.Description[:70] + "...")
	fmt.Println(f.Schema.Type)
	fmt.Println(f.PatchStrategyAndKey()) // no patch strategy or merge key

}

Output:

Arguments to the entrypoint. The docker image's CMD is used if this is...
[array]

Example (Map)

package main

import (
	"fmt"

	"sigs.k8s.io/kustomize/kyaml/openapi"
	"sigs.k8s.io/kustomize/kyaml/yaml"
)

func main() {
	s := openapi.SchemaForResourceType(yaml.TypeMeta{APIVersion: "apps/v1", Kind: "Deployment"})

	f := s.Lookup("metadata", "labels")
	fmt.Println(f.Schema.Description[:70] + "...")
	fmt.Println(f.Schema.Type)

}

Output:

Map of string keys and values that can be used to organize and categor...
[object]

Index

• Constants
• func AddDefinitions(definitions spec.Definitions)
• func AddSchema(s []byte) error
• func AddSchemaFromFile(path string) error
• func AddSchemaFromFileUsingField(path, field string) error
• func DefinitionRefs(openAPIPath string) ([]string, error)
• func DeleteSchemaInFile(openAPIPath string) error
• func IsNamespaceScoped(typeMeta yaml.TypeMeta) (bool, bool)
• func ResetOpenAPI()
• func Resolve(ref *spec.Ref) (*spec.Schema, error)
• func Schema() *spec.Schema
• func SuppressBuiltInSchemaUse()
• type ResourceSchema
  • func GetSchema(s string) (*ResourceSchema, error)
  • func SchemaForResourceType(t yaml.TypeMeta) *ResourceSchema
  • func (rs *ResourceSchema) Elements() *ResourceSchema
  • func (rs *ResourceSchema) Field(field string) *ResourceSchema
  • func (rs *ResourceSchema) IsMissingOrNull() bool
  • func (rs *ResourceSchema) Lookup(path ...string) *ResourceSchema
  • func (rs *ResourceSchema) PatchStrategyAndKey() (string, string)

Examples

• Package
• Package (ArrayElement)
• Package (ArrayMerge)
• Package (ArrayReplace)
• Package (Map)

Constants

const Definitions = "definitions"

const Elements = "[]"

const SupplementaryOpenAPIFieldName = "openAPI"

SupplementaryOpenAPIFieldName is the conventional field name (JSON/YAML) containing supplementary OpenAPI definitions.

Functions

func AddDefinitions

func AddDefinitions(definitions spec.Definitions)

AddDefinitions adds the definitions to the global schema.

func AddSchema

func AddSchema(s []byte) error

AddSchema parses s, and adds definitions from s to the global schema.

func AddSchemaFromFile

func AddSchemaFromFile(path string) error

AddSchemaFromFile reads the file at path and parses the OpenAPI definitions from the field "openAPI"

func AddSchemaFromFileUsingField

func AddSchemaFromFileUsingField(path, field string) error

AddSchemaFromFileUsingField reads the file at path and parses the OpenAPI definitions from the specified field. If field is the empty string, use the whole document as OpenAPI.

func DefinitionRefs

func DefinitionRefs(openAPIPath string) ([]string, error)

DefinitionRefs returns the list of openAPI definition references present in the input openAPIPath

func DeleteSchemaInFile

func DeleteSchemaInFile(openAPIPath string) error

DeleteSchemaInFile reads the file at path and removes all the openAPI definitions present in file from global schema

func IsNamespaceScoped

func IsNamespaceScoped(typeMeta yaml.TypeMeta) (bool, bool)

IsNamespaceScoped determines whether a resource is namespace or cluster-scoped by looking at the information in the openapi schema. The second return value tells whether the provided type could be found in the openapi schema. If the value is false here, the scope of the resource is not known. If the type if found, the first return value will be true if the resource is namespace-scoped, and false if the type is cluster-scoped.

func ResetOpenAPI

func ResetOpenAPI()

ResetOpenAPI resets the openapi data to empty

func Resolve

func Resolve(ref *spec.Ref) (*spec.Schema, error)

Resolve resolves the reference against the global schema

func Schema

func Schema() *spec.Schema

Schema returns the global schema

func SuppressBuiltInSchemaUse

func SuppressBuiltInSchemaUse()

SuppressBuiltInSchemaUse can be called to prevent using the built-in Kubernetes schema as part of the global schema. Must be called before the schema is used.

Types

type ResourceSchema

type ResourceSchema struct {
	// Schema is the OpenAPI schema for a Resource or field
	Schema *spec.Schema
}

ResourceSchema wraps the OpenAPI Schema.

func GetSchema

func GetSchema(s string) (*ResourceSchema, error)

GetSchema parses s into a ResourceSchema, resolving References within the global schema.

func SchemaForResourceType

func SchemaForResourceType(t yaml.TypeMeta) *ResourceSchema

SchemaForResourceType returns the Schema for the given Resource TODO(pwittrock): create a version of this function that will return a schema which can be used for duck-typed Resources -- e.g. contains common fields such as metadata, replicas and spec.template.spec

func (*ResourceSchema) Elements

func (rs *ResourceSchema) Elements() *ResourceSchema

Elements returns the Schema for the elements of an array.

func (*ResourceSchema) Field

func (rs *ResourceSchema) Field(field string) *ResourceSchema

Field returns the Schema for a field.

func (*ResourceSchema) IsMissingOrNull

func (rs *ResourceSchema) IsMissingOrNull() bool

IsEmpty returns true if the ResourceSchema is empty

func (*ResourceSchema) Lookup

func (rs *ResourceSchema) Lookup(path ...string) *ResourceSchema

Lookup calls either Field or Elements for each item in the path. If the path item is "[]", then Elements is called, otherwise Field is called. If any Field or Elements call returns nil, then Lookup returns nil immediately.

func (*ResourceSchema) PatchStrategyAndKey

func (rs *ResourceSchema) PatchStrategyAndKey() (string, string)

PatchStrategyAndKey returns the patch strategy and merge key extensions