kubectl源码分析之config set

谁借莪１个温暖的怀抱￠ 2023-02-21 11:40 40阅读 0赞

#  欢迎关注我的公众号： #

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAaHhwamF2YTE_size_8_color_FFFFFF_t_70_g_se_x_16][]

目前刚开始写一个月，一共写了18篇原创文章，文章目录如下：

[istio多集群探秘，部署了50次多集群后我得出的结论][istio_50]

[istio多集群链路追踪，附实操视频][istio]

[istio防故障利器，你知道几个,istio新手不要读，太难！][istio_istio]

[istio业务权限控制，原来可以这么玩][istio 1]

[istio实现非侵入压缩，微服务之间如何实现压缩][istio 2]

[不懂envoyfilter也敢说精通istio系列-http-rbac-不要只会用AuthorizationPolicy配置权限][envoyfilter_istio_-http-rbac-_AuthorizationPolicy]

[不懂envoyfilter也敢说精通istio系列-02-http-corsFilter-不要只会vs][envoyfilter_istio_-02-http-corsFilter-_vs]

[不懂envoyfilter也敢说精通istio系列-03-http-csrf filter-再也不用再代码里写csrf逻辑了][envoyfilter_istio_-03-http-csrf filter-_csrf]

[不懂envoyfilter也敢说精通istio系列http-jwt\_authn-不要只会RequestAuthorization][envoyfilter_istio_http-jwt_authn-_RequestAuthorization]

[不懂envoyfilter也敢说精通istio系列-05-fault-filter-故障注入不止是vs][envoyfilter_istio_-05-fault-filter-_vs]

[不懂envoyfilter也敢说精通istio系列-06-http-match-配置路由不只是vs][envoyfilter_istio_-06-http-match-_vs]

[不懂envoyfilter也敢说精通istio系列-07-负载均衡配置不止是dr][envoyfilter_istio_-07-_dr]

[不懂envoyfilter也敢说精通istio系列-08-连接池和断路器][envoyfilter_istio_-08-]

[不懂envoyfilter也敢说精通istio系列-09-http-route filter][envoyfilter_istio_-09-http-route filter]

[不懂envoyfilter也敢说精通istio系列-network filter-redis proxy][envoyfilter_istio_-network filter-redis proxy]

[不懂envoyfilter也敢说精通istio系列-network filter-HttpConnectionManager][envoyfilter_istio_-network filter-HttpConnectionManager]

[不懂envoyfilter也敢说精通istio系列-ratelimit-istio ratelimit完全手册][envoyfilter_istio_-ratelimit-istio ratelimit]

————————————————

type setOptions struct {//set结构体
    	configAccess  clientcmd.ConfigAccess
    	propertyName  string
    	propertyValue string
    	setRawBytes   cliflag.Tristate
    }

//创建set命令
    func NewCmdConfigSet(out io.Writer, configAccess clientcmd.ConfigAccess) *cobra.Command {
    	options := &setOptions{configAccess: configAccess}//初始化结构体
    
    	cmd := &cobra.Command{//创建cobra命令
    		Use:                   "set PROPERTY_NAME PROPERTY_VALUE",
    		DisableFlagsInUseLine: true,
    		Short:                 i18n.T("Sets an individual value in a kubeconfig file"),
    		Long:                  setLong,
    		Example:               setExample,
    		Run: func(cmd *cobra.Command, args []string) {
    			cmdutil.CheckErr(options.complete(cmd))//准备
    			cmdutil.CheckErr(options.run())//运行
    			fmt.Fprintf(out, "Property %q set.\n", options.propertyName)//打印结果
    		},
    	}
    
    	f := cmd.Flags().VarPF(&options.setRawBytes, "set-raw-bytes", "", "When writing a []byte PROPERTY_VALUE, write the given string directly without base64 decoding.")//set-raw-bytes选项
    	f.NoOptDefVal = "true"
    	return cmd
    }

