Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for StartManagerSync (0.13 sec)

  1. pkg/kubelet/runtimeclass/testing/fake_manager.go

    		NewRuntimeClass(SandboxRuntimeClass, SandboxRuntimeHandler),
    	)
    }
    
    // StartManagerSync starts the manager, and waits for the informer cache to sync.
    // Returns a function to stop the manager, which should be called with a defer:
    //
    //	defer StartManagerSync(t, m)()
    func StartManagerSync(m *runtimeclass.Manager) func() {
    	stopCh := make(chan struct{})
    	m.Start(stopCh)
    	m.WaitForCacheSync(stopCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  2. pkg/kubelet/runtimeclass/runtimeclass_manager_test.go

    		{rcn: pointer.String(rctest.SandboxRuntimeClass), expected: "kata-containers"},
    		{rcn: pointer.String("phantom"), expectError: true},
    	}
    
    	manager := runtimeclass.NewManager(rctest.NewPopulatedClient())
    	defer rctest.StartManagerSync(manager)()
    
    	for _, test := range tests {
    		tname := "nil"
    		if test.rcn != nil {
    			tname = *test.rcn
    		}
    		t.Run(fmt.Sprintf("%q->%q(err:%v)", tname, test.expected, test.expectError), func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 08 12:44:09 UTC 2023
    - 1.7K bytes
    - Viewed (0)
Back to top