- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for etcdctl (0.33 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
t.mux.RLock() defer t.mux.RUnlock() if t.closed { return fmt.Errorf("closed") } // See https://github.com/etcd-io/etcd/blob/c57f8b3af865d1b531b979889c602ba14377420e/etcdctl/ctlv3/command/ep_command.go#L118 _, err := t.client.Get(ctx, path.Join("/", t.prefix, "health")) if err != nil { return fmt.Errorf("error getting data from etcd: %w", err) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go
Prefix: "/registry", Transport: storagebackend.TransportConfig{ ServerList: nil, KeyFile: "/var/run/kubernetes/etcd.key", TrustedCAFile: "/var/run/kubernetes/etcdca.crt", CertFile: "/var/run/kubernetes/etcdce.crt", }, CompactionInterval: storagebackend.DefaultCompactInterval, CountMetricPollPeriod: time.Minute, }, DefaultStorageMediaType: "application/vnd.kubernetes.protobuf",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
"--enable-priority-and-fairness=false", "--enable-logs-handler=false", "--etcd-keyfile=/var/run/kubernetes/etcd.key", "--etcd-certfile=/var/run/kubernetes/etcdce.crt", "--etcd-cafile=/var/run/kubernetes/etcdca.crt", "--http2-max-streams-per-connection=42", "--tracing-config-file=/var/run/kubernetes/tracing_config.yaml", "--proxy-client-cert-file=/var/run/kubernetes/proxy.crt",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"--enable-logs-handler=false", "--endpoint-reconciler-type=" + string(reconcilers.LeaseEndpointReconcilerType), "--etcd-keyfile=/var/run/kubernetes/etcd.key", "--etcd-certfile=/var/run/kubernetes/etcdce.crt", "--etcd-cafile=/var/run/kubernetes/etcdca.crt", "--http2-max-streams-per-connection=42", "--kubelet-read-only-port=10255", "--kubelet-timeout=5s", "--kubelet-client-certificate=/var/run/kubernetes/ceserver.crt",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_server.go
) if r.cfg.etcdServerArgs != "" { extraArgs := strings.Fields(r.cfg.etcdServerArgs) etcdCmd.Args = append(etcdCmd.Args, extraArgs...) } fmt.Printf("Starting server %s: %+v\n", r.cfg.name, etcdCmd.Args) etcdCmd.Stdout = os.Stdout etcdCmd.Stderr = os.Stderr err := etcdCmd.Start() if err != nil { return err } interval := time.NewTicker(time.Millisecond * 500) defer interval.Stop()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
{Name: "listen-client-urls", Value: fmt.Sprintf("%s,%s", etcdutil.GetClientURLByIP(etcdLocalhostAddress), etcdutil.GetClientURL(endpoint))}, {Name: "advertise-client-urls", Value: etcdutil.GetClientURL(endpoint)}, {Name: "listen-peer-urls", Value: etcdutil.GetPeerURL(endpoint)}, {Name: "initial-advertise-peer-urls", Value: etcdutil.GetPeerURL(endpoint)}, {Name: "data-dir", Value: cfg.Etcd.Local.DataDir},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
cmd/kubeadm/app/phases/upgrade/staticpods_test.go
func (c fakeTLSEtcdClient) ListMembers() ([]etcdutil.Member, error) { return []etcdutil.Member{}, nil } func (c fakeTLSEtcdClient) AddMemberAsLearner(name string, peerAddrs string) ([]etcdutil.Member, error) { return []etcdutil.Member{}, nil } func (c fakeTLSEtcdClient) AddMember(name string, peerAddrs string) ([]etcdutil.Member, error) { return []etcdutil.Member{}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 32K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
newTestSuiteIAM(bt, false), newTestSuiteIAM(bt, true), ) } for i, testCase := range testCases { etcdStr := "" if testCase.withEtcdBackend { etcdStr = " (with etcd backend)" } t.Run( fmt.Sprintf("Test: %d, ServerType: %s%s", i+1, testCase.serverType, etcdStr), func(t *testing.T) { runAllIAMConcurrencyTests(testCase, &check{t, testCase.serverType}) }, ) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/etcd.go
"k8s.io/kubernetes/cmd/kubeadm/app/cmd/options" "k8s.io/kubernetes/cmd/kubeadm/app/cmd/phases/workflow" cmdutil "k8s.io/kubernetes/cmd/kubeadm/app/cmd/util" etcdphase "k8s.io/kubernetes/cmd/kubeadm/app/phases/etcd" etcdutil "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd" ) var ( etcdLocalExample = cmdutil.Examples(` # Generates the static Pod manifest file for etcd, functionally # equivalent to what is generated by kubeadm init.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 11 08:02:50 UTC 2022 - 3.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/controlplane/volumes.go
} // getEtcdCertVolumes returns the volumes/volumemounts needed for talking to an external etcd cluster func getEtcdCertVolumes(etcdCfg *kubeadmapi.ExternalEtcd, k8sCertificatesDir string) ([]v1.Volume, []v1.VolumeMount) { certPaths := []string{etcdCfg.CAFile, etcdCfg.CertFile, etcdCfg.KeyFile} certDirs := sets.New[string]() for _, certPath := range certPaths { certDir := filepath.ToSlash(filepath.Dir(certPath))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 09:33:18 UTC 2024 - 11.3K bytes - Viewed (0)