utils

package

v0.1.8 Latest Latest Go to latest Published: May 15, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateFolder(path string, override bool) error

Create folder (clear its content if it exists)

func GetKubeConfigPath() string

func WriteFile(path string, content string) error

WriteFile writes content to a file

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

func NewK8sClient() (*K8sClient, error)

func (c *K8sClient) ApplyManifest(obj *unstructured.Unstructured, source string, fallbackNamespace string) error

Helper function to apply a single manifest from an unstructured object

func (c *K8sClient) ApplyManifestFromFile(path string, fallbackNamespace string) (int, error)

ApplyManifestFromFile applies a Kubernetes manifest from a file

func (c *K8sClient) ApplyManifestFromString(manifest string, fallbackNamespace string) (int, error)

func (c *K8sClient) CheckIfResourceExists(gvr schema.GroupVersionResource, namespace string, name string) (bool, error)

func (c *K8sClient) CreateNamespace(namespace string) error

create namespace

func (c *K8sClient) DeleteArgoCDApplications(namespace string) error

func (c *K8sClient) GetArgoCDApplication(namespace string, name string) (string, error)

GetArgoCDApplication gets a single ArgoCD application by name

func (c *K8sClient) GetArgoCDApplications(namespace string) (string, error)

func (c *K8sClient) GetConfigMaps(namespace string, names ...string) (string, error)

func (c *K8sClient) GetResourceAnnotation(gvr schema.GroupVersionResource, namespace string, name string, annotationKey string) (string, error)

GetResourceAnnotation retrieves a specific annotation from any Kubernetes resource

func (c *K8sClient) GetSecretValue(namespace string, name string, key string) (string, error)

get secret value from key. e.g. key: "password"

func (c *K8sClient) RemoveObstructiveFinalizers(namespace string) error

RemoveObstructiveFinalizers removes finalizers from applications that would prevent deletion

func (c *K8sClient) WaitForDeploymentReady(namespace, name string, timeoutSeconds int) error

WaitForDeploymentReady waits for a deployment to be available Equivalent to: kubectl wait --for=condition=available deployment/name