kubernetes

Documentation

Index

• func CompareSpecs(a *GenericObject, b *GenericObject) (bool, error)
• func CreateCR(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) error
• func CreateUnstructuredCR(ctx context.Context, restConfig *rest.Config, ...) error
• func GetLabel(un *unstructured.Unstructured, key string) (string, error)
• func GetSecret(ctx context.Context, client k8sClient.Client, namespace, secretName string) (*corev1.Secret, error)
• func GetUnstructuredCR(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) (*unstructured.Unstructured, error)
• func IsValidKubernetesManifestFile(fileName string) bool
• func IsValidKubernetesNamespace(name string) bool
• func ListUnstructuredCR(ctx context.Context, restConfig *rest.Config, apiGroup string, version string, ...) (*unstructured.UnstructuredList, error)
• func NewKubectl() kube.Kubectl
• func NewPodDisruptionBudget(name, namespace string, maxUnavailable int32, ...) *policyv1.PodDisruptionBudget
• func ObjectToUnstructured(object *GenericObject) (*unstructured.Unstructured, error)
• func SetLabel(target *unstructured.Unstructured, key, val string) error
• func StartConfigMapWatcher(ctx context.Context, config *rest.Config) error
• func UpdateCR(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) error
• func UpdateStatus(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) error
• func UpdateUnstructuredCR(ctx context.Context, restConfig *rest.Config, ...) error
• type GenericObject
  • func GetCR(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) (*GenericObject, error)
  • func ListCR(ctx context.Context, restConfig *rest.Config, apiGroup string, version string, ...) ([]*GenericObject, error)
  • func UnstructuredToObject(u *unstructured.Unstructured) (*GenericObject, error)
  • func (obj *GenericObject) DeepCopy() *GenericObject
  • func (obj *GenericObject) DeepCopyObject() runtime.Object
• type GenericStatus
  • func ParseStatus(obj *GenericObject) (GenericStatus, error)

Functions

func CompareSpecs

func CompareSpecs(a *GenericObject, b *GenericObject) (bool, error)

func CreateCR

func CreateCR(
	ctx context.Context,
	restConfig *rest.Config,
	object *GenericObject,
	pluralName string,
) error

func CreateUnstructuredCR

func CreateUnstructuredCR(
	ctx context.Context,
	restConfig *rest.Config,
	unstruc *unstructured.Unstructured,
	gvr schema.GroupVersionResource,
	namespace string,
	name string,
) error

func GetLabel

func GetLabel(un *unstructured.Unstructured, key string) (string, error)

GetLabel returns the label identified by "key"

func GetSecret

func GetSecret(ctx context.Context, client k8sClient.Client, namespace, secretName string) (*corev1.Secret, error)

GetSecret gets secret using the kubernetes client

func GetUnstructuredCR

func GetUnstructuredCR(
	ctx context.Context,
	restConfig *rest.Config,
	object *GenericObject,
	pluralName string,
) (*unstructured.Unstructured, error)

func IsValidKubernetesManifestFile

func IsValidKubernetesManifestFile(fileName string) bool

func IsValidKubernetesNamespace

func IsValidKubernetesNamespace(name string) bool

func ListUnstructuredCR

func ListUnstructuredCR(
	ctx context.Context,
	restConfig *rest.Config,
	apiGroup string,
	version string,
	pluralName string,
	namespace string,
	labelSelector string,
	fieldSelector string,
) (*unstructured.UnstructuredList, error)

func NewKubectl

func NewKubectl() kube.Kubectl

func NewPodDisruptionBudget

func NewPodDisruptionBudget(name, namespace string, maxUnavailable int32, ownerReference []metav1.OwnerReference) *policyv1.PodDisruptionBudget

func ObjectToUnstructured

func ObjectToUnstructured(object *GenericObject) (*unstructured.Unstructured, error)

func SetLabel

func SetLabel(target *unstructured.Unstructured, key, val string) error

SetLabel sets the label identified by "key" on an unstructured object

func StartConfigMapWatcher

func StartConfigMapWatcher(ctx context.Context, config *rest.Config) error

StartConfigMapWatcher will start a watcher for ConfigMaps with the given label key and value

func UpdateCR

func UpdateCR(
	ctx context.Context,
	restConfig *rest.Config,
	object *GenericObject,
	pluralName string,
) error

func UpdateStatus

func UpdateStatus(ctx context.Context, restConfig *rest.Config, object *GenericObject, pluralName string) error

func UpdateUnstructuredCR

func UpdateUnstructuredCR(
	ctx context.Context,
	restConfig *rest.Config,
	unstruc *unstructured.Unstructured,
	gvr schema.GroupVersionResource,
	namespace string,
	name string,
) error

Types

type GenericObject

type GenericObject struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   runtime.RawExtension `json:"spec"`
	Status runtime.RawExtension `json:"status,omitempty"`
}

func GetCR

func GetCR(ctx context.Context, restConfig *rest.Config, object *GenericObject, pluralName string) (*GenericObject, error)

look up a Resource

func ListCR

func ListCR(ctx context.Context,
	restConfig *rest.Config,
	apiGroup string,
	version string,
	pluralName string,
	namespace string,

	labelSelector string,

	fieldSelector string) ([]*GenericObject, error)

func UnstructuredToObject

func UnstructuredToObject(u *unstructured.Unstructured) (*GenericObject, error)

func (*GenericObject) DeepCopy

func (obj *GenericObject) DeepCopy() *GenericObject

func (*GenericObject) DeepCopyObject

func (obj *GenericObject) DeepCopyObject() runtime.Object

type GenericStatus

type GenericStatus struct {
	Phase              string             `json:"phase,omitempty"`
	Conditions         []metav1.Condition `json:"conditions,omitempty"`
	ObservedGeneration int64              `json:"observedGeneration,omitempty"`
}

func ParseStatus

func ParseStatus(obj *GenericObject) (GenericStatus, error)