- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 76 for resource_prefix (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)