NewEtcdStorage - Code Search

pkg/registry/registrytest/etcd.go

	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
	"k8s.io/apiserver/pkg/storage/storagebackend"
	"k8s.io/kubernetes/pkg/kubeapiserver"
)

// NewEtcdStorage is for testing.  It configures the etcd storage for a bogus resource; the test must not care.
func NewEtcdStorage(t *testing.T, group string) (*storagebackend.ConfigForResource, *etcd3testing.EtcdTestServer) {

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Mar 16 03:10:18 UTC 2023

- 1.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/pod/rest/log_test.go

	api "k8s.io/kubernetes/pkg/apis/core"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func TestPodLogValidates(t *testing.T) {
	config, server := registrytest.NewEtcdStorage(t, "")
	defer server.Terminate(t)
	s, destroyFunc, err := generic.NewRawStorage(config, nil, nil, "")
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}
	defer destroyFunc()

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Aug 24 09:23:05 UTC 2023

- 1.6K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/event/storage/storage_test.go

	"k8s.io/kubernetes/pkg/registry/registrytest"
)

var testTTL uint64 = 60

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,
		ResourcePrefix:          "events",
	}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Jul 01 14:50:28 UTC 2020

- 3.4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/secret/storage/storage_test.go

	api "k8s.io/kubernetes/pkg/apis/core"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,
		ResourcePrefix:          "secrets",
	}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon Aug 12 20:55:35 UTC 2019

- 3.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/resource/resourceclassparameters/storage/storage_test.go

	_ "k8s.io/kubernetes/pkg/apis/resource/install"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, resource.GroupName)
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Mar 07 21:21:16 UTC 2024

- 4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/limitrange/storage/storage_test.go

	_ "k8s.io/kubernetes/pkg/apis/core/install"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,
		ResourcePrefix:          "limitranges",
	}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Fri Dec 13 16:56:29 UTC 2019

- 4.6K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/apps/daemonset/storage/storage_test.go

	api "k8s.io/kubernetes/pkg/apis/core"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *StatusREST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, apps.GroupName)
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,
		ResourcePrefix:          "daemonsets",

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon Aug 12 20:55:35 UTC 2019

- 5.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/resource/resourceclaimparameters/storage/storage_test.go

	_ "k8s.io/kubernetes/pkg/apis/resource/install"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, resource.GroupName)
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Mar 07 15:15:31 UTC 2024

- 4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/endpoint/storage/storage_test.go

	api "k8s.io/kubernetes/pkg/apis/core"
	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*REST, *etcd3testing.EtcdTestServer) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
	restOptions := generic.RESTOptions{
		StorageConfig:           etcdStorage,
		Decorator:               generic.UndecoratedStorage,
		DeleteCollectionWorkers: 1,
		ResourcePrefix:          "endpoints",
	}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon Aug 12 20:55:35 UTC 2019

- 3.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/service/allocator/storage/storage_test.go

	"k8s.io/kubernetes/pkg/registry/registrytest"
)

func newStorage(t *testing.T) (*Etcd, *etcd3testing.EtcdTestServer, allocator.Interface, *storagebackend.Config) {
	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
	mem := allocator.NewAllocationMap(100, "rangeSpecValue")
	etcd, err := NewEtcd(mem, "/ranges/serviceips", etcdStorage.ForResource(api.Resource("serviceipallocations")))
	if err != nil {

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Sep 01 20:54:26 UTC 2021

- 4.8K bytes

- Viewed (0)

Search Options