kubectl源码分析之config view

心已赠人 2023-02-21 01:56 29阅读 0赞

欢迎关注我的公众号：

watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAaHhwamF2YTE_size_8_color_FFFFFF_t_70_g_se_x_16

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

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

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

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

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

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

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

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

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

不懂envoyfilter也敢说精通istio系列http-jwt_authn-不要只会RequestAuthorization

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

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

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

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

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

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

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

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

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

  1. //创建config命令
  2. func NewCmdConfig(f cmdutil.Factory, pathOptions *clientcmd.PathOptions, streams genericclioptions.IOStreams) *cobra.Command {
  3.     if len(pathOptions.ExplicitFileFlag) == 0 {//设置kubeconfig选项名称
  4.         pathOptions.ExplicitFileFlag = clientcmd.RecommendedConfigPathFlag
  5.     }
  7.     cmd := &cobra.Command{//创建cobra命令
  8.         Use:                   "config SUBCOMMAND",
  9.         DisableFlagsInUseLine: true,
  10.         Short:                 i18n.T("Modify kubeconfig files"),
  11.         Long: templates.LongDesc(`
  12.             Modify kubeconfig files using subcommands like "kubectl config set current-context my-context"
  14.             The loading order follows these rules:
  16.             1. If the --` + pathOptions.ExplicitFileFlag + ` flag is set, then only that file is loaded. The flag may only be set once and no merging takes place.
  17.             2. If $` + pathOptions.EnvVar + ` environment variable is set, then it is used as a list of paths (normal path delimiting rules for your system). These paths are merged. When a value is modified, it is modified in the file that defines the stanza. When a value is created, it is created in the first file that exists. If no files in the chain exist, then it creates the last file in the list.
  18.             3. Otherwise, ` + path.Join("${HOME}", pathOptions.GlobalFileSubpath) + ` is used and no merging takes place.`),
  19.         Run: cmdutil.DefaultSubCommandRun(streams.ErrOut),
  20.     }
  22.     // file paths are common to all sub commands
  23.     cmd.PersistentFlags().StringVar(&pathOptions.LoadingRules.ExplicitPath, pathOptions.ExplicitFileFlag, pathOptions.LoadingRules.ExplicitPath, "use a particular kubeconfig file")//kubeconfig选项
  25.     // TODO(juanvallejo): update all subcommands to work with genericclioptions.IOStreams
  26.     cmd.AddCommand(NewCmdConfigView(f, streams, pathOptions))//添加view子命令
  27.     cmd.AddCommand(NewCmdConfigSetCluster(streams.Out, pathOptions))//set-cluster子命令
  28.     cmd.AddCommand(NewCmdConfigSetAuthInfo(streams.Out, pathOptions))//setauthinfo子命令
  29.     cmd.AddCommand(NewCmdConfigSetContext(streams.Out, pathOptions))//set-context子命令
  30.     cmd.AddCommand(NewCmdConfigSet(streams.Out, pathOptions))//set子命令
  31.     cmd.AddCommand(NewCmdConfigUnset(streams.Out, pathOptions))//unset子命令
  32.     cmd.AddCommand(NewCmdConfigCurrentContext(streams.Out, pathOptions))//current-context子命令
  33.     cmd.AddCommand(NewCmdConfigUseContext(streams.Out, pathOptions))//use-context子命令
  34.     cmd.AddCommand(NewCmdConfigGetContexts(streams, pathOptions))//get-context子命令
  35.     cmd.AddCommand(NewCmdConfigGetClusters(streams.Out, pathOptions))//get-cluster子命令
  36.     cmd.AddCommand(NewCmdConfigDeleteCluster(streams.Out, pathOptions))//delete-cluster子命令
  37.     cmd.AddCommand(NewCmdConfigDeleteContext(streams.Out, streams.ErrOut, pathOptions))//delete-context子命令
  38.     cmd.AddCommand(NewCmdConfigRenameContext(streams.Out, pathOptions))//rename-context子命令
  40.     return cmd
  41. }
  43. type ViewOptions struct {//view结构体
  44.     PrintFlags  *genericclioptions.PrintFlags
  45.     PrintObject printers.ResourcePrinterFunc
  47.     ConfigAccess clientcmd.ConfigAccess
  48.     Merge        cliflag.Tristate
  49.     Flatten      bool
  50.     Minify       bool
  51.     RawByteData  bool
  53.     Context      string
  54.     OutputFormat string
  56.     genericclioptions.IOStreams
  57. }
  59. //创建config命令
  60. func NewCmdConfigView(f cmdutil.Factory, streams genericclioptions.IOStreams, ConfigAccess clientcmd.ConfigAccess) *cobra.Command {
  61.     o := &ViewOptions{//初始化结构体
  62.         PrintFlags:   genericclioptions.NewPrintFlags("").WithTypeSetter(scheme.Scheme).WithDefaultOutput("yaml"),
  63.         ConfigAccess: ConfigAccess,
  65.         IOStreams: streams,
  66.     }
  68.     cmd := &cobra.Command{//创建cobra命令
  69.         Use:     "view",
  70.         Short:   i18n.T("Display merged kubeconfig settings or a specified kubeconfig file"),
  71.         Long:    viewLong,
  72.         Example: viewExample,
  73.         Run: func(cmd *cobra.Command, args []string) {
  74.             cmdutil.CheckErr(o.Complete(cmd, args))//准备
  75.             cmdutil.CheckErr(o.Validate())//校验
  76.             cmdutil.CheckErr(o.Run())//运行
  77.         },
  78.     }
  80.     o.PrintFlags.AddFlags(cmd)//打印选项
  82.     o.Merge.Default(true)//merge默认值
  83.     mergeFlag := cmd.Flags().VarPF(&o.Merge, "merge", "", "Merge the full hierarchy of kubeconfig files")//merge选项
  84.     mergeFlag.NoOptDefVal = "true"
  85.     cmd.Flags().BoolVar(&o.RawByteData, "raw", o.RawByteData, "Display raw byte data")//raw选项
  86.     cmd.Flags().BoolVar(&o.Flatten, "flatten", o.Flatten, "Flatten the resulting kubeconfig file into self-contained output (useful for creating portable kubeconfig files)")//flatten选项
  87.     cmd.Flags().BoolVar(&o.Minify, "minify", o.Minify, "Remove all information not used by current-context from the output")//minify选项
  88.     return cmd
  89. }
  91. //准备
  92. func (o *ViewOptions) Complete(cmd *cobra.Command, args []string) error {
  93.     if len(args) != 0 {//参数必须是0个
  94.         return cmdutil.UsageErrorf(cmd, "unexpected arguments: %v", args)
  95.     }
  96.     if o.ConfigAccess.IsExplicitFile() {//如果指定了kubeconfig选项
  97.         if !o.Merge.Provided() {//如果merge没设置，设置为false
  98.             o.Merge.Set("false")
  99.         }
  100.     }
  102.     printer, err := o.PrintFlags.ToPrinter()//print flag转printer
  103.     if err != nil {
  104.         return err
  105.     }
  106.     o.PrintObject = printer.PrintObj//设置printObject函数
  107.     o.Context = cmdutil.GetFlagString(cmd, "context")//设置context
  109.     return nil
  110. }
  112. func (o ViewOptions) Validate() error {//校验
  113.     if !o.Merge.Value() && !o.ConfigAccess.IsExplicitFile() {//如果merge为false，必须指定kubeconfig选项
  114.         return errors.New("if merge==false a precise file must to specified")
  115.     }
  117.     return nil
  118. }
  120. //运行
  121. func (o ViewOptions) Run() error {
  122.     config, err := o.loadConfig()//加载config
  123.     if err != nil {
  124.         return err
  125.     }
  127.     if o.Minify {//如果指定了minify
  128.         if len(o.Context) > 0 {//如果指定了context
  129.             config.CurrentContext = o.Context//设置config context
  130.         }
  131.         if err := clientcmdapi.MinifyConfig(config); err != nil {//修剪config
  132.             return err
  133.         }
  134.     }
  136.     if o.Flatten {// 如果指定了flattern
  137.         if err := clientcmdapi.FlattenConfig(config); err != nil {//flatten config
  138.             return err
  139.         }
  140.     } else if !o.RawByteData {//如果没指定raw
  141.         clientcmdapi.ShortenConfig(config)//shorten config
  142.     }
  144.     convertedObj, err := latest.Scheme.ConvertToVersion(config, latest.ExternalVersion)//转换config版本
  145.     if err != nil {
  146.         return err
  147.     }
  149.     return o.PrintObject(convertedObj, o.Out)//打印
  150. }
  152. func (o ViewOptions) loadConfig() (*clientcmdapi.Config, error) {//加载config
  153.     err := o.Validate()//校验
  154.     if err != nil {
  155.         return nil, err
  156.     }
  158.     config, err := o.getStartingConfig()//获取config
  159.     return config, err
  160. }
  162. // getStartingConfig returns the Config object built from the sources specified by the options, the filename read (only if it was a single file), and an error if something goes wrong
  163. func (o *ViewOptions) getStartingConfig() (*clientcmdapi.Config, error) {
  164.     switch {
  165.     case !o.Merge.Value():// 如果merge为false
  166.         return clientcmd.LoadFromFile(o.ConfigAccess.GetExplicitFile())//从文件加载
  168.     default:
  169.         return o.ConfigAccess.GetStartingConfig()//从configAccess加载
  170.     }
  171. }
  173. func MinifyConfig(config *Config) error {//修剪config
  174.     if len(config.CurrentContext) == 0 {//如果没有currentContext报错
  175.         return errors.New("current-context must exist in order to minify")
  176.     }
  178.     currContext, exists := config.Contexts[config.CurrentContext]//获取currentContext
  179.     if !exists {
  180.         return fmt.Errorf("cannot locate context %v", config.CurrentContext)
  181.     }
  183.     newContexts := map[string]*Context{}
  184.     newContexts[config.CurrentContext] = currContext//设置新的context
  186.     newClusters := map[string]*Cluster{}//clustermap
  187.     if len(currContext.Cluster) > 0 {//如果currentContext的cluster有值
  188.         if _, exists := config.Clusters[currContext.Cluster]; !exists {//获取当前cluster
  189.             return fmt.Errorf("cannot locate cluster %v", currContext.Cluster)
  190.         }
  192.         newClusters[currContext.Cluster] = config.Clusters[currContext.Cluster]//把cluster设置到newCluster里
  193.     }
  195.     newAuthInfos := map[string]*AuthInfo{}//newAuthinfos map
  196.     if len(currContext.AuthInfo) > 0 {//如果当前contenxt有授权信息
  197.         if _, exists := config.AuthInfos[currContext.AuthInfo]; !exists {//判断授权信息是否存在
  198.             return fmt.Errorf("cannot locate user %v", currContext.AuthInfo)
  199.         }
  201.         newAuthInfos[currContext.AuthInfo] = config.AuthInfos[currContext.AuthInfo]//设置newAuthInfos
  202.     }
  204.     config.AuthInfos = newAuthInfos//设置config当前上下文的信息
  205.     config.Clusters = newClusters
  206.     config.Contexts = newContexts
  208.     return nil
  209. }
  211. func FlattenConfig(config *Config) error {//flatten config
  212.     for key, authInfo := range config.AuthInfos {//遍历授权信息
  213.         baseDir, err := MakeAbs(path.Dir(authInfo.LocationOfOrigin), "")//获取授权信息秘钥基路径
  214.         if err != nil {
  215.             return err
  216.         }
  218.         if err := FlattenContent(&authInfo.ClientCertificate, &authInfo.ClientCertificateData, baseDir); err != nil {//从文件读取ClientCertificate信息，赋值给ClientCertificateData
  219.             return err
  220.         }
  221.         if err := FlattenContent(&authInfo.ClientKey, &authInfo.ClientKeyData, baseDir); err != nil {//从文件读取ClientKey信息赋值给ClientKeyData
  222.             return err
  223.         }
  225.         config.AuthInfos[key] = authInfo//设置授权信息
  226.     }
  227.     for key, cluster := range config.Clusters {//遍历clusters
  228.         baseDir, err := MakeAbs(path.Dir(cluster.LocationOfOrigin), "")//获取cluster秘钥信息基路径
  229.         if err != nil {
  230.             return err
  231.         }
  233.         if err := FlattenContent(&cluster.CertificateAuthority, &cluster.CertificateAuthorityData, baseDir); err != nil {//从文件读取CertificateAuthority，赋值给CertificateAuthorityData
  234.             return err
  235.         }
  237.         config.Clusters[key] = cluster//设置cluster
  238.     }
  240.     return nil
  241. }
  243. func ShortenConfig(config *Config) {//简化config
  244.     // trick json encoder into printing a human readable string in the raw data
  245.     // by base64 decoding what we want to print. Relies on implementation of
  246.     // http://golang.org/pkg/encoding/json/#Marshal using base64 to encode []byte
  247.     for key, authInfo := range config.AuthInfos {//遍历授权信息
  248.         if len(authInfo.ClientKeyData) > 0 {
  249.             authInfo.ClientKeyData = redactedBytes//设置ClientKeyData 
  250.         }
  251.         if len(authInfo.ClientCertificateData) > 0 {
  252.             authInfo.ClientCertificateData = redactedBytes//设置ClientCertificateData 
  253.         }
  254.         config.AuthInfos[key] = authInfo//设置授权信息
  255.     }
  256.     for key, cluster := range config.Clusters {
  257.         if len(cluster.CertificateAuthorityData) > 0 {
  258.             cluster.CertificateAuthorityData = dataOmittedBytes//设置CertificateAuthorityData 
  259.         }
  260.         config.Clusters[key] = cluster//设置cluster
  261.     }
  262. }

发表评论

表情：
评论列表 （有 0 条评论，29人围观）

还没有评论，来说两句吧...

相关阅读