var _ … type metaRuntimeInterface … type serializationResult … type serializationsCache … type cachingObject … // newCachingObject performs a deep copy of the given object and wraps it // into a cachingObject. // An error is returned if it's not possible to cast the object to // metav1.Object type. func newCachingObject(object runtime.Object) (*cachingObject, error) { … } func (o *cachingObject) getSerializationResult(id runtime.Identifier) *serializationResult { … } // CacheEncode implements runtime.CacheableObject interface. // It serializes the object and writes the result to given io.Writer trying // to first use the already cached result and falls back to a given encode // function in case of cache miss. // It assumes that for a given identifier, the encode function always encodes // each input object into the same output format. func (o *cachingObject) CacheEncode(id runtime.Identifier, encode func(runtime.Object, io.Writer) error, w io.Writer) error { … } // GetObject implements runtime.CacheableObject interface. // It returns deep-copy of the wrapped object to return ownership of it // to the called according to the contract of the interface. func (o *cachingObject) GetObject() runtime.Object { … } // GetObjectKind implements runtime.Object interface. func (o *cachingObject) GetObjectKind() schema.ObjectKind { … } // DeepCopyObject implements runtime.Object interface. func (o *cachingObject) DeepCopyObject() runtime.Object { … } var invalidationCacheTimestampLock … var invalidationCacheTimestamp … // shouldLogCacheInvalidation allows for logging cache-invalidation // at most once per second (to avoid spamming logs in case of issues). func shouldLogCacheInvalidation(now time.Time) bool { … } func (o *cachingObject) invalidateCacheLocked() { … } func (o *cachingObject) conditionalSet(isNoop func() bool, set func()) { … } func (o *cachingObject) GetNamespace() string { … } func (o *cachingObject) SetNamespace(namespace string) { … } func (o *cachingObject) GetName() string { … } func (o *cachingObject) SetName(name string) { … } func (o *cachingObject) GetGenerateName() string { … } func (o *cachingObject) SetGenerateName(name string) { … } func (o *cachingObject) GetUID() types.UID { … } func (o *cachingObject) SetUID(uid types.UID) { … } func (o *cachingObject) GetResourceVersion() string { … } func (o *cachingObject) SetResourceVersion(version string) { … } func (o *cachingObject) GetGeneration() int64 { … } func (o *cachingObject) SetGeneration(generation int64) { … } func (o *cachingObject) GetSelfLink() string { … } func (o *cachingObject) SetSelfLink(selfLink string) { … } func (o *cachingObject) GetCreationTimestamp() metav1.Time { … } func (o *cachingObject) SetCreationTimestamp(timestamp metav1.Time) { … } func (o *cachingObject) GetDeletionTimestamp() *metav1.Time { … } func (o *cachingObject) SetDeletionTimestamp(timestamp *metav1.Time) { … } func (o *cachingObject) GetDeletionGracePeriodSeconds() *int64 { … } func (o *cachingObject) SetDeletionGracePeriodSeconds(gracePeriodSeconds *int64) { … } func (o *cachingObject) GetLabels() map[string]string { … } func (o *cachingObject) SetLabels(labels map[string]string) { … } func (o *cachingObject) GetAnnotations() map[string]string { … } func (o *cachingObject) SetAnnotations(annotations map[string]string) { … } func (o *cachingObject) GetFinalizers() []string { … } func (o *cachingObject) SetFinalizers(finalizers []string) { … } func (o *cachingObject) GetOwnerReferences() []metav1.OwnerReference { … } func (o *cachingObject) SetOwnerReferences(references []metav1.OwnerReference) { … } func (o *cachingObject) GetManagedFields() []metav1.ManagedFieldsEntry { … } func (o *cachingObject) SetManagedFields(managedFields []metav1.ManagedFieldsEntry) { … }
Codebase Browser
kubernetes