Allow override of kubeconfig dialer

k3s-io · Sep 16, 2021 · 5cbb88f · 5cbb88f
1 parent 29d1cbd
commit 5cbb88f
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go
@@ -78,6 +78,10 @@ import (
 	"k8s.io/kubernetes/pkg/serviceaccount"
 )
 
+var (
+	DefaultProxyDialerFn utilnet.DialFunc
+)
+
 // TODO: delete this check after insecure flags removed in v1.24
 func checkNonZeroInsecurePort(fs *pflag.FlagSet) error {
 	for _, name := range options.InsecurePortFlags {
@@ -177,7 +181,12 @@ func Run(completeOptions completedServerRunOptions, stopCh <-chan struct{}) erro
 
 // CreateServerChain creates the apiservers connected via delegation.
 func CreateServerChain(completedOptions completedServerRunOptions, stopCh <-chan struct{}) (*aggregatorapiserver.APIAggregator, error) {
+	if DefaultProxyDialerFn != nil {
+		completedOptions.KubeletConfig.Dial = DefaultProxyDialerFn
+	}
+
 	kubeAPIServerConfig, serviceResolver, pluginInitializer, err := CreateKubeAPIServerConfig(completedOptions)
+
 	if err != nil {
 		return nil, err
 	}