kubernetes

Nov 18, 2024

Changes in this version

+ func CreateResource(ctx context.Context, c client.Client, obj *unstructured.Unstructured) error

+ func DeleteResource(ctx context.Context, c client.Client, obj *unstructured.Unstructured) error

+ func GetLiveResource(ctx context.Context, object *unstructured.Unstructured, pluralName string) (*unstructured.Unstructured, error)

+ func ListLiveResource(ctx context.Context, apiGroup string, version string, pluralName string, ...) (*unstructured.UnstructuredList, error)

+ func ListResources(ctx context.Context, c client.Client, gvk schema.GroupVersionKind, ...) (*unstructured.UnstructuredList, error)

+ func PatchResource(ctx context.Context, c client.Client, obj *unstructured.Unstructured, ...) error

+ func SetDynamicClient(restConfig *rest.Config) error

+ func UpdateResource(ctx context.Context, c client.Client, obj *unstructured.Unstructured) error

Aug 14, 2024

Changes in this version

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

+ func CreateUnstructuredCR(ctx context.Context, restConfig *rest.Config, ...) error

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

+ func ListUnstructuredCR(ctx context.Context, restConfig *rest.Config, apiGroup string, version string, ...) (*unstructured.UnstructuredList, error)

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

+ func UpdateUnstructuredCR(ctx context.Context, restConfig *rest.Config, ...) error

type GenericObject

+ func ListCR(ctx context.Context, restConfig *rest.Config, apiGroup string, version string, ...) ([]*GenericObject, error)

+ func (obj *GenericObject) DeepCopy() *GenericObject

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

Jul 16, 2024

Changes in this version

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

+ func NewPodDisruptionBudget(name, namespace string, maxUnavailable int32, ...) *policyv1.PodDisruptionBudget

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

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

type GenericStatus

+ ObservedGeneration int64

Jun 25, 2024

Changes in this version

+ func ApplyCRSpec(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) error

+ func ApplyOwnership(manifest string, controllerRollout *v1alpha1.NumaflowControllerRollout) ([]byte, error)

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

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

+ func GetResource(ctx context.Context, restConfig *rest.Config, object *GenericObject, ...) (*unstructured.Unstructured, error)

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

+ func IsValidKubernetesManifestFile(fileName string) bool

+ func IsValidKubernetesNamespace(name string) bool

+ func NewKubectl() kube.Kubectl

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

+ func SetAnnotation(obj metav1.Object, key, value string)

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

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

+ type GenericObject struct

+ Spec runtime.RawExtension

+ Status runtime.RawExtension

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

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

+ type GenericStatus struct

+ Conditions []metav1.Condition

+ Phase string

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