Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for etcdserver (0.21 sec)

  1. pkg/controlplane/instance_test.go

    // they were never used outside of unit tests because the export strategies were not assigned inside the Store.
    func TestLegacyRestStorageStrategies(t *testing.T) {
    	_, etcdserver, apiserverCfg, _ := newInstance(t)
    	defer etcdserver.Terminate(t)
    
    	storageProvider, err := corerest.New(corerest.Config{
    		GenericConfig: *apiserverCfg.ControlPlane.NewCoreGenericConfig(),
    		Proxy: corerest.ProxyConfig{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  2. pkg/registry/core/componentstatus/validator.go

    	}
    	if server.Validate != nil {
    		if err := server.Validate([]byte(data)); err != nil {
    			return probe.Failure, data, err
    		}
    	}
    	return result, data, nil
    }
    
    type EtcdServer struct {
    	storagebackend.Config
    }
    
    func (server *EtcdServer) DoServerCheck() (probe.Result, string, error) {
    	prober, err := factory.CreateProber(server.Config)
    	if err != nil {
    		return probe.Failure, "", err
    	}
    	defer prober.Close()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 20 13:08:41 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/preflight/checks.go

    			"or disable swap on the node")}, nil
    	}
    
    	return nil, nil
    }
    
    type etcdVersionResponse struct {
    	Etcdserver  string `json:"etcdserver"`
    	Etcdcluster string `json:"etcdcluster"`
    }
    
    // ExternalEtcdVersionCheck checks if version of external etcd meets the demand of kubeadm
    type ExternalEtcdVersionCheck struct {
    	Etcd kubeadmapi.Etcd
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users_test.go

    	// is skipped.
    	etcdServer := env.Get(EnvTestEtcdBackend, "")
    	if s.withEtcdBackend && etcdServer == "" {
    		c.Skip("Skipping etcd backend IAM test as no etcd server is configured.")
    	}
    
    	s.TestSuiteCommon.SetUpSuite(c)
    
    	s.iamSetup(c)
    
    	if s.withEtcdBackend {
    		s.setUpEtcd(c, etcdServer)
    	}
    }
    
    func (s *TestSuiteIAM) RestartIAMSuite(c *check) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  5. cluster/images/etcd-version-monitor/etcd-version-monitor.go

    		}
    	}
    	return results, nil
    }
    
    // EtcdVersion struct for unmarshalling the json response from etcd's /version endpoint.
    type EtcdVersion struct {
    	BinaryVersion  string `json:"etcdserver"`
    	ClusterVersion string `json:"etcdcluster"`
    }
    
    // Function for fetching etcd version info and feeding it to the prometheus metric.
    func getVersion(lastSeenBinaryVersion *string) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 16 06:50:02 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  6. pkg/registry/core/rest/storage_core.go

    	}
    
    	for ix, cfg := range s.storageFactory.Configs() {
    		serversToValidate[fmt.Sprintf("etcd-%d", ix)] = &componentstatus.EtcdServer{Config: cfg}
    	}
    	return serversToValidate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go

    	GRPCStatus() *grpcstatus.Status
    }
    
    func isTooLargeError(err error) bool {
    	if err != nil {
    		if etcdErr, ok := err.(etcdError); ok {
    			if etcdErr.Code() == grpccodes.InvalidArgument && etcdErr.Error() == "etcdserver: request is too large" {
    				return true
    			}
    		}
    		if grpcErr, ok := err.(grpcError); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 17K bytes
    - Viewed (0)
  8. cluster/gce/gci/testdata/kube-apiserver/etcd.template

    readonly ETCD_APISERVER_SERVER_KEY={{.APIServerKey}}
    readonly ETCD_APISERVER_SERVER_CERT={{.APIServerCert}}
    readonly ETCD_APISERVER_CLIENT_KEY={{.ETCDKey}}
    readonly ETCD_APISERVER_CLIENT_CERT={{.ETCDCert}}
    readonly ETCD_SERVERS={{.ETCDServers}}
    readonly ETCD_APISERVER_CA_CERT_PATH={{.CACertPath}}
    readonly ETCD_APISERVER_CLIENT_CERT_PATH={{.APIServerCertPath}}
    readonly ETCD_APISERVER_CLIENT_KEY_PATH={{.APIServerKeyPath}}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 18 11:14:24 UTC 2021
    - 819 bytes
    - Viewed (0)
  9. cluster/gce/gci/apiserver_etcd_test.go

    			want: []string{
    				"--etcd-servers-overrides=/events#http://127.0.0.1:4002",
    			},
    		},
    		{
    			desc: "ETCD-SERVERS and ETCD_SERVERS_OVERRIDES are set",
    			env: kubeAPIServeETCDEnv{
    				ETCDServers:         "ETCDServers",
    				ETCDServersOverride: "ETCDServersOverrides",
    			},
    			want: []string{
    				"--etcd-servers-overrides=ETCDServersOverrides",
    			},
    		},
    	}
    
    	for _, tc := range testCases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 18 11:14:24 UTC 2021
    - 5.6K bytes
    - Viewed (0)
  10. pkg/test/framework/components/echo/common/ports/ports.go

    	TCP              = echo.Port{Name: "tcp", Protocol: protocol.TCP, ServicePort: 9090, WorkloadPort: 19090}
    	HTTPS            = echo.Port{Name: "https", Protocol: protocol.HTTPS, ServicePort: 443, WorkloadPort: 18443, TLS: true}
    	TCPServer        = echo.Port{Name: "tcp-server", Protocol: protocol.TCP, ServicePort: 9091, WorkloadPort: 16060, ServerFirst: true}
    	AutoTCP          = echo.Port{Name: "auto-tcp", Protocol: protocol.TCP, ServicePort: 9092, WorkloadPort: 19091}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 08 16:17:34 UTC 2023
    - 3.2K bytes
    - Viewed (0)
Back to top