Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for etcdutil (0.14 sec)

  1. 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)
  2. 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)
  3. cmd/kubeadm/app/phases/etcd/local_test.go

    	"github.com/google/go-cmp/cmp"
    	"github.com/lithammer/dedent"
    
    	v1 "k8s.io/api/core/v1"
    	kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
    	kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
    	etcdutil "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd"
    	staticpodutil "k8s.io/kubernetes/cmd/kubeadm/app/util/staticpod"
    	testutil "k8s.io/kubernetes/cmd/kubeadm/test"
    )
    
    func TestGetEtcdPodSpec(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 14:07:27 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/upgrade/staticpods.go

    	etcdphase "k8s.io/kubernetes/cmd/kubeadm/app/phases/etcd"
    	kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util"
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/apiclient"
    	dryrunutil "k8s.io/kubernetes/cmd/kubeadm/app/util/dryrun"
    	etcdutil "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd"
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/image"
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/staticpod"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 10:07:41 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. cluster/images/etcd/Makefile

    		$(BIN_INSTALL) $$etcd_release_tmp_dir/etcd-v$$version-windows-amd64/etcd.exe $$etcd_release_tmp_dir/etcd-v$$version-windows-amd64/etcdctl.exe $(TEMP_DIR)/; \
    		$(BIN_INSTALL) $(TEMP_DIR)/etcd.exe $(TEMP_DIR)/etcd-$$version.exe; \
    		$(BIN_INSTALL) $(TEMP_DIR)/etcdctl.exe $(TEMP_DIR)/etcdctl-$$version.exe; \
    	done
    else
    	for version in $(BUNDLED_ETCD_VERSIONS); do \
    		etcd_release_tmp_dir=$(shell mktemp -d); \
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/test/integration/registration_test.go

    				Metadata: Metadata{
    					Name:      "bar",
    					Namespace: "",
    				},
    			},
    		},
    	}
    
    	etcdURL, ok := os.LookupEnv("KUBE_INTEGRATION_ETCD_URL")
    	if !ok {
    		etcdURL = "http://127.0.0.1:2379"
    	}
    	cfg := clientv3.Config{
    		Endpoints: []string{etcdURL},
    	}
    	c, err := clientv3.New(cfg)
    	if err != nil {
    		t.Fatal(err)
    	}
    	kv := clientv3.NewKV(c)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 14 11:58:05 UTC 2022
    - 15.4K bytes
    - Viewed (0)
  7. 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)
Back to top