kubectl源码分析之create priorityclass

 欢迎关注我的公众号：

————————————————------------------------------------------------------------------------------------

type PriorityClassOpts struct {//pc结构体
  CreateSubcommandOptions *CreateSubcommandOptions
}

//创建pc命令
func NewCmdCreatePriorityClass(f cmdutil.Factory, ioStreams genericclioptions.IOStreams) *cobra.Command {
  options := &PriorityClassOpts{//初始化pc结构体
    CreateSubcommandOptions: NewCreateSubcommandOptions(ioStreams),
  }

  cmd := &cobra.Command{//创建cobra命令
    Use:                   "priorityclass NAME --value=VALUE --global-default=BOOL [--dry-run]",
    DisableFlagsInUseLine: true,
    Aliases:               []string{"pc"},
    Short:                 i18n.T("Create a priorityclass with the specified name."),
    Long:                  pcLong,
    Example:               pcExample,
    Run: func(cmd *cobra.Command, args []string) {
      cmdutil.CheckErr(options.Complete(f, cmd, args))//准备运行
      cmdutil.CheckErr(options.Run())//运行命令
    },
  }

  options.CreateSubcommandOptions.PrintFlags.AddFlags(cmd)//设置print选项

  cmdutil.AddApplyAnnotationFlags(cmd)//设置save-config选项
  cmdutil.AddValidateFlags(cmd)//设置valdate选项
  cmdutil.AddGeneratorFlags(cmd, generateversioned.PriorityClassV1GeneratorName)//设置generator选项

  cmd.Flags().Int32("value", 0, i18n.T("the value of this priority class."))//设置value选项
  cmd.Flags().Bool("global-default", false, i18n.T("global-default specifies whether this PriorityClass should be considered as the default priority."))//设置global-default选项
  cmd.Flags().String("description", "", i18n.T("description is an arbitrary string that usually provides guidelines on when this priority class should be used."))//设置description选项
  cmd.Flags().String("preemption-policy", "", i18n.T("preemption-policy is the policy for preempting pods with lower priority."))//设置preemption-policy选项
  return cmd
}

//准备运行
func (o *PriorityClassOpts) Complete(f cmdutil.Factory, cmd *cobra.Command, args []string) error {
  name, err := NameFromCommandArgs(cmd, args)//获取名称
  if err != nil {
    return err
  }

  var generator generate.StructuredGenerator
  switch generatorName := cmdutil.GetFlagString(cmd, "generator"); generatorName {
  case generateversioned.PriorityClassV1GeneratorName://湖区generator名称并判断
    generator = &generateversioned.PriorityClassV1Generator{
      Name:             name,
      Value:            cmdutil.GetFlagInt32(cmd, "value"),
      GlobalDefault:    cmdutil.GetFlagBool(cmd, "global-default"),
      Description:      cmdutil.GetFlagString(cmd, "description"),
      PreemptionPolicy: apiv1.PreemptionPolicy(cmdutil.GetFlagString(cmd, "preemption-policy")),
    }
  default:
    return errUnsupportedGenerator(cmd, generatorName)
  }

  return o.CreateSubcommandOptions.Complete(f, cmd, args, generator)//运行createSubCommandOption的complete方法
}

// Run calls the CreateSubcommandOptions.Run in the PriorityClassOpts instance
func (o *PriorityClassOpts) Run() error {//运行命令
  return o.CreateSubcommandOptions.Run()//运行createSubCommandOption的run方法
}