Unify genericapiserver Config.New() and master Config.New()

This commit is contained in:
Dr. Stefan Schimanski
2016-09-27 17:54:45 +02:00
parent c0826a2e7e
commit b4c6a68036
8 changed files with 12 additions and 12 deletions

View File

@@ -330,7 +330,7 @@ func Run(s *options.APIServer) error {
cachesize.SetWatchCacheSizes(s.WatchCacheSizes) cachesize.SetWatchCacheSizes(s.WatchCacheSizes)
} }
m, err := master.New(config) m, err := config.New()
if err != nil { if err != nil {
return err return err
} }

View File

@@ -194,7 +194,7 @@ type RESTStorageProvider interface {
// Certain config fields will be set to a default value if unset. // Certain config fields will be set to a default value if unset.
// Certain config fields must be specified, including: // Certain config fields must be specified, including:
// KubeletClient // KubeletClient
func New(c *Config) (*Master, error) { func (c *Config) New() (*Master, error) {
if c.KubeletClient == nil { if c.KubeletClient == nil {
return nil, fmt.Errorf("Master.New() called with config.KubeletClient == nil") return nil, fmt.Errorf("Master.New() called with config.KubeletClient == nil")
} }

View File

@@ -125,7 +125,7 @@ func setUp(t *testing.T) (*Master, *etcdtesting.EtcdTestServer, Config, *assert.
func newMaster(t *testing.T) (*Master, *etcdtesting.EtcdTestServer, Config, *assert.Assertions) { func newMaster(t *testing.T) (*Master, *etcdtesting.EtcdTestServer, Config, *assert.Assertions) {
_, etcdserver, config, assert := setUp(t) _, etcdserver, config, assert := setUp(t)
master, err := New(&config) master, err := config.New()
if err != nil { if err != nil {
t.Fatalf("Error in bringing up the master: %v", err) t.Fatalf("Error in bringing up the master: %v", err)
} }
@@ -151,7 +151,7 @@ func limitedAPIResourceConfigSource() *genericapiserver.ResourceConfig {
func newLimitedMaster(t *testing.T) (*Master, *etcdtesting.EtcdTestServer, Config, *assert.Assertions) { func newLimitedMaster(t *testing.T) (*Master, *etcdtesting.EtcdTestServer, Config, *assert.Assertions) {
_, etcdserver, config, assert := setUp(t) _, etcdserver, config, assert := setUp(t)
config.APIResourceConfigSource = limitedAPIResourceConfigSource() config.APIResourceConfigSource = limitedAPIResourceConfigSource()
master, err := New(&config) master, err := config.New()
if err != nil { if err != nil {
t.Fatalf("Error in bringing up the master: %v", err) t.Fatalf("Error in bringing up the master: %v", err)
} }
@@ -1262,7 +1262,7 @@ func TestValidOpenAPISpec(t *testing.T) {
Version: "unversioned", Version: "unversioned",
}, },
} }
master, err := New(&config) master, err := config.New()
if err != nil { if err != nil {
t.Fatalf("Error in bringing up the master: %v", err) t.Fatalf("Error in bringing up the master: %v", err)
} }

View File

@@ -67,7 +67,7 @@ func TestSubjectAccessReview(t *testing.T) {
masterConfig.Authenticator = authenticator.RequestFunc(alwaysAlice) masterConfig.Authenticator = authenticator.RequestFunc(alwaysAlice)
masterConfig.Authorizer = sarAuthorizer{} masterConfig.Authorizer = sarAuthorizer{}
masterConfig.AdmissionControl = admit.NewAlwaysAdmit() masterConfig.AdmissionControl = admit.NewAlwaysAdmit()
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
t.Fatalf("error in bringing up the master: %v", err) t.Fatalf("error in bringing up the master: %v", err)
} }
@@ -169,7 +169,7 @@ func TestSelfSubjectAccessReview(t *testing.T) {
}) })
masterConfig.Authorizer = sarAuthorizer{} masterConfig.Authorizer = sarAuthorizer{}
masterConfig.AdmissionControl = admit.NewAlwaysAdmit() masterConfig.AdmissionControl = admit.NewAlwaysAdmit()
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
t.Fatalf("error in bringing up the master: %v", err) t.Fatalf("error in bringing up the master: %v", err)
} }
@@ -257,7 +257,7 @@ func TestLocalSubjectAccessReview(t *testing.T) {
masterConfig.Authenticator = authenticator.RequestFunc(alwaysAlice) masterConfig.Authenticator = authenticator.RequestFunc(alwaysAlice)
masterConfig.Authorizer = sarAuthorizer{} masterConfig.Authorizer = sarAuthorizer{}
masterConfig.AdmissionControl = admit.NewAlwaysAdmit() masterConfig.AdmissionControl = admit.NewAlwaysAdmit()
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
t.Fatalf("error in bringing up the master: %v", err) t.Fatalf("error in bringing up the master: %v", err)
} }

View File

@@ -149,7 +149,7 @@ func startMasterOrDie(masterConfig *master.Config) (*master.Master, *httptest.Se
}, },
} }
} }
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
glog.Fatalf("error in bringing up the master: %v", err) glog.Fatalf("error in bringing up the master: %v", err)
} }

View File

@@ -73,7 +73,7 @@ func TestQuota(t *testing.T) {
masterConfig := framework.NewIntegrationTestMasterConfig() masterConfig := framework.NewIntegrationTestMasterConfig()
masterConfig.AdmissionControl = admission masterConfig.AdmissionControl = admission
m, err = master.New(masterConfig) m, err = masterConfig.New()
if err != nil { if err != nil {
t.Fatalf("Error in bringing up the master: %v", err) t.Fatalf("Error in bringing up the master: %v", err)
} }

View File

@@ -48,7 +48,7 @@ func mustSetupScheduler() (schedulerConfigFactory *factory.ConfigFactory, destro
var m *master.Master var m *master.Master
masterConfig := framework.NewIntegrationTestMasterConfig() masterConfig := framework.NewIntegrationTestMasterConfig()
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
panic("error in brining up the master: " + err.Error()) panic("error in brining up the master: " + err.Error())
} }

View File

@@ -412,7 +412,7 @@ func startServiceAccountTestServer(t *testing.T) (*clientset.Clientset, restclie
masterConfig.AdmissionControl = serviceAccountAdmission masterConfig.AdmissionControl = serviceAccountAdmission
// Create a master and install handlers into mux. // Create a master and install handlers into mux.
m, err := master.New(masterConfig) m, err := masterConfig.New()
if err != nil { if err != nil {
t.Fatalf("Error in bringing up the master: %v", err) t.Fatalf("Error in bringing up the master: %v", err)
} }