Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for store (0.15 sec)

  1. cni/pkg/nodeagent/server.go

    		return nil, fmt.Errorf("error starting cni server: %w", err)
    	}
    	s.cniServerStopFunc = cniServer.Stop
    
    	return s, nil
    }
    
    func (s *Server) Ready() {
    	s.isReady.Store(true)
    }
    
    func (s *Server) NotReady() {
    	s.isReady.Store(false)
    }
    
    // buildKubeClient creates the kube client
    func buildKubeClient(kubeConfig string) (kube.Client, error) {
    	// Used by validation
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache_test.go

    	i := 0
    	return func(s string) (NetnsCloser, error) {
    		inode := inodes[i]
    		i++
    		return newFakeNsInode(inc(), inode), nil
    	}
    }
    
    func TestUpsertPodCache(t *testing.T) {
    	counter.Store(0)
    
    	p := newPodNetnsCache(openNsTestOverrideWithInodes(1, 1))
    
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}}
    	nspath1 := "/path/to/netns/1"
    	nspath2 := "/path/to/netns/2"
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/healthServer.go

    	}()
    
    	return
    }
    
    func initRouter(router *http.ServeMux) (installReady *atomic.Value, watchReady *atomic.Value) {
    	installReady = &atomic.Value{}
    	watchReady = &atomic.Value{}
    	installReady.Store(false)
    	watchReady.Store(false)
    
    	router.HandleFunc(constants.LivenessEndpoint, healthz)
    	router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady))
    
    	return
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/storage/v1alpha1/generated.proto

    import "k8s.io/apimachinery/pkg/runtime/schema/generated.proto";
    
    // Package-wide variables from generator "generated".
    option go_package = "k8s.io/api/storage/v1alpha1";
    
    // CSIStorageCapacity stores the result of one CSI GetCapacity call.
    // For a given StorageClass, this describes the available capacity in a
    // particular topology segment.  This can be used when considering where to
    // instantiate new PersistentVolumes.
    //
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/fakes_test.go

    	return f.fd
    }
    
    func (f *fakeNs) Inode() uint64 {
    	return f.inode
    }
    
    // Close simulates closing the file descriptor and returns nil for no error
    func (f *fakeNs) Close() error {
    	f.closed.Store(true)
    	return nil
    }
    
    func fakeFs() fs.FS {
    	subFs, err := fs.Sub(fakeProc, "testdata")
    	if err != nil {
    		panic(err)
    	}
    	subFs, err = fs.Sub(subFs, "cgroupns")
    	if err != nil {
    		panic(err)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. common-protos/k8s.io/apimachinery/pkg/runtime/generated.proto

    // your external MyAPIObject. That causes the raw JSON to be stored, but not unpacked.
    // The next step is to copy (using pkg/conversion) into the internal struct. The runtime
    // package's DefaultScheme has conversion functions installed which will unpack the
    // JSON stored in RawExtension, turning it into the correct object type, and storing it
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top