Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for etcd3testing (0.22 sec)

  1. pkg/registry/core/persistentvolumeclaim/storage/storage_test.go

    	"k8s.io/apiserver/pkg/registry/rest"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/registry/registrytest"
    )
    
    func newStorage(t *testing.T) (*REST, *StatusREST, *etcd3testing.EtcdTestServer) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. pkg/controlplane/instance_test.go

    	storagerest "k8s.io/kubernetes/pkg/registry/storage/rest"
    )
    
    // setUp is a convenience function for setting up for (most) tests.
    func setUp(t *testing.T) (*etcd3testing.EtcdTestServer, Config, *assert.Assertions) {
    	server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t)
    
    	config := &Config{
    		ControlPlane: controlplaneapiserver.Config{
    			Generic: genericapiserver.NewConfig(legacyscheme.Codecs),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  3. pkg/registry/core/service/portallocator/storage/storage_test.go

    */
    
    package storage
    
    import (
    	"context"
    	"fmt"
    	"strings"
    	"testing"
    
    	utilnet "k8s.io/apimachinery/pkg/util/net"
    	"k8s.io/apiserver/pkg/registry/generic"
    	"k8s.io/apiserver/pkg/storage"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	"k8s.io/apiserver/pkg/storage/storagebackend/factory"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	_ "k8s.io/kubernetes/pkg/apis/core/install"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go

    	"k8s.io/apiextensions-apiserver/pkg/registry/customresource/tableconvertor"
    )
    
    func newStorage(t *testing.T) (customresource.CustomResourceStorage, *etcd3testing.EtcdTestServer) {
    	server, etcdStorage := etcd3testing.NewUnsecuredEtcd3TestClientServer(t)
    	etcdStorage.Codec = unstructured.UnstructuredJSONScheme
    	groupResource := schema.GroupResource{Group: "mygroup.example.com", Resource: "noxus"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  5. pkg/registry/core/replicationcontroller/storage/storage_test.go

    	"k8s.io/apiserver/pkg/registry/rest"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	"k8s.io/kubernetes/pkg/apis/autoscaling"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/registry/registrytest"
    )
    
    const (
    	namespace = metav1.NamespaceDefault
    	name      = "foo"
    )
    
    func newStorage(t *testing.T) (ControllerStorage, *etcd3testing.EtcdTestServer) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 16 06:57:01 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  6. pkg/registry/core/pod/storage/storage_test.go

    	storeerr "k8s.io/apiserver/pkg/storage/errors"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/registry/registrytest"
    	"k8s.io/kubernetes/pkg/securitycontext"
    )
    
    func newStorage(t *testing.T) (*REST, *BindingREST, *StatusREST, *etcd3testing.EtcdTestServer) {
    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	"k8s.io/apimachinery/pkg/watch"
    	"k8s.io/apiserver/pkg/apis/example"
    	examplev1 "k8s.io/apiserver/pkg/apis/example/v1"
    	"k8s.io/apiserver/pkg/features"
    	"k8s.io/apiserver/pkg/storage"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    	"k8s.io/utils/clock"
    	testingclock "k8s.io/utils/clock/testing"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	"k8s.io/apiserver/pkg/features"
    	"k8s.io/apiserver/pkg/registry/generic"
    	"k8s.io/apiserver/pkg/registry/rest"
    	"k8s.io/apiserver/pkg/storage"
    	cacherstorage "k8s.io/apiserver/pkg/storage/cacher"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	"k8s.io/apiserver/pkg/storage/names"
    	"k8s.io/apiserver/pkg/storage/storagebackend/factory"
    	storagetesting "k8s.io/apiserver/pkg/storage/testing"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  9. pkg/registry/core/service/storage/storage_test.go

    func newStorage(t *testing.T, ipFamilies []api.IPFamily) (*wrapperRESTForTests, *StatusREST, *etcd3testing.EtcdTestServer) {
    	return newStorageWithPods(t, ipFamilies, nil, nil)
    }
    
    func newStorageWithPods(t *testing.T, ipFamilies []api.IPFamily, pods []api.Pod, endpoints []*api.Endpoints) (*wrapperRESTForTests, *StatusREST, *etcd3testing.EtcdTestServer) {
    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
Back to top