k8s

Mar 5, 2026

Changes in this version

+ func GetKubeConfigPath() (string, bool)

+ type Client struct

+ func NewClient(disableClientThrottling bool) (*Client, error)

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

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

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

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

+ func (c *Client) CreateNamespace(namespace string) (bool, error)

+ func (c *Client) DeleteAllApplicationsOlderThan(namespace string, minutes int) error

+ func (c *Client) DeleteArgoCDApplication(namespace string, name string) error

+ func (c *Client) DeleteArgoCDApplications(namespace string) error

+ func (c *Client) GetArgoCDApplication(namespace string, name string) (*v1alpha1.Application, error)

+ func (c *Client) GetConfig() *rest.Config

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

+ func (c *Client) GetListOfNamespacedScopedResources() (map[schema.GroupKind]bool, error)

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

+ func (c *Client) GetServiceNameByLabel(namespace, labelSelector string) (string, error)

+ func (c *Client) PortForwardToPod(namespace, podName string, localPort, remotePort int, readyChan chan struct{}, ...) error

+ func (c *Client) PortForwardToService(namespace, serviceName string, localPort, remotePort int, ...) error

+ func (c *Client) RemoveObstructiveFinalizers(namespace string) error

+ func (c *Client) SetArgoCDAppRefreshAnnotation(namespace string, name string) error

+ func (c *Client) WaitForDeploymentReady(namespace, labelSelector string, timeoutSeconds int) error

+ func (c *Client) WatchForContainerRestarts(namespace, labelSelector string, pollInterval time.Duration) chan struct{}

+ type CrashEvent struct

+ ContainerName string

+ CurrRestarts int32

+ EventType string

+ PodName string

+ PrevRestarts int32

+ type CrashWatcherState struct

+ CrashLoopReported map[string]bool

+ RestartCounts map[string]int32

+ func NewCrashWatcherState() *CrashWatcherState

+ func (s *CrashWatcherState) DetectCrashEvents(pods []corev1.Pod) []CrashEvent

Apr 14, 2025

Changes in this version

+ func GetYamlFiles(directory string, fileRegex *string) []string

+ type Resource struct

+ FileName string

+ Yaml yaml.Node

+ func ParseYaml(dir string, files []string) []Resource