Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for StorageBackend (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top