- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for StorageBackend (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go
testOptions: &EtcdOptions{ StorageConfig: storagebackend.Config{ Transport: storagebackend.TransportConfig{ ServerList: []string{"http://127.0.0.1"}, }, }, DefaultStorageMediaType: "", }, }, { name: "recognized storage-media-type", testOptions: &EtcdOptions{ StorageConfig: storagebackend.Config{ Transport: storagebackend.TransportConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go
switch c.Type { case storagebackend.StorageTypeETCD2: return nil, fmt.Errorf("%s is no longer a supported storage backend", c.Type) case storagebackend.StorageTypeUnset, storagebackend.StorageTypeETCD3: return newETCD3HealthCheck(c, stopCh) default: return nil, fmt.Errorf("unknown storage type: %s", c.Type) } }
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/storagebackend/factory/factory_test.go
cfg: storagebackend.Config{ Type: storagebackend.StorageTypeETCD3, Transport: storagebackend.TransportConfig{}, HealthcheckTimeout: 5 * time.Second, }, responseTime: 3 * time.Second, want: nil, }, { name: "timeouts if response time higher than default timeout", cfg: storagebackend.Config{ Type: storagebackend.StorageTypeETCD3,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 12.1K bytes - Viewed (0) -
pkg/registry/core/rest/storage_core_test.go
return nil, nil } func (f fakeStorageFactory) ResourcePrefix(groupResource schema.GroupResource) string { return "" } func (f fakeStorageFactory) Backends() []storage.Backend { return []storage.Backend{{Server: "etcd-0"}} } func (f fakeStorageFactory) Configs() []storagebackend.Config {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory_test.go
servers []string wantConfigs []storagebackend.Config }{ { wantConfigs: []storagebackend.Config{ {Transport: storagebackend.TransportConfig{ServerList: defaultEtcdLocations}, Prefix: "/registry"}, }, }, { resource: &schema.GroupResource{Group: example.GroupName, Resource: "resource"}, servers: []string{}, wantConfigs: []storagebackend.Config{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory.go
} // Configs implements StorageFactory. func (s *DefaultStorageFactory) Configs() []storagebackend.Config { return configs(s.StorageConfig, s.Overrides) } // Configs gets configurations for all of registered storage destinations. func Configs(storageConfig storagebackend.Config) []storagebackend.Config { return configs(storageConfig, nil) }
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/registry/generic/storage_decorator.go
"k8s.io/apiserver/pkg/storage" "k8s.io/apiserver/pkg/storage/storagebackend" "k8s.io/apiserver/pkg/storage/storagebackend/factory" "k8s.io/client-go/tools/cache" ) // StorageDecorator is a function signature for producing a storage.Interface // and an associated DestroyFunc from given parameters. type StorageDecorator func( config *storagebackend.ConfigForResource, resourcePrefix string,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testing/test_server.go
func NewUnsecuredEtcd3TestClientServer(t *testing.T) (*EtcdTestServer, *storagebackend.Config) { server := &EtcdTestServer{} server.V3Client = testserver.RunEtcd(t, nil) config := &storagebackend.Config{ Type: "etcd3", Prefix: PathPrefix(), Transport: storagebackend.TransportConfig{ ServerList: server.V3Client.Endpoints(), }, } return server, config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
}, Prefix: "/registry", CompactionInterval: storagebackend.DefaultCompactInterval, CountMetricPollPeriod: time.Minute, DBMetricPollInterval: storagebackend.DefaultDBMetricPollInterval, HealthcheckTimeout: storagebackend.DefaultHealthcheckTimeout, ReadycheckTimeout: storagebackend.DefaultReadinessTimeout, LeaseManagerConfig: etcd3.LeaseManagerConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
} for i := range etcdConfig.AdvertiseClientUrls { etcdConfig.AdvertiseClientUrls[i].Scheme = "https" } client := testserver.RunEtcd(t, etcdConfig) cfg := storagebackend.Config{ Type: storagebackend.StorageTypeETCD3, Transport: storagebackend.TransportConfig{ ServerList: client.Endpoints(), CertFile: certFile, KeyFile: keyFile, TrustedCAFile: caFile,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 3.4K bytes - Viewed (0)