kubernetes/pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go

type ClusterRoleAggregationController …

// NewClusterRoleAggregation creates a new controller
func NewClusterRoleAggregation(clusterRoleInformer rbacinformers.ClusterRoleInformer, clusterRoleClient rbacclient.ClusterRolesGetter) *ClusterRoleAggregationController { … }

func (c *ClusterRoleAggregationController) syncClusterRole(ctx context.Context, key string) error { … }

func (c *ClusterRoleAggregationController) applyClusterRoles(ctx context.Context, name string, newPolicyRules []rbacv1.PolicyRule) error { … }

func (c *ClusterRoleAggregationController) updateClusterRoles(ctx context.Context, sharedClusterRole *rbacv1.ClusterRole, newPolicyRules []rbacv1.PolicyRule) error { … }

func toApplyPolicyRules(rules []rbacv1.PolicyRule) []*rbacv1ac.PolicyRuleApplyConfiguration { … }

func toApplyPolicyRule(rule rbacv1.PolicyRule) *rbacv1ac.PolicyRuleApplyConfiguration { … }

func ruleExists(haystack []rbacv1.PolicyRule, needle rbacv1.PolicyRule) bool { … }

// Run starts the controller and blocks until stopCh is closed.
func (c *ClusterRoleAggregationController) Run(ctx context.Context, workers int) { … }

func (c *ClusterRoleAggregationController) runWorker(ctx context.Context) { … }

func (c *ClusterRoleAggregationController) processNextWorkItem(ctx context.Context) bool { … }

func (c *ClusterRoleAggregationController) enqueue() { … }

type byName …

func (a byName) Len() int           { … }

func (a byName) Swap(i, j int)      { … }

func (a byName) Less(i, j int) bool { … }