- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 2,466 for JOIN (0.09 sec)
-
cmd/kubeadm/app/cmd/phases/join/preflight.go
"k8s.io/kubernetes/cmd/kubeadm/app/preflight" ) var ( preflightExample = cmdutil.Examples(` # Run join pre-flight checks using a config file. kubeadm join phase preflight --config kubeadm-config.yaml `) notReadyToJoinControlPlaneTemp = template.Must(template.New("join").Parse(dedent.Dedent(` One or more conditions for hosting a new control plane instance is not satisfied. {{.Error}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 03:55:23 UTC 2024 - 5.3K bytes - Viewed (0) -
tensorflow/cc/training/coordinator_test.cc
counter.Wait(); TF_EXPECT_OK(coord.RequestStop()); EXPECT_EQ(coord.Join().code(), absl::StatusCode::kInvalidArgument); } TEST(CoordinatorTest, JoinWithoutStop) { Coordinator coord; std::unique_ptr<MockQueueRunner> qr(new MockQueueRunner(&coord)); TF_ASSERT_OK(coord.RegisterRunner(std::move(qr))); EXPECT_EQ(coord.Join().code(), Code::FAILED_PRECONDITION); } TEST(CoordinatorTest, AllRunnersStopped) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubelet/flags.go
} // GetNodeNameAndHostname obtains the name for this Node using the following precedence // (from lower to higher): // - actual hostname // - NodeRegistrationOptions.Name (same as "--node-name" passed to "kubeadm init/join") // - "hostname-override" flag in NodeRegistrationOptions.KubeletExtraArgs // It also returns the hostname or an error if getting the hostname failed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 10:27:05 UTC 2023 - 5K bytes - Viewed (0) -
src/syscall/getdirentries_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 2.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
tmpDir := t.TempDir() tmpCharts := chartSourceType(filepath.Join(tmpDir, operatorSubdirFilePath)) err := copyDir(string(liveCharts), string(tmpCharts)) if err != nil { t.Fatal(err) } rs, err := readFile(filepath.Join(testDataDir, "input-extra-resources", testResourceFile+".yaml")) if err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 43.5K bytes - Viewed (0) -
pkg/kubelet/kubeletconfig/util/files/files_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 07 11:36:13 UTC 2022 - 11.7K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
set.V6Name = fmt.Sprintf(V6Name, name) v6err := deps.ipsetIPHashCreate(set.V6Name, true) err = errors.Join(err, v6err) } return set, err } func (m *IPSet) DestroySet() error { var err error err = m.Deps.destroySet(m.V4Name) if m.V6Name != "" { v6err := m.Deps.destroySet(m.V6Name) err = errors.Join(err, v6err) } return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.9K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca_test.go
_, err = os.Stat(path.Join(dir, "root-cert.pem")) g.Expect(os.IsNotExist(err)).Should(Equal(true)) // Should load remote cacerts successfully. createCASecret(t, s.kubeClient) err = s.loadCACerts(caOpts, dir) g.Expect(err).Should(BeNil()) expectedRoot, err := readSampleCertFromFile("root-cert.pem") g.Expect(err).Should(BeNil())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 4.3K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate.go
etcdctlVersioned := fmt.Sprintf("etcdctl-%s", opts.targetVersion) if err := copyFile(filepath.Join(opts.binDir, etcdVersioned), filepath.Join(opts.binDir, "etcd")); err != nil { klog.Fatalf("Failed to copy %s: %v", etcdVersioned, err) } if err := copyFile(filepath.Join(opts.binDir, etcdctlVersioned), filepath.Join(opts.binDir, "etcdctl")); err != nil { klog.Fatalf("Failed to copy %s: %v", etcdctlVersioned, err) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 16 23:10:54 UTC 2020 - 3.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/telemetry/dir.go
func NewDir(dir string) Dir { return Dir{ dir: dir, local: filepath.Join(dir, "local"), upload: filepath.Join(dir, "upload"), debug: filepath.Join(dir, "debug"), modefile: filepath.Join(dir, "mode"), } } func init() { cfgDir, err := os.UserConfigDir() if err != nil { return } Default = NewDir(filepath.Join(cfgDir, "go", "telemetry")) } func (d Dir) Dir() string { return d.dir }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:13:09 UTC 2024 - 4.8K bytes - Viewed (0)