- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 41 for NewEtcdStorage (0.25 sec)
-
pkg/registry/core/persistentvolume/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" ) func newStorage(t *testing.T) (*REST, *StatusREST, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "persistentvolumes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" token "k8s.io/kubernetes/pkg/serviceaccount" ) func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "serviceaccounts", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/registry/batch/job/storage/storage_test.go
api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/registry/registrytest" ) func newStorage(t *testing.T) (*JobStorage, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, batch.GroupName) restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "jobs",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 11.2K bytes - Viewed (0) -
pkg/registry/core/persistentvolumeclaim/storage/storage_test.go
"k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/registry/registrytest" ) func newStorage(t *testing.T) (*REST, *StatusREST, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "persistentvolumeclaims",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/storage/storage_test.go
sizePortRange = 2768 ) func newStorage(t *testing.T) (*etcd3testing.EtcdTestServer, portallocator.Interface, allocator.Interface, storage.Interface, factory.DestroyFunc) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") serviceNodePortRange := utilnet.PortRange{Base: basePortRange, Size: sizePortRange} configForAllocations := etcdStorage.ForResource(api.Resource("servicenodeportallocations")) var backing allocator.Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" ) // TODO: allow for global factory override func newStorage(t *testing.T) (StatefulSetStorage, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, apps.GroupName) restOptions := generic.RESTOptions{StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "statefulsets"} storage, err := NewStorage(restOptions)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 14K bytes - Viewed (0) -
pkg/registry/apps/deployment/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" ) const defaultReplicas = 100 func newStorage(t *testing.T) (*DeploymentStorage, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, apps.GroupName) restOptions := generic.RESTOptions{StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "deployments"} deploymentStorage, err := NewStorage(restOptions)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:45 UTC 2023 - 19.7K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
) const ( namespace = metav1.NamespaceDefault name = "foo" ) func newStorage(t *testing.T) (ControllerStorage, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "replicationcontrollers",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
"k8s.io/kubernetes/pkg/securitycontext" ) func newStorage(t *testing.T) (*REST, *BindingREST, *StatusREST, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 3, ResourcePrefix: "pods", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" ) const defaultReplicas = 100 func newStorage(t *testing.T) (*ReplicaSetStorage, *etcd3testing.EtcdTestServer) { etcdStorage, server := registrytest.NewEtcdStorage(t, "extensions") restOptions := generic.RESTOptions{StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "replicasets"} replicaSetStorage, err := NewStorage(restOptions)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 17.7K bytes - Viewed (0)