- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for StartManagerSync (0.24 sec)
-
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) -
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) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox_test.go
func TestCreatePodSandbox_RuntimeClass(t *testing.T) { ctx := context.Background() rcm := runtimeclass.NewManager(rctest.NewPopulatedClient()) defer rctest.StartManagerSync(rcm)() fakeRuntime, _, m, err := createTestRuntimeManager() require.NoError(t, err) m.runtimeClassManager = rcm tests := map[string]struct { rcn *string expectedHandler string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.3K bytes - Viewed (0)