type ResourceInfo … type Manager … var _ … type defaultManager … type updateStatus … // NewDefaultManager creates a new defaultManager. func NewDefaultManager() Manager { … } // AddResourceInfo adds ResourceInfo to the manager. func (s *defaultManager) AddResourceInfo(resources ...*ResourceInfo) { … } func (s *defaultManager) addPendingManagedStatusLocked(r *ResourceInfo) { … } // UpdateStorageVersions tries to update the StorageVersions of the recorded resources func (s *defaultManager) UpdateStorageVersions(kubeAPIServerClientConfig *rest.Config, serverID string) { … } // dedupResourceInfos dedups ResourceInfos with the same underlying storage. // ResourceInfos from the same Group with different Versions share the same underlying storage. // ResourceInfos from different Groups may share the same underlying storage, e.g. // networking.k8s.io ingresses and extensions ingresses. The StorageVersion manager // only needs to update one StorageVersion for the equivalent Groups. func dedupResourceInfos(infos []ResourceInfo) []ResourceInfo { … } func sortResourceInfosByGroupResource(infos []ResourceInfo) { … } type byGroupResource … func (s byGroupResource) Len() int { … } func (s byGroupResource) Less(i, j int) bool { … } func (s byGroupResource) Swap(i, j int) { … } // recordStatusSuccess marks updated ResourceInfo as completed. func (s *defaultManager) recordStatusSuccess(r *ResourceInfo) { … } func (s *defaultManager) recordStatusSuccessLocked(r *ResourceInfo) { … } func (s *defaultManager) recordSuccessGroupResourceLocked(gr schema.GroupResource) { … } // recordStatusFailure records latest error updating ResourceInfo. func (s *defaultManager) recordStatusFailure(r *ResourceInfo, err error) { … } func (s *defaultManager) recordStatusFailureLocked(r *ResourceInfo, err error) { … } func (s *defaultManager) recordErrorGroupResourceLocked(gr schema.GroupResource, err error) { … } // PendingUpdate returns if the StorageVersion of a resource is still wait to be updated. func (s *defaultManager) PendingUpdate(gr schema.GroupResource) bool { … } // LastUpdateError returns the last error hit when updating the storage version of the given resource. func (s *defaultManager) LastUpdateError(gr schema.GroupResource) error { … } // setComplete marks the completion of updating StorageVersions. No write requests need to be blocked anymore. func (s *defaultManager) setComplete() { … } // Completed returns if updating StorageVersions has completed. func (s *defaultManager) Completed() bool { … } func decodableVersions(directlyDecodableVersions []schema.GroupVersion, e runtime.EquivalentResourceRegistry, gr schema.GroupResource) []string { … }
Codebase Browser
kubernetes