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 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 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)