- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for etcdserver (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)