kubernetes

package

Go to main page

Versions in this module

v0

v0.9.0

Aug 4, 2026

Changes in this version

+ const VersionMarkerConfigMapName

+ const VersionMarkerPhaseIdle

+ const VersionMarkerPhaseUpgrading

+ func SourcesEqual(a, b map[string]SourceRef) bool

type BaseKubernetesManager

+ func (k *BaseKubernetesManager) ApplySecret(name, namespace string, stringData map[string]string, owner string) error

+ func (k *BaseKubernetesManager) ApplyVersionMarker(namespace string, marker VersionMarker) error

+ func (k *BaseKubernetesManager) GetKustomizationInventory(name, namespace string) ([]InventoryEntry, error)

+ func (k *BaseKubernetesManager) GetKustomizationReadiness(names []string) (map[string]bool, error)

+ func (k *BaseKubernetesManager) GetVersionMarker(namespace string) (VersionMarker, bool, error)

+ func (k *BaseKubernetesManager) KustomizationExists(name, namespace string) (bool, error)

+ func (k *BaseKubernetesManager) ListPrunableKustomizations(blueprint *blueprintv1alpha1.Blueprint, namespace string) ([]string, error)

+ func (k *BaseKubernetesManager) NamespaceExists(name string) (bool, error)

+ func (k *BaseKubernetesManager) PruneBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace string) error

+ func (k *BaseKubernetesManager) PruneSecrets(desired map[string]map[string]bool) error

+ func (k *BaseKubernetesManager) RollWorkloadsForSecret(ctx context.Context, namespace, secretName, digest string) error

+ type InventoryEntry struct

+ Group string

+ Kind string

+ Name string

+ Namespace string

type KubernetesManager

+ ApplySecret func(name, namespace string, stringData map[string]string, owner string) error

+ ApplyVersionMarker func(namespace string, marker VersionMarker) error

+ GetKustomizationInventory func(name, namespace string) ([]InventoryEntry, error)

+ GetKustomizationReadiness func(names []string) (map[string]bool, error)

+ GetVersionMarker func(namespace string) (VersionMarker, bool, error)

+ KustomizationExists func(name, namespace string) (bool, error)

+ ListPrunableKustomizations func(blueprint *blueprintv1alpha1.Blueprint, namespace string) ([]string, error)

+ NamespaceExists func(name string) (bool, error)

+ PruneBlueprint func(blueprint *blueprintv1alpha1.Blueprint, namespace string) error

+ PruneSecrets func(desired map[string]map[string]bool) error

+ RollWorkloadsForSecret func(ctx context.Context, namespace, secretName, digest string) error

type MockKubernetesManager

+ ApplySecretFunc func(name, namespace string, stringData map[string]string, owner string) error

+ ApplyVersionMarkerFunc func(namespace string, marker VersionMarker) error

+ GetKustomizationInventoryFunc func(name, namespace string) ([]InventoryEntry, error)

+ GetKustomizationReadinessFunc func(names []string) (map[string]bool, error)

+ GetVersionMarkerFunc func(namespace string) (VersionMarker, bool, error)

+ KustomizationExistsFunc func(name, namespace string) (bool, error)

+ ListPrunableKustomizationsFunc func(blueprint *blueprintv1alpha1.Blueprint, namespace string) ([]string, error)

+ NamespaceExistsFunc func(name string) (bool, error)

+ PruneBlueprintFunc func(blueprint *blueprintv1alpha1.Blueprint, namespace string) error

+ PruneSecretsFunc func(desired map[string]map[string]bool) error

+ RollWorkloadsForSecretFunc func(ctx context.Context, namespace, secretName, digest string) error

+ func (m *MockKubernetesManager) ApplySecret(name, namespace string, stringData map[string]string, owner string) error

+ func (m *MockKubernetesManager) ApplyVersionMarker(namespace string, marker VersionMarker) error

+ func (m *MockKubernetesManager) GetKustomizationInventory(name, namespace string) ([]InventoryEntry, error)

+ func (m *MockKubernetesManager) GetKustomizationReadiness(names []string) (map[string]bool, error)

+ func (m *MockKubernetesManager) GetVersionMarker(namespace string) (VersionMarker, bool, error)

+ func (m *MockKubernetesManager) KustomizationExists(name, namespace string) (bool, error)

+ func (m *MockKubernetesManager) ListPrunableKustomizations(blueprint *blueprintv1alpha1.Blueprint, namespace string) ([]string, error)

+ func (m *MockKubernetesManager) NamespaceExists(name string) (bool, error)

+ func (m *MockKubernetesManager) PruneBlueprint(blueprint *blueprintv1alpha1.Blueprint, namespace string) error

+ func (m *MockKubernetesManager) PruneSecrets(desired map[string]map[string]bool) error

+ func (m *MockKubernetesManager) RollWorkloadsForSecret(ctx context.Context, namespace, secretName, digest string) error

+ type SourceRef struct

+ Ref string

+ URL string

+ type VersionMarker struct

+ AppliedSources map[string]SourceRef

+ Phase string

+ SchemaVersion int

+ TargetSources map[string]SourceRef

+ func BuildTransitionMarker(applied map[string]SourceRef, blueprint *blueprintv1alpha1.Blueprint) (VersionMarker, error)

+ func BuildVersionMarker(blueprint *blueprintv1alpha1.Blueprint) (VersionMarker, error)

+ func ParseVersionMarker(data map[string]string) (VersionMarker, bool, error)

+ func (m VersionMarker) ToConfigMapData() (map[string]string, error)

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL