kubernetes

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

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

type KubernetesClient interface {
	// Resource operations
	GetResource(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
	ListResources(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error)
	ApplyResource(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, opts metav1.ApplyOptions) (*unstructured.Unstructured, error)
	DeleteResource(gvr schema.GroupVersionResource, namespace, name string, opts metav1.DeleteOptions) error
	PatchResource(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions) (*unstructured.Unstructured, error)
	CheckHealth(ctx context.Context, endpoint string) error
	// Node health operations
	GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error)
}

type KubernetesManager interface {
	Initialize() error
	ApplyKustomization(kustomization kustomizev1.Kustomization) error
	DeleteKustomization(name, namespace string) error
	WaitForKustomizations(message string, names ...string) error
	CreateNamespace(name string) error
	DeleteNamespace(name string) error
	ApplyConfigMap(name, namespace string, data map[string]string) error
	GetHelmReleasesForKustomization(name, namespace string) ([]helmv2.HelmRelease, error)
	SuspendKustomization(name, namespace string) error
	SuspendHelmRelease(name, namespace string) error
	ApplyGitRepository(repo *sourcev1.GitRepository) error
	ApplyOCIRepository(repo *sourcev1.OCIRepository) error
	CheckGitRepositoryStatus() error
	GetKustomizationStatus(names []string) (map[string]bool, error)
	WaitForKubernetesHealthy(ctx context.Context, endpoint string, outputFunc func(string), nodeNames ...string) error
	GetNodeReadyStatus(ctx context.Context, nodeNames []string) (map[string]bool, error)
}

type MockKubernetesClient struct {
	GetResourceFunc        func(gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
	ListResourcesFunc      func(gvr schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error)
	ApplyResourceFunc      func(gvr schema.GroupVersionResource, obj *unstructured.Unstructured, opts metav1.ApplyOptions) (*unstructured.Unstructured, error)
	DeleteResourceFunc     func(gvr schema.GroupVersionResource, namespace, name string, opts metav1.DeleteOptions) error
	PatchResourceFunc      func(gvr schema.GroupVersionResource, namespace, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions) (*unstructured.Unstructured, error)
	CheckHealthFunc        func(ctx context.Context, endpoint string) error
	GetNodeReadyStatusFunc func(ctx context.Context, nodeNames []string) (map[string]bool, error)
}

type MockKubernetesManager struct {
	InitializeFunc                      func() error
	ApplyKustomizationFunc              func(kustomization kustomizev1.Kustomization) error
	DeleteKustomizationFunc             func(name, namespace string) error
	WaitForKustomizationsFunc           func(message string, names ...string) error
	GetKustomizationStatusFunc          func(names []string) (map[string]bool, error)
	CreateNamespaceFunc                 func(name string) error
	DeleteNamespaceFunc                 func(name string) error
	ApplyConfigMapFunc                  func(name, namespace string, data map[string]string) error
	GetHelmReleasesForKustomizationFunc func(name, namespace string) ([]helmv2.HelmRelease, error)
	SuspendKustomizationFunc            func(name, namespace string) error
	SuspendHelmReleaseFunc              func(name, namespace string) error
	ApplyGitRepositoryFunc              func(repo *sourcev1.GitRepository) error
	ApplyOCIRepositoryFunc              func(repo *sourcev1.OCIRepository) error
	CheckGitRepositoryStatusFunc        func() error
	WaitForKubernetesHealthyFunc        func(ctx context.Context, endpoint string, outputFunc func(string), nodeNames ...string) error
	GetNodeReadyStatusFunc              func(ctx context.Context, nodeNames []string) (map[string]bool, error)
}

type Shims struct {
	// Other operations
	RegexpMatchString func(pattern string, s string) (bool, error)
	YamlMarshal       func(v any) ([]byte, error)
	YamlUnmarshal     func(data []byte, v any, opts ...yaml.JSONOpt) error
	K8sYamlUnmarshal  func(data []byte, v any, opts ...yaml.JSONOpt) error
	TimeSleep         func(d time.Duration)
	ToUnstructured    func(obj any) (map[string]any, error)
	FromUnstructured  func(obj map[string]any, target any) error
}