Versions in this module Expand all Collapse all v0 v0.7.3 Jul 29, 2026 Changes in this version + type ClusterCache struct + func NewClusterCache(t interface{ ... }) *ClusterCache + func (_m *ClusterCache) EXPECT() *ClusterCache_Expecter + func (_mock *ClusterCache) EnsureSynced() error + func (_mock *ClusterCache) FindResources(namespace string, predicates ...func(r *cache.Resource) bool) map[kube.ResourceKey]*cache.Resource + func (_mock *ClusterCache) GetAPIResources() []kube.APIResourceInfo + func (_mock *ClusterCache) GetClusterInfo() cache.ClusterInfo + func (_mock *ClusterCache) GetGVKParser() *managedfields.GvkParser + func (_mock *ClusterCache) GetManagedLiveObjs(targetObjs []*unstructured.Unstructured, ...) (map[kube.ResourceKey]*unstructured.Unstructured, error) + func (_mock *ClusterCache) GetOpenAPISchema() openapi.Resources + func (_mock *ClusterCache) GetServerVersion() string + func (_mock *ClusterCache) Invalidate(opts ...cache.UpdateSettingsFunc) + func (_mock *ClusterCache) IsNamespaced(gk schema.GroupKind) (bool, error) + func (_mock *ClusterCache) IterateHierarchyV2(keys []kube.ResourceKey, action func(resource *cache.Resource, ...) bool) + func (_mock *ClusterCache) OnEvent(handler cache.OnEventHandler) cache.Unsubscribe + func (_mock *ClusterCache) OnProcessEventsHandler(handler cache.OnProcessEventsHandler) cache.Unsubscribe + func (_mock *ClusterCache) OnResourceUpdated(handler cache.OnResourceUpdatedHandler) cache.Unsubscribe + type ClusterCache_EnsureSynced_Call struct + func (_c *ClusterCache_EnsureSynced_Call) Return(err error) *ClusterCache_EnsureSynced_Call + func (_c *ClusterCache_EnsureSynced_Call) Run(run func()) *ClusterCache_EnsureSynced_Call + func (_c *ClusterCache_EnsureSynced_Call) RunAndReturn(run func() error) *ClusterCache_EnsureSynced_Call + type ClusterCache_Expecter struct + func (_e *ClusterCache_Expecter) EnsureSynced() *ClusterCache_EnsureSynced_Call + func (_e *ClusterCache_Expecter) FindResources(namespace any, predicates ...any) *ClusterCache_FindResources_Call + func (_e *ClusterCache_Expecter) GetAPIResources() *ClusterCache_GetAPIResources_Call + func (_e *ClusterCache_Expecter) GetClusterInfo() *ClusterCache_GetClusterInfo_Call + func (_e *ClusterCache_Expecter) GetGVKParser() *ClusterCache_GetGVKParser_Call + func (_e *ClusterCache_Expecter) GetManagedLiveObjs(targetObjs any, isManaged any) *ClusterCache_GetManagedLiveObjs_Call + func (_e *ClusterCache_Expecter) GetOpenAPISchema() *ClusterCache_GetOpenAPISchema_Call + func (_e *ClusterCache_Expecter) GetServerVersion() *ClusterCache_GetServerVersion_Call + func (_e *ClusterCache_Expecter) Invalidate(opts ...any) *ClusterCache_Invalidate_Call + func (_e *ClusterCache_Expecter) IsNamespaced(gk any) *ClusterCache_IsNamespaced_Call + func (_e *ClusterCache_Expecter) IterateHierarchyV2(keys any, action any) *ClusterCache_IterateHierarchyV2_Call + func (_e *ClusterCache_Expecter) OnEvent(handler any) *ClusterCache_OnEvent_Call + func (_e *ClusterCache_Expecter) OnProcessEventsHandler(handler any) *ClusterCache_OnProcessEventsHandler_Call + func (_e *ClusterCache_Expecter) OnResourceUpdated(handler any) *ClusterCache_OnResourceUpdated_Call + type ClusterCache_FindResources_Call struct + func (_c *ClusterCache_FindResources_Call) Return(resourceKeyToResource map[kube.ResourceKey]*cache.Resource) *ClusterCache_FindResources_Call + func (_c *ClusterCache_FindResources_Call) Run(run func(namespace string, predicates ...func(r *cache.Resource) bool)) *ClusterCache_FindResources_Call + func (_c *ClusterCache_FindResources_Call) RunAndReturn(...) *ClusterCache_FindResources_Call + type ClusterCache_GetAPIResources_Call struct + func (_c *ClusterCache_GetAPIResources_Call) Return(aPIResourceInfos []kube.APIResourceInfo) *ClusterCache_GetAPIResources_Call + func (_c *ClusterCache_GetAPIResources_Call) Run(run func()) *ClusterCache_GetAPIResources_Call + func (_c *ClusterCache_GetAPIResources_Call) RunAndReturn(run func() []kube.APIResourceInfo) *ClusterCache_GetAPIResources_Call + type ClusterCache_GetClusterInfo_Call struct + func (_c *ClusterCache_GetClusterInfo_Call) Return(clusterInfo cache.ClusterInfo) *ClusterCache_GetClusterInfo_Call + func (_c *ClusterCache_GetClusterInfo_Call) Run(run func()) *ClusterCache_GetClusterInfo_Call + func (_c *ClusterCache_GetClusterInfo_Call) RunAndReturn(run func() cache.ClusterInfo) *ClusterCache_GetClusterInfo_Call + type ClusterCache_GetGVKParser_Call struct + func (_c *ClusterCache_GetGVKParser_Call) Return(gvkParser *managedfields.GvkParser) *ClusterCache_GetGVKParser_Call + func (_c *ClusterCache_GetGVKParser_Call) Run(run func()) *ClusterCache_GetGVKParser_Call + func (_c *ClusterCache_GetGVKParser_Call) RunAndReturn(run func() *managedfields.GvkParser) *ClusterCache_GetGVKParser_Call + type ClusterCache_GetManagedLiveObjs_Call struct + func (_c *ClusterCache_GetManagedLiveObjs_Call) Return(resourceKeyToUnstructured map[kube.ResourceKey]*unstructured.Unstructured, ...) *ClusterCache_GetManagedLiveObjs_Call + func (_c *ClusterCache_GetManagedLiveObjs_Call) Run(run func(targetObjs []*unstructured.Unstructured, ...)) *ClusterCache_GetManagedLiveObjs_Call + func (_c *ClusterCache_GetManagedLiveObjs_Call) RunAndReturn(...) *ClusterCache_GetManagedLiveObjs_Call + type ClusterCache_GetOpenAPISchema_Call struct + func (_c *ClusterCache_GetOpenAPISchema_Call) Return(resources openapi.Resources) *ClusterCache_GetOpenAPISchema_Call + func (_c *ClusterCache_GetOpenAPISchema_Call) Run(run func()) *ClusterCache_GetOpenAPISchema_Call + func (_c *ClusterCache_GetOpenAPISchema_Call) RunAndReturn(run func() openapi.Resources) *ClusterCache_GetOpenAPISchema_Call + type ClusterCache_GetServerVersion_Call struct + func (_c *ClusterCache_GetServerVersion_Call) Return(s string) *ClusterCache_GetServerVersion_Call + func (_c *ClusterCache_GetServerVersion_Call) Run(run func()) *ClusterCache_GetServerVersion_Call + func (_c *ClusterCache_GetServerVersion_Call) RunAndReturn(run func() string) *ClusterCache_GetServerVersion_Call + type ClusterCache_Invalidate_Call struct + func (_c *ClusterCache_Invalidate_Call) Return() *ClusterCache_Invalidate_Call + func (_c *ClusterCache_Invalidate_Call) Run(run func(opts ...cache.UpdateSettingsFunc)) *ClusterCache_Invalidate_Call + func (_c *ClusterCache_Invalidate_Call) RunAndReturn(run func(opts ...cache.UpdateSettingsFunc)) *ClusterCache_Invalidate_Call + type ClusterCache_IsNamespaced_Call struct + func (_c *ClusterCache_IsNamespaced_Call) Return(b bool, err error) *ClusterCache_IsNamespaced_Call + func (_c *ClusterCache_IsNamespaced_Call) Run(run func(gk schema.GroupKind)) *ClusterCache_IsNamespaced_Call + func (_c *ClusterCache_IsNamespaced_Call) RunAndReturn(run func(gk schema.GroupKind) (bool, error)) *ClusterCache_IsNamespaced_Call + type ClusterCache_IterateHierarchyV2_Call struct + func (_c *ClusterCache_IterateHierarchyV2_Call) Return() *ClusterCache_IterateHierarchyV2_Call + func (_c *ClusterCache_IterateHierarchyV2_Call) Run(...) *ClusterCache_IterateHierarchyV2_Call + func (_c *ClusterCache_IterateHierarchyV2_Call) RunAndReturn(...) *ClusterCache_IterateHierarchyV2_Call + type ClusterCache_OnEvent_Call struct + func (_c *ClusterCache_OnEvent_Call) Return(unsubscribe cache.Unsubscribe) *ClusterCache_OnEvent_Call + func (_c *ClusterCache_OnEvent_Call) Run(run func(handler cache.OnEventHandler)) *ClusterCache_OnEvent_Call + func (_c *ClusterCache_OnEvent_Call) RunAndReturn(run func(handler cache.OnEventHandler) cache.Unsubscribe) *ClusterCache_OnEvent_Call + type ClusterCache_OnProcessEventsHandler_Call struct + func (_c *ClusterCache_OnProcessEventsHandler_Call) Return(unsubscribe cache.Unsubscribe) *ClusterCache_OnProcessEventsHandler_Call + func (_c *ClusterCache_OnProcessEventsHandler_Call) Run(run func(handler cache.OnProcessEventsHandler)) *ClusterCache_OnProcessEventsHandler_Call + func (_c *ClusterCache_OnProcessEventsHandler_Call) RunAndReturn(run func(handler cache.OnProcessEventsHandler) cache.Unsubscribe) *ClusterCache_OnProcessEventsHandler_Call + type ClusterCache_OnResourceUpdated_Call struct + func (_c *ClusterCache_OnResourceUpdated_Call) Return(unsubscribe cache.Unsubscribe) *ClusterCache_OnResourceUpdated_Call + func (_c *ClusterCache_OnResourceUpdated_Call) Run(run func(handler cache.OnResourceUpdatedHandler)) *ClusterCache_OnResourceUpdated_Call + func (_c *ClusterCache_OnResourceUpdated_Call) RunAndReturn(run func(handler cache.OnResourceUpdatedHandler) cache.Unsubscribe) *ClusterCache_OnResourceUpdated_Call
Go to main page