Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DefaultWatchReactor (0.39 sec)

  1. pkg/volume/csi/csi_attacher_test.go

    			plug, tmpDir := newTestPlugin(t, fakeClient)
    			defer os.RemoveAll(tmpDir)
    
    			fakeWatcher := watch.NewRaceFreeFake()
    			fakeClient.Fake.PrependWatchReactor("volumeattachments", core.DefaultWatchReactor(fakeWatcher, nil))
    
    			attacher, err := plug.NewAttacher()
    			if err != nil {
    				t.Fatalf("failed to create new attacher: %v", err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
  2. pkg/controller/replicaset/replica_set_test.go

    		}
    	}
    }
    
    func TestWatchControllers(t *testing.T) {
    
    	fakeWatch := watch.NewFake()
    	client := fake.NewSimpleClientset()
    	client.PrependWatchReactor("replicasets", core.DefaultWatchReactor(fakeWatch, nil))
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    	informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc())
    	tCtx := ktesting.Init(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
Back to top