kubernetes/staging/src/k8s.io/client-go/discovery/cached/memory/memcache.go

type cacheEntry …

type memCacheClient …

var ErrCacheNotFound …

type emptyResponseError …

func (e *emptyResponseError) Error() string { … }

var _ …

// isTransientConnectionError checks whether given error is "Connection refused" or
// "Connection reset" error which usually means that apiserver is temporarily
// unavailable.
func isTransientConnectionError(err error) bool { … }

func isTransientError(err error) bool { … }

// ServerResourcesForGroupVersion returns the supported resources for a group and version.
func (d *memCacheClient) ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error) { … }

// ServerGroupsAndResources returns the groups and supported resources for all groups and versions.
func (d *memCacheClient) ServerGroupsAndResources() ([]*metav1.APIGroup, []*metav1.APIResourceList, error) { … }

// GroupsAndMaybeResources returns the list of APIGroups, and possibly the map of group/version
// to resources. The returned groups will never be nil, but the resources map can be nil
// if there are no cached resources.
func (d *memCacheClient) GroupsAndMaybeResources() (*metav1.APIGroupList, map[schema.GroupVersion]*metav1.APIResourceList, map[schema.GroupVersion]error, error) { … }

func (d *memCacheClient) ServerGroups() (*metav1.APIGroupList, error) { … }

func (d *memCacheClient) RESTClient() restclient.Interface { … }

func (d *memCacheClient) ServerPreferredResources() ([]*metav1.APIResourceList, error) { … }

func (d *memCacheClient) ServerPreferredNamespacedResources() ([]*metav1.APIResourceList, error) { … }

func (d *memCacheClient) ServerVersion() (*version.Info, error) { … }

func (d *memCacheClient) OpenAPISchema() (*openapi_v2.Document, error) { … }

func (d *memCacheClient) OpenAPIV3() openapi.Client { … }

func (d *memCacheClient) Fresh() bool { … }

// Invalidate enforces that no cached data that is older than the current time
// is used.
func (d *memCacheClient) Invalidate() { … }

// refreshLocked refreshes the state of cache. The caller must hold d.lock for
// writing.
func (d *memCacheClient) refreshLocked() error { … }

func (d *memCacheClient) serverResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error) { … }

// WithLegacy returns current memory-cached discovery client;
// current client does not support legacy-only discovery.
func (d *memCacheClient) WithLegacy() discovery.DiscoveryInterface { … }

// NewMemCacheClient creates a new CachedDiscoveryInterface which caches
// discovery information in memory and will stay up-to-date if Invalidate is
// called with regularity.
//
// NOTE: The client will NOT resort to live lookups on cache misses.
func NewMemCacheClient(delegate discovery.DiscoveryInterface) discovery.CachedDiscoveryInterface { … }