Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for syncClusterRole (0.14 sec)

  1. pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go

    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "ClusterRoleAggregator",
    			},
    		),
    	}
    	c.syncHandler = c.syncClusterRole
    
    	clusterRoleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    		UpdateFunc: func(old, cur interface{}) {
    			c.enqueue()
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. pkg/controller/clusterroleaggregation/clusterroleaggregation_controller_test.go

    				})
    				c := ClusterRoleAggregationController{
    					clusterRoleClient: fakeClient.RbacV1(),
    					clusterRoleLister: rbaclisters.NewClusterRoleLister(indexer),
    				}
    				err := c.syncClusterRole(context.TODO(), test.clusterRoleToSync)
    				if err != nil {
    					t.Fatal(err)
    				}
    
    				if test.expectedClusterRoleApply == nil {
    					if len(fakeClient.Actions()) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 9K bytes
    - Viewed (0)
Back to top