k8sutil

Documentation

Index

• func CombineManifests(base []byte, manifests ...[]byte) []byte
• func CreateFQAPIs(pkg string, gvs map[string][]string) (apis []string)
• func FormatOperatorNameDNS1123(name string) string
• func GenerateCombinedGlobalManifest(crdsDir string) (*os.File, error)
• func GenerateCombinedNamespacedManifest(deployDir string) (*os.File, error)
• func GetCustomResourceDefinitions(crdsDir string) (crds []apiextv1beta1.CustomResourceDefinition, err 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)
• func TrimDNS1123Label(label string) string
• 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)
• type Scanner
  • func NewYAMLScanner(b []byte) *Scanner
  • func (s *Scanner) Bytes() []byte
  • func (s *Scanner) Err() error
  • func (s *Scanner) Scan() bool
  • func (s *Scanner) Text() string

Functions

func CombineManifests

func CombineManifests(base []byte, manifests ...[]byte) []byte

CombineManifests combines given manifests with a base manifest and adds yaml style separation. Nothing is appended if the manifest is empty or base already contains a trailing separator.

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 GenerateCombinedGlobalManifest

func GenerateCombinedGlobalManifest(crdsDir string) (*os.File, error)

GenerateCombinedGlobalManifest creates a temporary manifest yaml by combining all standard global resource manifests in crdsDir.

func GenerateCombinedNamespacedManifest

func GenerateCombinedNamespacedManifest(deployDir string) (*os.File, error)

GenerateCombinedNamespacedManifest creates a temporary manifest yaml by combining all standard namespaced resource manifests in deployDir.

func GetCustomResourceDefinitions

func GetCustomResourceDefinitions(crdsDir string) (crds []apiextv1beta1.CustomResourceDefinition, err error)

GetCustomResourceDefinitions returns all CRD manifests in the directory crdsDir.

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.

func TrimDNS1123Label

func TrimDNS1123Label(label string) string

TrimDNS1123Label trims a label to meet the DNS 1123 label length requirement by removing characters from the beginning of label such that len(label) <= 63.

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)

type Scanner

type Scanner struct {
	// contains filtered or unexported fields
}

Scanner scans a yaml manifest file for manifest tokens delimited by "---". See bufio.Scanner for semantics.

func NewYAMLScanner

func NewYAMLScanner(b []byte) *Scanner

func (*Scanner) Bytes

func (s *Scanner) Bytes() []byte

func (*Scanner) Err

func (s *Scanner) Err() error

func (*Scanner) Scan

func (s *Scanner) Scan() bool

func (*Scanner) Text

func (s *Scanner) Text() string