Versions in this module Expand all Collapse all v0 v0.7.1 Jul 30, 2025 v0.7.0 Jul 27, 2025 Changes in this version + type BaseKubernetesManager struct + func NewKubernetesManager(injector di.Injector) *BaseKubernetesManager + func (k *BaseKubernetesManager) ApplyConfigMap(name, namespace string, data map[string]string) error + func (k *BaseKubernetesManager) ApplyGitRepository(repo *sourcev1.GitRepository) error + func (k *BaseKubernetesManager) ApplyKustomization(kustomization kustomizev1.Kustomization) error + func (k *BaseKubernetesManager) ApplyOCIRepository(repo *sourcev1.OCIRepository) error + func (k *BaseKubernetesManager) CheckGitRepositoryStatus() error + func (k *BaseKubernetesManager) CreateNamespace(name string) error + func (k *BaseKubernetesManager) DeleteKustomization(name, namespace string) error + func (k *BaseKubernetesManager) DeleteNamespace(name string) error + func (k *BaseKubernetesManager) GetHelmReleasesForKustomization(name, namespace string) ([]helmv2.HelmRelease, error) + func (k *BaseKubernetesManager) GetKustomizationStatus(names []string) (map[string]bool, error) + func (k *BaseKubernetesManager) GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error) + func (k *BaseKubernetesManager) Initialize() error + func (k *BaseKubernetesManager) SuspendHelmRelease(name, namespace string) error + func (k *BaseKubernetesManager) SuspendKustomization(name, namespace string) error + func (k *BaseKubernetesManager) WaitForKubernetesHealthy(ctx context.Context, endpoint string, outputFunc func(string), ...) error + func (k *BaseKubernetesManager) WaitForKustomizations(message string, names ...string) error + type DynamicKubernetesClient struct + func NewDynamicKubernetesClient() *DynamicKubernetesClient + func (c *DynamicKubernetesClient) ApplyResource(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error) + func (c *DynamicKubernetesClient) CheckHealth(ctx context.Context, endpoint string) error + func (c *DynamicKubernetesClient) DeleteResource(gvr schema.GroupVersionResource, namespace, name string, ...) error + func (c *DynamicKubernetesClient) GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error) + func (c *DynamicKubernetesClient) GetResource(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error) + func (c *DynamicKubernetesClient) ListResources(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error) + func (c *DynamicKubernetesClient) PatchResource(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, ...) (*unstructured.Unstructured, error) + type KubernetesClient interface + ApplyResource func(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error) + CheckHealth func(ctx context.Context, endpoint string) error + DeleteResource func(gvr schema.GroupVersionResource, namespace, name string, ...) error + GetNodeReadyStatus func(ctx context.Context, nodeNames []string) (map[string]bool, error) + GetResource func(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error) + ListResources func(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error) + PatchResource func(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, ...) (*unstructured.Unstructured, error) + type KubernetesManager interface + ApplyConfigMap func(name, namespace string, data map[string]string) error + ApplyGitRepository func(repo *sourcev1.GitRepository) error + ApplyKustomization func(kustomization kustomizev1.Kustomization) error + ApplyOCIRepository func(repo *sourcev1.OCIRepository) error + CheckGitRepositoryStatus func() error + CreateNamespace func(name string) error + DeleteKustomization func(name, namespace string) error + DeleteNamespace func(name string) error + GetHelmReleasesForKustomization func(name, namespace string) ([]helmv2.HelmRelease, error) + GetKustomizationStatus func(names []string) (map[string]bool, error) + GetNodeReadyStatus func(ctx context.Context, nodeNames []string) (map[string]bool, error) + Initialize func() error + SuspendHelmRelease func(name, namespace string) error + SuspendKustomization func(name, namespace string) error + WaitForKubernetesHealthy func(ctx context.Context, endpoint string, outputFunc func(string), ...) error + WaitForKustomizations func(message string, names ...string) error + type MockKubernetesClient struct + ApplyResourceFunc func(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error) + CheckHealthFunc func(ctx context.Context, endpoint string) error + DeleteResourceFunc func(gvr schema.GroupVersionResource, namespace, name string, ...) error + GetNodeReadyStatusFunc func(ctx context.Context, nodeNames []string) (map[string]bool, error) + GetResourceFunc func(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error) + ListResourcesFunc func(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error) + PatchResourceFunc func(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, ...) (*unstructured.Unstructured, error) + func NewMockKubernetesClient() *MockKubernetesClient + func (m *MockKubernetesClient) ApplyResource(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error) + func (m *MockKubernetesClient) CheckHealth(ctx context.Context, endpoint string) error + func (m *MockKubernetesClient) DeleteResource(gvr schema.GroupVersionResource, namespace, name string, ...) error + func (m *MockKubernetesClient) GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error) + func (m *MockKubernetesClient) GetResource(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error) + func (m *MockKubernetesClient) ListResources(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error) + func (m *MockKubernetesClient) PatchResource(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, ...) (*unstructured.Unstructured, error) + type MockKubernetesManager struct + ApplyConfigMapFunc func(name, namespace string, data map[string]string) error + ApplyGitRepositoryFunc func(repo *sourcev1.GitRepository) error + ApplyKustomizationFunc func(kustomization kustomizev1.Kustomization) error + ApplyOCIRepositoryFunc func(repo *sourcev1.OCIRepository) error + CheckGitRepositoryStatusFunc func() error + CreateNamespaceFunc func(name string) error + DeleteKustomizationFunc func(name, namespace string) error + DeleteNamespaceFunc func(name string) error + GetHelmReleasesForKustomizationFunc func(name, namespace string) ([]helmv2.HelmRelease, error) + GetKustomizationStatusFunc func(names []string) (map[string]bool, error) + GetNodeReadyStatusFunc func(ctx context.Context, nodeNames []string) (map[string]bool, error) + InitializeFunc func() error + SuspendHelmReleaseFunc func(name, namespace string) error + SuspendKustomizationFunc func(name, namespace string) error + WaitForKubernetesHealthyFunc func(ctx context.Context, endpoint string, outputFunc func(string), ...) error + WaitForKustomizationsFunc func(message string, names ...string) error + func NewMockKubernetesManager(injector di.Injector) *MockKubernetesManager + func (m *MockKubernetesManager) ApplyConfigMap(name, namespace string, data map[string]string) error + func (m *MockKubernetesManager) ApplyGitRepository(repo *sourcev1.GitRepository) error + func (m *MockKubernetesManager) ApplyKustomization(kustomization kustomizev1.Kustomization) error + func (m *MockKubernetesManager) ApplyOCIRepository(repo *sourcev1.OCIRepository) error + func (m *MockKubernetesManager) CheckGitRepositoryStatus() error + func (m *MockKubernetesManager) CreateNamespace(name string) error + func (m *MockKubernetesManager) DeleteKustomization(name, namespace string) error + func (m *MockKubernetesManager) DeleteNamespace(name string) error + func (m *MockKubernetesManager) GetHelmReleasesForKustomization(name, namespace string) ([]helmv2.HelmRelease, error) + func (m *MockKubernetesManager) GetKustomizationStatus(names []string) (map[string]bool, error) + func (m *MockKubernetesManager) GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error) + func (m *MockKubernetesManager) Initialize() error + func (m *MockKubernetesManager) SuspendHelmRelease(name, namespace string) error + func (m *MockKubernetesManager) SuspendKustomization(name, namespace string) error + func (m *MockKubernetesManager) WaitForKubernetesHealthy(ctx context.Context, endpoint string, outputFunc func(string), ...) error + func (m *MockKubernetesManager) WaitForKustomizations(message string, names ...string) error + type Shims struct + FromUnstructured func(obj map[string]any, target any) error + K8sYamlUnmarshal func(data []byte, v any, opts ...yaml.JSONOpt) error + RegexpMatchString func(pattern string, s string) (bool, error) + TimeSleep func(d time.Duration) + ToUnstructured func(obj any) (map[string]any, error) + YamlMarshal func(v any) ([]byte, error) + YamlUnmarshal func(data []byte, v any, opts ...yaml.JSONOpt) error + func NewShims() *Shims
Go to main page