kubernetes/staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

type EtcdOptions …

var storageTypes …

func NewEtcdOptions(backendConfig *storagebackend.Config) *EtcdOptions { … }

var storageMediaTypes …

func (s *EtcdOptions) Validate() []error { … }

// AddFlags adds flags related to etcd storage for a specific APIServer to the specified FlagSet
func (s *EtcdOptions) AddFlags(fs *pflag.FlagSet) { … }

// ApplyTo mutates the provided server.Config.  It must never mutate the receiver (EtcdOptions).
func (s *EtcdOptions) ApplyTo(c *server.Config) error { … }

// ApplyWithStorageFactoryTo mutates the provided server.Config.  It must never mutate the receiver (EtcdOptions).
func (s *EtcdOptions) ApplyWithStorageFactoryTo(factory serverstorage.StorageFactory, c *server.Config) error { … }

func monitorGetter(factory serverstorage.StorageFactory) func() (monitors []metrics.Monitor, err error) { … }

func (s *EtcdOptions) CreateRESTOptionsGetter(factory serverstorage.StorageFactory, resourceTransformers storagevalue.ResourceTransformers) generic.RESTOptionsGetter { … }

func (s *EtcdOptions) maybeApplyResourceTransformers(c *server.Config) (err error) { … }

func addHealthChecksWithoutLivez(c *server.Config, healthChecks ...healthz.HealthChecker) { … }

func (s *EtcdOptions) addEtcdHealthEndpoint(c *server.Config) error { … }

type StorageFactoryRestOptionsFactory …

func (f *StorageFactoryRestOptionsFactory) GetRESTOptions(resource schema.GroupResource, example runtime.Object) (generic.RESTOptions, error) { … }

// ParseWatchCacheSizes turns a list of cache size values into a map of group resources
// to requested sizes.
func ParseWatchCacheSizes(cacheSizes []string) (map[schema.GroupResource]int, error) { … }

// WriteWatchCacheSizes turns a map of cache size values into a list of string specifications.
func WriteWatchCacheSizes(watchCacheSizes map[schema.GroupResource]int) ([]string, error) { … }

var _ …

type SimpleStorageFactory …

func (s *SimpleStorageFactory) NewConfig(resource schema.GroupResource, example runtime.Object) (*storagebackend.ConfigForResource, error) { … }

func (s *SimpleStorageFactory) ResourcePrefix(resource schema.GroupResource) string { … }

func (s *SimpleStorageFactory) Configs() []storagebackend.Config { … }

func (s *SimpleStorageFactory) Backends() []serverstorage.Backend { … }

var _ …

type transformerStorageFactory …

func (t *transformerStorageFactory) NewConfig(resource schema.GroupResource, example runtime.Object) (*storagebackend.ConfigForResource, error) { … }

func (t *transformerStorageFactory) ResourcePrefix(resource schema.GroupResource) string { … }

func (t *transformerStorageFactory) Configs() []storagebackend.Config { … }

func (t *transformerStorageFactory) Backends() []serverstorage.Backend { … }