- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RunEtcd (0.08 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testing/test_server.go
func NewUnsecuredEtcd3TestClientServer(t *testing.T) (*EtcdTestServer, *storagebackend.Config) { server := &EtcdTestServer{} server.V3Client = testserver.RunEtcd(t, nil) config := &storagebackend.Config{ Type: "etcd3", Prefix: PathPrefix(), Transport: storagebackend.TransportConfig{ ServerList: server.V3Client.Endpoints(), }, } return server, config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testserver/test_server.go
cfg.Dir = t.TempDir() os.Chmod(cfg.Dir, 0700) return cfg } // RunEtcd starts an embedded etcd server with the provided config // (or NewTestConfig(t) if nil), and returns a client connected to the server. // The server is terminated when the test ends. func RunEtcd(t testing.TB, cfg *embed.Config) *clientv3.Client { t.Helper() if cfg == nil { cfg = NewTestConfig(t) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 06 11:40:40 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
etcdConfig.ListenClientUrls[i].Scheme = "https" } for i := range etcdConfig.AdvertiseClientUrls { etcdConfig.AdvertiseClientUrls[i].Scheme = "https" } client := testserver.RunEtcd(t, etcdConfig) cfg := storagebackend.Config{ Type: storagebackend.StorageTypeETCD3, Transport: storagebackend.TransportConfig{ ServerList: client.Endpoints(), CertFile: certFile,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 3.4K bytes - Viewed (0)