- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for RunEtcd (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact_test.go
"testing" etcdrpc "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" clientv3 "go.etcd.io/etcd/client/v3" "k8s.io/apiserver/pkg/storage/etcd3/testserver" ) func TestCompact(t *testing.T) { client := testserver.RunEtcd(t, nil) ctx := context.Background() putResp, err := client.Put(ctx, "/somekey", "data") if err != nil { t.Fatalf("Put failed: %v", err) } putResp1, err := client.Put(ctx, "/somekey", "data2")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 23 14:22:57 UTC 2021 - 2.5K bytes - Viewed (0) -
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)