- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for store (0.22 sec)
-
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) -
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) -
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) -
common-protos/k8s.io/api/resource/v1alpha2/generated.proto
// parameters that will be used by the driver when allocating a // resource that uses this class. A dynamic resource driver can // distinguish between parameters stored here and and those stored in // ResourceClaimSpec. // +optional optional ResourceClassParametersReference parametersRef = 3; // Only nodes matching the selector will be considered by the scheduler
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 14.4K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels // +optional map<string, string> labels = 11; // Annotations is an unstructured key value map stored with a resource that may be // set by external tools to store and retrieve arbitrary metadata. They are not // queryable and should be preserved when modifying objects.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 53.3K bytes - Viewed (0) -
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) -
common-protos/k8s.io/api/storage/v1beta1/generated.proto
// If all drivers in the list are uninstalled, this can become empty. // +patchMergeKey=name // +patchStrategy=merge repeated CSINodeDriver drivers = 1; } // 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 - 24.9K bytes - Viewed (0) -
Makefile.core.mk
# (2) in the VERSION file, in which we will append "-dev" to it ifeq ($(VERSION),) VERSION_FROM_FILE := $(shell cat VERSION) ifeq ($(VERSION_FROM_FILE),) $(error VERSION not detected. Make sure it's stored in the VERSION file or defined in VERSION variable) endif VERSION := $(VERSION_FROM_FILE)-dev endif export VERSION # Base version of Istio image to use BASE_VERSION ?= master-2024-05-08T18-51-53
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 20:25:15 GMT 2024 - 22.5K bytes - Viewed (0) -
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) -
common-protos/k8s.io/api/storage/v1/generated.proto
// If all drivers in the list are uninstalled, this can become empty. // +patchMergeKey=name // +patchStrategy=merge repeated CSINodeDriver drivers = 1; } // 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 - 24.7K bytes - Viewed (0)