github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 01:06:27 +00:00
Code Issues Projects Releases Wiki Activity

Add --disable-compression flag to kubectl

Browse Source
This commit is contained in:
Shyam Jeedigunta 2022-09-19 11:59:50 -07:00
parent 04ee339c7a
commit 0663a8ff45
1 changed files with 59 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go
View File

@ -55,6 +55,7 @@ const (
flagPassword = "password" flagPassword = "password"
flagTimeout = "request-timeout" flagTimeout = "request-timeout"
flagCacheDir = "cache-dir" flagCacheDir = "cache-dir"
flagDisableCompression = "disable-compression"
) )
// RESTClientGetter is an interface that the ConfigFlags describe to provide an easier way to mock for commands // RESTClientGetter is an interface that the ConfigFlags describe to provide an easier way to mock for commands
@ -97,6 +98,7 @@ type ConfigFlags struct {
Username *string Username *string
Password *string Password *string
Timeout *string Timeout *string
DisableCompression *bool
// If non-nil, wrap config function can transform the Config // If non-nil, wrap config function can transform the Config
// before it is returned in ToRESTConfig function. // before it is returned in ToRESTConfig function.
WrapConfigFn func(*rest.Config) *rest.Config WrapConfigFn func(*rest.Config) *rest.Config
@ -199,6 +201,9 @@ func (f *ConfigFlags) toRawKubeConfigLoader() clientcmd.ClientConfig {
if f.Insecure != nil { if f.Insecure != nil {
overrides.ClusterInfo.InsecureSkipTLSVerify = *f.Insecure overrides.ClusterInfo.InsecureSkipTLSVerify = *f.Insecure
} }
if f.DisableCompression != nil {
overrides.ClusterInfo.DisableCompression = *f.DisableCompression
}
// bind context flags // bind context flags
if f.Context != nil { if f.Context != nil {
@ -393,6 +398,9 @@ func (f *ConfigFlags) AddFlags(flags *pflag.FlagSet) {
if f.Timeout != nil { if f.Timeout != nil {
flags.StringVar(f.Timeout, flagTimeout, *f.Timeout, "The length of time to wait before giving up on a single server request. Non-zero values should contain a corresponding time unit (e.g. 1s, 2m, 3h). A value of zero means don't timeout requests.") flags.StringVar(f.Timeout, flagTimeout, *f.Timeout, "The length of time to wait before giving up on a single server request. Non-zero values should contain a corresponding time unit (e.g. 1s, 2m, 3h). A value of zero means don't timeout requests.")
} }
if f.DisableCompression != nil {
flags.BoolVar(f.DisableCompression, flagDisableCompression, *f.DisableCompression, "If true, opt-out of response compression for all requests to the server")
}
} }
// WithDeprecatedPasswordFlag enables the username and password config flags // WithDeprecatedPasswordFlag enables the username and password config flags
@ -424,6 +432,7 @@ func (f *ConfigFlags) WithWrapConfigFn(wrapConfigFn func(*rest.Config) *rest.Con
func NewConfigFlags(usePersistentConfig bool) *ConfigFlags { func NewConfigFlags(usePersistentConfig bool) *ConfigFlags {
impersonateGroup := []string{} impersonateGroup := []string{}
insecure := false insecure := false
disableCompression := false
return &ConfigFlags{ return &ConfigFlags{
Insecure: &insecure, Insecure: &insecure,
@ -444,6 +453,7 @@ func NewConfigFlags(usePersistentConfig bool) *ConfigFlags {
Impersonate: utilpointer.String(""), Impersonate: utilpointer.String(""),
ImpersonateUID: utilpointer.String(""), ImpersonateUID: utilpointer.String(""),
ImpersonateGroup: &impersonateGroup, ImpersonateGroup: &impersonateGroup,
DisableCompression: &disableCompression,
usePersistentConfig: usePersistentConfig, usePersistentConfig: usePersistentConfig,
// The more groups you have, the more discovery requests you need to make. // The more groups you have, the more discovery requests you need to make.