- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RegisterNodeServer (0.43 sec)
-
pkg/kubelet/cm/dra/plugin/client_test.go
if err != nil { teardown() return "", nil, err } s := grpc.NewServer() switch version { case v1alpha3Version: fakeGRPCServer := &fakeV1alpha3GRPCServer{} drapbv1alpha3.RegisterNodeServer(s, fakeGRPCServer) default: return "", nil, fmt.Errorf("unsupported version: %s", version) } go func() { go s.Serve(listener) <-closeCh s.GracefulStop() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager_test.go
unprepareResourcesResponse: unprepareResourcesResponse, } if shouldTimeout { timeout := *pluginClientTimeout * 2 fakeDRADriverGRPCServer.timeout = &timeout } drapbv1.RegisterNodeServer(s, fakeDRADriverGRPCServer) go func() { go s.Serve(l) <-stopCh s.GracefulStop() }() return fakeDRAServerInfo{ server: fakeDRADriverGRPCServer, socketName: socketName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0)