Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 76 for resource_prefix (0.28 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory.go

    	NewConfig(groupResource schema.GroupResource) (*storagebackend.ConfigForResource, error)
    
    	// ResourcePrefix returns the overridden resource prefix for the GroupResource
    	// This allows for cohabitation of resources with different native types and provides
    	// centralized control over the shape of etcd directories
    	ResourcePrefix(groupResource schema.GroupResource) string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 13:35:58 UTC 2023
    - 14.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go

    	switch c.Type {
    	case storagebackend.StorageTypeETCD2:
    		return nil, nil, fmt.Errorf("%s is no longer a supported storage backend", c.Type)
    	case storagebackend.StorageTypeUnset, storagebackend.StorageTypeETCD3:
    		return newETCD3Storage(c, newFunc, newListFunc, resourcePrefix)
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/util.go

    // This method issues an empty list request and reads only the ResourceVersion from the object metadata
    func GetCurrentResourceVersionFromStorage(ctx context.Context, storage Interface, newListFunc func() runtime.Object, resourcePrefix, objectType string) (uint64, error) {
    	if storage == nil {
    		return 0, fmt.Errorf("storage wasn't provided for %s", objectType)
    	}
    	if newListFunc == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:05:06 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. pkg/registry/core/event/storage/storage_test.go

    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    	restOptions := generic.RESTOptions{
    		StorageConfig:           etcdStorage,
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 1,
    		ResourcePrefix:          "events",
    	}
    	rest, err := NewREST(restOptions, testTTL)
    	if err != nil {
    		t.Fatalf("unexpected error from REST storage: %v", err)
    	}
    	return rest, server
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 01 14:50:28 UTC 2020
    - 3.4K bytes
    - Viewed (0)
  5. pkg/registry/core/rest/storage_core_test.go

    	}
    }
    
    type fakeStorageFactory struct{}
    
    func (f fakeStorageFactory) NewConfig(groupResource schema.GroupResource) (*storagebackend.ConfigForResource, error) {
    	return nil, nil
    }
    
    func (f fakeStorageFactory) ResourcePrefix(groupResource schema.GroupResource) string {
    	return ""
    }
    
    func (f fakeStorageFactory) Backends() []storage.Backend {
    	return []storage.Backend{{Server: "etcd-0"}}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 13 08:10:29 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/FilteringClassLoader.java

            }
    
            /**
             * Marks all resources with the given prefix as visible.
             *
             * @param resourcePrefix the resource prefix
             */
            public void allowResources(String resourcePrefix) {
                resourcePrefixes.add(resourcePrefix + "/");
            }
    
            /**
             * Marks a single resource as visible.
             *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 12.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/registry/generic/options.go

    type RESTOptions struct {
    	StorageConfig *storagebackend.ConfigForResource
    	Decorator     StorageDecorator
    
    	EnableGarbageCollection   bool
    	DeleteCollectionWorkers   int
    	ResourcePrefix            string
    	CountMetricPollPeriod     time.Duration
    	StorageObjectCountTracker flowcontrolrequest.StorageObjectCountTracker
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 01 20:54:26 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

    		Decorator:                 generic.UndecoratedStorage,
    		DeleteCollectionWorkers:   f.Options.DeleteCollectionWorkers,
    		EnableGarbageCollection:   f.Options.EnableGarbageCollection,
    		ResourcePrefix:            f.StorageFactory.ResourcePrefix(resource),
    		CountMetricPollPeriod:     f.Options.StorageConfig.CountMetricPollPeriod,
    		StorageObjectCountTracker: f.Options.StorageConfig.StorageObjectCountTracker,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 15:02:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  9. pkg/registry/storage/csistoragecapacity/storage/storage_test.go

    	restOptions := generic.RESTOptions{
    		StorageConfig:           etcdStorage,
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 1,
    		ResourcePrefix:          "csistoragecapacities",
    	}
    	csiStorageCapacityStorage, err := NewStorage(restOptions)
    	if err != nil {
    		t.Fatalf("unexpected error from REST storage: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 03 19:54:14 UTC 2020
    - 4.4K bytes
    - Viewed (0)
  10. pkg/registry/storage/volumeattributesclass/storage/storage_test.go

    	restOptions := generic.RESTOptions{
    		StorageConfig:           etcdStorage,
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 1,
    		ResourcePrefix:          "volumeattributesclasses",
    	}
    	volumeAttributesClassStorage, err := NewREST(restOptions)
    	if err != nil {
    		t.Fatalf("unexpected error from REST storage: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 03:18:56 UTC 2023
    - 4.3K bytes
    - Viewed (0)
Back to top