Versions in this module Expand all Collapse all v0 v0.8.1 Dec 12, 2025 v0.8.0 Dec 2, 2025 Changes in this version + type BaseKubernetesManager struct + func NewKubernetesManager(kubernetesClient client.KubernetesClient) *BaseKubernetesManager + func (k *BaseKubernetesManager) ApplyBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace string) error + 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) DeleteBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace 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) 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, blueprint *blueprintv1alpha1.Blueprint) error + type KubernetesManager interface + ApplyBlueprint func(blueprint *blueprintv1alpha1.Blueprint, namespace string) error + 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 + DeleteBlueprint func(blueprint *blueprintv1alpha1.Blueprint, namespace 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) + 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, blueprint *blueprintv1alpha1.Blueprint) error + type MockKubernetesManager struct + ApplyBlueprintFunc func(blueprint *blueprintv1alpha1.Blueprint, namespace string) error + 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 + DeleteBlueprintFunc func(blueprint *blueprintv1alpha1.Blueprint, namespace 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) + 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, blueprint *blueprintv1alpha1.Blueprint) error + func NewMockKubernetesManager() *MockKubernetesManager + func (m *MockKubernetesManager) ApplyBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace string) error + 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) DeleteBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace 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) 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, blueprint *blueprintv1alpha1.Blueprint) 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