Skip to content

K
k3s
Commit f5a5f188 authored by Darren Shepherd's avatar Darren Shepherd Committed by Erik Wilson
Browse files
Options

Allow override of kubeconfig dialer

parent 0b80546d
Show whitespace changes
Inline Side-by-side
Showing with 8 additions and 0 deletions
cmd/kube-apiserver/app/server.go
View file @ f5a5f188
...@@ -77,6 +77,10 @@ import ( ...@@ -77,6 +77,10 @@ import (
const etcdRetryLimit = 60 const etcdRetryLimit = 60
const etcdRetryInterval = 1 * time.Second const etcdRetryInterval = 1 * time.Second
var (
DefaultProxyDialerFn utilnet.DialFunc
)
// NewAPIServerCommand creates a *cobra.Command object with default parameters // NewAPIServerCommand creates a *cobra.Command object with default parameters
func NewAPIServerCommand(stopCh <-chan struct{}) *cobra.Command { func NewAPIServerCommand(stopCh <-chan struct{}) *cobra.Command {
s := options.NewServerRunOptions() s := options.NewServerRunOptions()
...@@ -161,6 +165,10 @@ func CreateServerChain(completedOptions completedServerRunOptions, stopCh <-chan ...@@ -161,6 +165,10 @@ func CreateServerChain(completedOptions completedServerRunOptions, stopCh <-chan
return nil, nil, err return nil, nil, err
} }
if DefaultProxyDialerFn != nil {
completedOptions.KubeletConfig.Dial = DefaultProxyDialerFn
}
kubeAPIServerConfig, insecureServingInfo, serviceResolver, pluginInitializer, admissionPostStartHook, err := CreateKubeAPIServerConfig(completedOptions, proxyTransport) kubeAPIServerConfig, insecureServingInfo, serviceResolver, pluginInitializer, admissionPostStartHook, err := CreateKubeAPIServerConfig(completedOptions, proxyTransport)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment