kubernetes/pkg/registry/rbac/rest/storage_rbac.go

const PostStartHookName …

type RESTStorageProvider …

var _ …

func (p RESTStorageProvider) NewRESTStorage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (genericapiserver.APIGroupInfo, error) { … }

func (p RESTStorageProvider) storage(version schema.GroupVersion, apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (map[string]rest.Storage, error) { … }

func (p RESTStorageProvider) PostStartHook() (string, genericapiserver.PostStartHookFunc, error) { … }

type PolicyData …

func isConflictOrServiceUnavailable(err error) bool { … }

func retryOnConflictOrServiceUnavailable(backoff wait.Backoff, fn func() error) error { … }

func (p *PolicyData) EnsureRBACPolicy() genericapiserver.PostStartHookFunc { … }

func ensureRBACPolicy(p *PolicyData, client clientset.Interface) (done bool, err error) { … }

func (p RESTStorageProvider) GroupName() string { … }

// primeAggregatedClusterRoles copies roles that have transitioned to aggregated roles and may need to pick up changes
// that were done to the legacy roles.
func primeAggregatedClusterRoles(clusterRolesToAggregate map[string]string, clusterRoleClient rbacv1client.ClusterRolesGetter) error { … }

// primeSplitClusterRoleBindings ensures the existence of target ClusterRoleBindings
// by copying Subjects, Annotations, and Labels from the specified source
// ClusterRoleBinding, if present.
func primeSplitClusterRoleBindings(clusterRoleBindingToSplit map[string]rbacapiv1.ClusterRoleBinding, clusterRoleBindingClient rbacv1client.ClusterRoleBindingsGetter) error { … }