func (o *setOptions) complete(cmd *cobra.Command) error {//准备
    	endingArgs := cmd.Flags().Args()//获取参数
    	if len(endingArgs) != 2 {//参数必须是2个
    		return helpErrorf(cmd, "Unexpected args: %v", endingArgs)
    	}
    
    	o.propertyValue = endingArgs[1]//设置propertyValue
    	o.propertyName = endingArgs[0]//设置propertyName
    	return nil
    }

func (o setOptions) validate() error {//校验
    	if len(o.propertyValue) == 0 {//propertyValue不能为空
    		return errors.New("you cannot use set to unset a property")
    	}
    
    	if len(o.propertyName) == 0 {//propertyName不能为空
    		return errors.New("you must specify a property")
    	}
    
    	return nil
    }

func (o setOptions) run() error {//运行
    	err := o.validate()//校验
    	if err != nil {
    		return err
    	}
    
    	config, err := o.configAccess.GetStartingConfig()//加载config
    	if err != nil {
    		return err
    	}
    	steps, err := newNavigationSteps(o.propertyName)//创建steps
    	if err != nil {
    		return err
    	}
    
    	setRawBytes := false
    	if o.setRawBytes.Provided() {//如果设置了set-raw-bytes,设置setRawBytes 
    		setRawBytes = o.setRawBytes.Value()
    	}
    
    	err = modifyConfig(reflect.ValueOf(config), steps, o.propertyValue, false, setRawBytes)//修改配置
    	if err != nil {
    		return err
    	}
    
    	if err := clientcmd.ModifyConfig(o.configAccess, *config, false); err != nil {/保存配置到文件
    		return err
    	}
    
    	return nil
    }

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAaHhwamF2YTE_size_8_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/20211007094240106.jpg?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBAaHhwamF2YTE=,size_8,color_FFFFFF,t_70,g_se,x_16
[istio_50]: https://mp.weixin.qq.com/s/_OPMjmWCDSTlmbAxytg33A
[istio]: https://mp.weixin.qq.com/s/kjvtno_UzJAGr1joxm3tvw
[istio_istio]: https://mp.weixin.qq.com/s/e2-p_NY31Mc5y07S4Bb1JQ
[istio 1]: https://mp.weixin.qq.com/s/iTV0SCQLhSOTYncp3PxoHQ
[istio 2]: https://mp.weixin.qq.com/s/eINlrT242RlAwfuZu1_PcA
[envoyfilter_istio_-http-rbac-_AuthorizationPolicy]: https://mp.weixin.qq.com/s/Q-yTGBNqkjOov49LTXPrPA
[envoyfilter_istio_-02-http-corsFilter-_vs]: https://mp.weixin.qq.com/s/bFMdrT7OKSqoWv8pDXOIqQ
[envoyfilter_istio_-03-http-csrf filter-_csrf]: https://mp.weixin.qq.com/s/dlG9phV-kMMxs4UPzuRNYg
[envoyfilter_istio_http-jwt_authn-_RequestAuthorization]: https://mp.weixin.qq.com/s/IfrJ-FdLYsdhPkDrcO_YXA
[envoyfilter_istio_-05-fault-filter-_vs]: https://mp.weixin.qq.com/s/a4gDXqD8uswgglMwkUph2Q
[envoyfilter_istio_-06-http-match-_vs]: https://mp.weixin.qq.com/s/TpS3DHdcaJiPivIS_jsIGw
[envoyfilter_istio_-07-_dr]: https://mp.weixin.qq.com/s/k-zJm7n7OOKg6MotQJYPAA
[envoyfilter_istio_-08-]: https://mp.weixin.qq.com/s/n_bJ3saNeTtXRprIymhwzg
[envoyfilter_istio_-09-http-route filter]: https://mp.weixin.qq.com/s/JAeZr0BMVQxIrB3S_7Ru0A
[envoyfilter_istio_-network filter-redis proxy]: https://mp.weixin.qq.com/s/B9IPTI8F3q42nVkqbQRlPw
[envoyfilter_istio_-network filter-HttpConnectionManager]: https://mp.weixin.qq.com/s/W3OPQWkCVvuHGS49cTNhlg
[envoyfilter_istio_-ratelimit-istio ratelimit]: https://mp.weixin.qq.com/s/KgiDsELNol27mgZvDbFsqw