k8sutil

Documentation

Index

• func CreateFQAPIs(pkg string, gvs map[string][]string) (apis []string)
• func FormatOperatorNameDNS1123(name string) string
• func GetCRDManifestPaths(crdsDir string) (crdPaths []string, err error)
• func GetCRDs(crdsDir string) ([]*apiextv1beta1.CustomResourceDefinition, error)
• func GetDisplayName(name string) string
• func GetKubeconfigAndNamespace(configPath string) (*rest.Config, string, error)
• func GetObjectBytes(obj interface{}, m MarshalFunc) ([]byte, error)
• func GetTypeMetaFromBytes(b []byte) (t metav1.TypeMeta, err error)
• func ParseGroupSubpackages(apisDir string) (map[string][]string, error)
• func ParseGroupVersions(apisDir string) (map[string][]string, error)
• type CRDVersions
  • func (vs CRDVersions) Len() int
  • func (vs CRDVersions) Less(i, j int) bool
  • func (vs CRDVersions) Swap(i, j int)
• type MarshalFunc
• type MatchingFields
  • func (m MatchingFields) ApplyToDeleteAllOf(opts *client.DeleteAllOfOptions)
  • func (m MatchingFields) ApplyToList(opts *client.ListOptions)

Functions

func CreateFQAPIs

func CreateFQAPIs(pkg string, gvs map[string][]string) (apis []string)

CreateFQAPIs return a slice of all fully qualified pkg + groups + versions of pkg and gvs in the format "pkg/groupA/v1".

func FormatOperatorNameDNS1123

func FormatOperatorNameDNS1123(name string) string

FormatOperatorNameDNS1123 ensures name is DNS1123 label-compliant by replacing all non-compliant UTF-8 characters with "-".

func GetCRDManifestPaths

func GetCRDManifestPaths(crdsDir string) (crdPaths []string, err error)

GetCRDManifestPaths gets all CRD manifest paths in crdsDir and subdirs.

func GetCRDs

func GetCRDs(crdsDir string) ([]*apiextv1beta1.CustomResourceDefinition, error)

GetCRDs parses all CRD manifests in the directory crdsDir and all of its subdirectories.

func GetDisplayName

func GetDisplayName(name string) string

GetDisplayName turns a project dir name in any of {snake, chain, camel} cases, hierarchical dot structure, or space-delimited into a space-delimited, title'd display name. Ex. "another-_AppOperator_againTwiceThrice More" -> "Another App Operator Again Twice Thrice More"

func GetKubeconfigAndNamespace

func GetKubeconfigAndNamespace(configPath string) (*rest.Config, string, error)

GetKubeconfigAndNamespace returns the *rest.Config and default namespace defined in the kubeconfig at the specified path. If no path is provided, returns the default *rest.Config and namespace

func GetObjectBytes

func GetObjectBytes(obj interface{}, m MarshalFunc) ([]byte, error)

GetObjectBytes marshalls an object with m and removes runtime-managed fields: 'status', 'creationTimestamp'

func GetTypeMetaFromBytes

func GetTypeMetaFromBytes(b []byte) (t metav1.TypeMeta, err error)

GetTypeMetaFromBytes gets the type and object metadata from b. b is assumed to be a single Kubernetes resource manifest.

func ParseGroupSubpackages

func ParseGroupSubpackages(apisDir string) (map[string][]string, error)

ParseGroupSubpackages parses the apisDir directory tree and returns a map of all found API groups to subpackages.

func ParseGroupVersions

func ParseGroupVersions(apisDir string) (map[string][]string, error)

ParseGroupVersions parses the apisDir directory tree and returns a map of all found API groups to versions.

Types

type CRDVersions

type CRDVersions []apiextv1beta1.CustomResourceDefinitionVersion

func (CRDVersions) Len

func (vs CRDVersions) Len() int

func (CRDVersions) Less

func (vs CRDVersions) Less(i, j int) bool

func (CRDVersions) Swap

func (vs CRDVersions) Swap(i, j int)

type MarshalFunc

type MarshalFunc func(interface{}) ([]byte, error)

type MatchingFields

type MatchingFields struct {
	Sel fields.Selector
}

MatchingFields implements the client.ListOption and client.DeleteAllOfOption interfaces so fields.Selector can be used directly in client.List and client.DeleteAllOf.

func (MatchingFields) ApplyToDeleteAllOf

func (m MatchingFields) ApplyToDeleteAllOf(opts *client.DeleteAllOfOptions)

func (MatchingFields) ApplyToList

func (m MatchingFields) ApplyToList(opts *client.ListOptions)