Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RegisterNodeServer (0.43 sec)

  1. 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)
  2. 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)
Back to top