Fix golint issues in pkg/kubeapiserver

This commit is contained in:
Igor Zibarev 2019-11-05 22:25:32 +03:00
parent 08410cbf06
commit 03dfa1a641
5 changed files with 14 additions and 6 deletions

View File

@ -429,7 +429,7 @@ func buildGenericConfig(
genericConfig.Version = &kubeVersion genericConfig.Version = &kubeVersion
storageFactoryConfig := kubeapiserver.NewStorageFactoryConfig() storageFactoryConfig := kubeapiserver.NewStorageFactoryConfig()
storageFactoryConfig.ApiResourceConfig = genericConfig.MergedResourceConfig storageFactoryConfig.APIResourceConfig = genericConfig.MergedResourceConfig
completedStorageFactoryConfig, err := storageFactoryConfig.Complete(s.Etcd) completedStorageFactoryConfig, err := storageFactoryConfig.Complete(s.Etcd)
if err != nil { if err != nil {
lastErr = err lastErr = err

View File

@ -51,6 +51,7 @@ var SpecialDefaultResourcePrefixes = map[schema.GroupResource]string{
{Group: "policy", Resource: "podsecuritypolicies"}: "podsecuritypolicy", {Group: "policy", Resource: "podsecuritypolicies"}: "podsecuritypolicy",
} }
// NewStorageFactoryConfig returns a new StorageFactoryConfig set up with necessary resource overrides.
func NewStorageFactoryConfig() *StorageFactoryConfig { func NewStorageFactoryConfig() *StorageFactoryConfig {
resources := []schema.GroupVersionResource{ resources := []schema.GroupVersionResource{
@ -73,9 +74,10 @@ func NewStorageFactoryConfig() *StorageFactoryConfig {
} }
} }
// StorageFactoryConfig is a configuration for creating storage factory.
type StorageFactoryConfig struct { type StorageFactoryConfig struct {
StorageConfig storagebackend.Config StorageConfig storagebackend.Config
ApiResourceConfig *serverstorage.ResourceConfig APIResourceConfig *serverstorage.ResourceConfig
DefaultResourceEncoding *serverstorage.DefaultResourceEncodingConfig DefaultResourceEncoding *serverstorage.DefaultResourceEncodingConfig
DefaultStorageMediaType string DefaultStorageMediaType string
Serializer runtime.StorageSerializer Serializer runtime.StorageSerializer
@ -84,6 +86,7 @@ type StorageFactoryConfig struct {
EncryptionProviderConfigFilepath string EncryptionProviderConfigFilepath string
} }
// Complete completes the StorageFactoryConfig with provided etcdOptions returning completedStorageFactoryConfig.
func (c *StorageFactoryConfig) Complete(etcdOptions *serveroptions.EtcdOptions) (*completedStorageFactoryConfig, error) { func (c *StorageFactoryConfig) Complete(etcdOptions *serveroptions.EtcdOptions) (*completedStorageFactoryConfig, error) {
c.StorageConfig = etcdOptions.StorageConfig c.StorageConfig = etcdOptions.StorageConfig
c.DefaultStorageMediaType = etcdOptions.DefaultStorageMediaType c.DefaultStorageMediaType = etcdOptions.DefaultStorageMediaType
@ -92,10 +95,15 @@ func (c *StorageFactoryConfig) Complete(etcdOptions *serveroptions.EtcdOptions)
return &completedStorageFactoryConfig{c}, nil return &completedStorageFactoryConfig{c}, nil
} }
// completedStorageFactoryConfig is a wrapper around StorageFactoryConfig completed with etcd options.
//
// Note: this struct is intentionally unexported so that it can only be constructed via a StorageFactoryConfig.Complete
// call. The implied consequence is that this does not comply with golint.
type completedStorageFactoryConfig struct { type completedStorageFactoryConfig struct {
*StorageFactoryConfig *StorageFactoryConfig
} }
// New returns a new storage factory created from the completed storage factory configuration.
func (c *completedStorageFactoryConfig) New() (*serverstorage.DefaultStorageFactory, error) { func (c *completedStorageFactoryConfig) New() (*serverstorage.DefaultStorageFactory, error) {
resourceEncodingConfig := resourceconfig.MergeResourceEncodingConfigs(c.DefaultResourceEncoding, c.ResourceEncodingOverrides) resourceEncodingConfig := resourceconfig.MergeResourceEncodingConfigs(c.DefaultResourceEncoding, c.ResourceEncodingOverrides)
storageFactory := serverstorage.NewDefaultStorageFactory( storageFactory := serverstorage.NewDefaultStorageFactory(
@ -103,7 +111,7 @@ func (c *completedStorageFactoryConfig) New() (*serverstorage.DefaultStorageFact
c.DefaultStorageMediaType, c.DefaultStorageMediaType,
c.Serializer, c.Serializer,
resourceEncodingConfig, resourceEncodingConfig,
c.ApiResourceConfig, c.APIResourceConfig,
SpecialDefaultResourcePrefixes) SpecialDefaultResourcePrefixes)
storageFactory.AddCohabitatingResources(networking.Resource("networkpolicies"), extensions.Resource("networkpolicies")) storageFactory.AddCohabitatingResources(networking.Resource("networkpolicies"), extensions.Resource("networkpolicies"))

View File

@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
limitations under the License. limitations under the License.
*/ */
// The kubeapiserver package holds code that is common to both the kube-apiserver // Package kubeapiserver holds code that is common to both the kube-apiserver
// and the federation-apiserver, but isn't part of a generic API server. // and the federation-apiserver, but isn't part of a generic API server.
// For instance, the non-delegated authorization options are used by those two // For instance, the non-delegated authorization options are used by those two
// servers, but no generic API server is likely to use them. // servers, but no generic API server is likely to use them.

View File

@ -44,7 +44,7 @@ func NewEtcdStorageForResource(t *testing.T, resource schema.GroupResource) (*st
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
completedConfig.ApiResourceConfig = serverstorage.NewResourceConfig() completedConfig.APIResourceConfig = serverstorage.NewResourceConfig()
factory, err := completedConfig.New() factory, err := completedConfig.New()
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)

View File

@ -278,7 +278,7 @@ func NewMasterConfigWithOptions(opts *MasterConfigOptions) *master.Config {
} }
storageConfig := kubeapiserver.NewStorageFactoryConfig() storageConfig := kubeapiserver.NewStorageFactoryConfig()
storageConfig.ApiResourceConfig = serverstorage.NewResourceConfig() storageConfig.APIResourceConfig = serverstorage.NewResourceConfig()
completedStorageConfig, err := storageConfig.Complete(etcdOptions) completedStorageConfig, err := storageConfig.Complete(etcdOptions)
if err != nil { if err != nil {
panic(err) panic(err)