@@ -68,6 +68,9 @@ import (
68
68
"k8s.io/kubernetes/cmd/kube-apiserver/app/options"
69
69
"k8s.io/kubernetes/pkg/api/legacyscheme"
70
70
"k8s.io/kubernetes/pkg/capabilities"
71
+ "k8s.io/kubernetes/pkg/controlplane"
72
+ "k8s.io/kubernetes/pkg/controlplane/reconcilers"
73
+ "k8s.io/kubernetes/pkg/controlplane/tunneler"
71
74
"k8s.io/kubernetes/pkg/features"
72
75
generatedopenapi "k8s.io/kubernetes/pkg/generated/openapi"
73
76
"k8s.io/kubernetes/pkg/kubeapiserver"
@@ -76,9 +79,6 @@ import (
76
79
"k8s.io/kubernetes/pkg/kubeapiserver/authorizer/modes"
77
80
kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options"
78
81
kubeserver "k8s.io/kubernetes/pkg/kubeapiserver/server"
79
- "k8s.io/kubernetes/pkg/master"
80
- "k8s.io/kubernetes/pkg/master/reconcilers"
81
- "k8s.io/kubernetes/pkg/master/tunneler"
82
82
rbacrest "k8s.io/kubernetes/pkg/registry/rbac/rest"
83
83
"k8s.io/kubernetes/pkg/serviceaccount"
84
84
)
@@ -225,7 +225,7 @@ func CreateServerChain(completedOptions completedServerRunOptions, stopCh <-chan
225
225
}
226
226
227
227
// CreateKubeAPIServer creates and wires a workable kube-apiserver
228
- func CreateKubeAPIServer (kubeAPIServerConfig * master .Config , delegateAPIServer genericapiserver.DelegationTarget ) (* master .Master , error ) {
228
+ func CreateKubeAPIServer (kubeAPIServerConfig * controlplane .Config , delegateAPIServer genericapiserver.DelegationTarget ) (* controlplane .Master , error ) {
229
229
kubeAPIServer , err := kubeAPIServerConfig .Complete ().New (delegateAPIServer )
230
230
if err != nil {
231
231
return nil , err
@@ -287,7 +287,7 @@ func CreateKubeAPIServerConfig(
287
287
nodeTunneler tunneler.Tunneler ,
288
288
proxyTransport * http.Transport ,
289
289
) (
290
- * master .Config ,
290
+ * controlplane .Config ,
291
291
* genericapiserver.DeprecatedInsecureServingInfo ,
292
292
aggregatorapiserver.ServiceResolver ,
293
293
[]admission.PluginInitializer ,
@@ -320,7 +320,7 @@ func CreateKubeAPIServerConfig(
320
320
321
321
s .Logs .Apply ()
322
322
323
- serviceIPRange , apiServerServiceIP , err := master .ServiceIPRange (s .PrimaryServiceClusterIPRange )
323
+ serviceIPRange , apiServerServiceIP , err := controlplane .ServiceIPRange (s .PrimaryServiceClusterIPRange )
324
324
if err != nil {
325
325
return nil , nil , nil , nil , err
326
326
}
@@ -329,15 +329,15 @@ func CreateKubeAPIServerConfig(
329
329
var secondaryServiceIPRange net.IPNet
330
330
// process secondary range only if provided by user
331
331
if s .SecondaryServiceClusterIPRange .IP != nil {
332
- secondaryServiceIPRange , _ , err = master .ServiceIPRange (s .SecondaryServiceClusterIPRange )
332
+ secondaryServiceIPRange , _ , err = controlplane .ServiceIPRange (s .SecondaryServiceClusterIPRange )
333
333
if err != nil {
334
334
return nil , nil , nil , nil , err
335
335
}
336
336
}
337
337
338
- config := & master .Config {
338
+ config := & controlplane .Config {
339
339
GenericConfig : genericConfig ,
340
- ExtraConfig : master .ExtraConfig {
340
+ ExtraConfig : controlplane .ExtraConfig {
341
341
APIResourceConfigSource : storageFactory .APIResourceConfigSource ,
342
342
StorageFactory : storageFactory ,
343
343
EventTTL : s .EventTTL ,
@@ -442,7 +442,7 @@ func buildGenericConfig(
442
442
lastErr error ,
443
443
) {
444
444
genericConfig = genericapiserver .NewConfig (legacyscheme .Codecs )
445
- genericConfig .MergedResourceConfig = master .DefaultAPIResourceConfigSource ()
445
+ genericConfig .MergedResourceConfig = controlplane .DefaultAPIResourceConfigSource ()
446
446
447
447
if lastErr = s .GenericServerRunOptions .ApplyTo (genericConfig ); lastErr != nil {
448
448
return
@@ -457,7 +457,7 @@ func buildGenericConfig(
457
457
if lastErr = s .Features .ApplyTo (genericConfig ); lastErr != nil {
458
458
return
459
459
}
460
- if lastErr = s .APIEnablement .ApplyTo (genericConfig , master .DefaultAPIResourceConfigSource (), legacyscheme .Scheme ); lastErr != nil {
460
+ if lastErr = s .APIEnablement .ApplyTo (genericConfig , controlplane .DefaultAPIResourceConfigSource (), legacyscheme .Scheme ); lastErr != nil {
461
461
return
462
462
}
463
463
if lastErr = s .EgressSelector .ApplyTo (genericConfig ); lastErr != nil {
@@ -727,7 +727,7 @@ func getServiceIPAndRanges(serviceClusterIPRanges string) (net.IP, net.IPNet, ne
727
727
// nothing provided by user, use default range (only applies to the Primary)
728
728
if len (serviceClusterIPRangeList ) == 0 {
729
729
var primaryServiceClusterCIDR net.IPNet
730
- primaryServiceIPRange , apiServerServiceIP , err = master .ServiceIPRange (primaryServiceClusterCIDR )
730
+ primaryServiceIPRange , apiServerServiceIP , err = controlplane .ServiceIPRange (primaryServiceClusterCIDR )
731
731
if err != nil {
732
732
return net.IP {}, net.IPNet {}, net.IPNet {}, fmt .Errorf ("error determining service IP ranges: %v" , err )
733
733
}
@@ -740,7 +740,7 @@ func getServiceIPAndRanges(serviceClusterIPRanges string) (net.IP, net.IPNet, ne
740
740
return net.IP {}, net.IPNet {}, net.IPNet {}, fmt .Errorf ("service-cluster-ip-range[0] is not a valid cidr" )
741
741
}
742
742
743
- primaryServiceIPRange , apiServerServiceIP , err = master .ServiceIPRange (* (primaryServiceClusterCIDR ))
743
+ primaryServiceIPRange , apiServerServiceIP , err = controlplane .ServiceIPRange (* (primaryServiceClusterCIDR ))
744
744
if err != nil {
745
745
return net.IP {}, net.IPNet {}, net.IPNet {}, fmt .Errorf ("error determining service IP ranges for primary service cidr: %v" , err )
746
746
}
0 commit comments