- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for storage (0.2 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/install/install_test.go
cfg := &config.InstallConfig{ MountedCNINetDir: cniNetDir, ChainedCNIPlugin: c.chainedCNIPlugin, CNIBinTargetDirs: []string{cniBinDir}, } isReady := &atomic.Value{} isReady.Store(false) installer := NewInstaller(cfg, isReady) installer.cniConfigFilepath = cniConfigFilePath installer.kubeconfigFilepath = kubeConfigFilePath err := installer.Cleanup()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
if err != nil { return "", warn, err } // convert any binary data to the string equivalent for easier review. The // kube-apiserver will convert this to binary before it persists it to storage. remoteSecret.StringData = make(map[string]string, len(remoteSecret.Data)) for k, v := range remoteSecret.Data { remoteSecret.StringData[k] = string(v) } remoteSecret.Data = nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer_test.go
installReady.Store(true) watchReady.Store(true) assert.Equal(t, installReady.Load(), true) assert.Equal(t, watchReady.Load(), true) makeReq(t, server.URL, constants.LivenessEndpoint, http.StatusOK) makeReq(t, server.URL, constants.ReadinessEndpoint, http.StatusOK) watchReady.Store(false) assert.Equal(t, watchReady.Load(), false)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 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/install/install.go
} return nil } // Sets isReady to true. func setReady(isReady *atomic.Value) { installReady.Record(1) isReady.Store(true) } // Sets isReady to false. func setNotReady(isReady *atomic.Value) { installReady.Record(0) isReady.Store(false)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K 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) -
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) -
cni/pkg/cmd/root.go
ambientAgent.Start() defer ambientAgent.Stop() log.Info("Ambient node agent started, starting installer...") } else { // Ambient not enabled, so this readiness flag is no-op'd watchServerReady.Store(true) } installer := install.NewInstaller(&cfg.InstallConfig, installDaemonReady) repair.StartRepair(ctx, cfg.RepairConfig) log.Info("Installer created, watching node CNI dir")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
for k, v := range metaMap { clusterEnv[k] = v } } return os.WriteFile(filepath.Join(dir, "cluster.env"), []byte(mapToString(clusterEnv)), filePerms) } // Get and store the needed certificate and token. The certificate comes from the CA root cert, and // the token is generated by kubectl under the workload group's namespace and service account
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0)