k8s 开源_openstack源码

k8s 开源_openstack源码createfunc main() { #随机数 rand.Seed(time.Now().UnixNano()) #创建一个新的命令行对象 command := cmd.NewDefaultKubectlCommand() #日志 logs.InitLogs() defer logs.FlushLogs() #真正执行的命令行 if err := command.Execute(); err != nil { os.Exit(1) }}# NewDefaultKubectl

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

create

func main() { 
   
	#随机数
	rand.Seed(time.Now().UnixNano())
	#创建一个新的命令行对象
	command := cmd.NewDefaultKubectlCommand()
	#日志
	logs.InitLogs()
	defer logs.FlushLogs()
	#真正执行的命令行
	if err := command.Execute(); err != nil { 
   
		os.Exit(1)
	}
}
# NewDefaultKubectlCommand函数
# in io.Reader, out, errout io.Writer 标准输入 标准输出 标准错误输出
func NewDefaultKubectlCommandWithArgs(pluginHandler PluginHandler, args []string, in io.Reader, out, errout io.Writer) *cobra.Command { 
   
	#创建一个新的命令行
	cmd := NewKubectlCommand(in, out, errout)
	if len(args) > 1 { 
   
	
	#第一个参数 即create -f nginx_pod.yml部分
		cmdPathPieces := args[1:]
		#调用cmd的find函数去匹配参数
		if _, _, err := cmd.Find(cmdPathPieces); err != nil { 
   
			if err := HandlePluginCommand(pluginHandler, cmdPathPieces); err != nil { 
   
				fmt.Fprintf(errout, "Error: %v\n", err)
				os.Exit(1)
			}
		}
	}

	return cmd
}
func NewKubectlCommand(in io.Reader, out, err io.Writer) *cobra.Command { 
   
	#打印help出现的信息
	cmds := &cobra.Command{ 
   
		Use:   "kubectl",
		Short: i18n.T("kubectl controls the Kubernetes cluster manager"),
		Long: templates.LongDesc(` kubectl controls the Kubernetes cluster manager. Find more information at: https://kubernetes.io/docs/reference/kubectl/overview/`),
		Run: runHelp,

		#运行函数之前的钩子
		PersistentPreRunE: func(*cobra.Command, []string) error { 
   
			rest.SetDefaultWarningHandler(warningHandler)
			#运行前初始化性能评估的工作
			return initProfiling()
		},
		#运行函数之后的钩子
		PersistentPostRunE: func(*cobra.Command, []string) error { 
   
			#运行后的保存性能检测的工作
			if err := flushProfiling(); err != nil { 
   
				return err
			}
			#打印警报
			if warningsAsErrors { 
   
				,,,
			}
			return nil
		},
	}
	groups := templates.CommandGroups{ 
   
		{ 
   
			#命令的信息 初级命令
			Message: "Basic Commands (Beginner):",
			#里面有create expose run set 命令
			Commands: []*cobra.Command{ 
   
				create.NewCmdCreate(f, ioStreams),
				expose.NewCmdExposeService(f, ioStreams),
				run.NewCmdRun(f, ioStreams),
				set.NewCmdSet(f, ioStreams),
			},
		},
		{ 
   
			#中级命令
			Message: "Basic Commands (Intermediate):",
			#包含explain get edit 等
			Commands: []*cobra.Command{ 
   
				explain.NewCmdExplain("kubectl", f, ioStreams),
				get.NewCmdGet("kubectl", f, ioStreams),
				edit.NewCmdEdit(f, ioStreams),
				delete.NewCmdDelete(f, ioStreams),
			},
		},
		{ 
   	#部署相关的内容
			Message: "Deploy Commands:",
			Commands: []*cobra.Command{ 
   
				rollout.NewCmdRollout(f, ioStreams),
				scale.NewCmdScale(f, ioStreams),
				autoscale.NewCmdAutoscale(f, ioStreams),
			},
		},
		...
		# kubectl下面添加的其他的一些子命令
		cmds.AddCommand(alpha)
	cmds.AddCommand(cmdconfig.NewCmdConfig(clientcmd.NewDefaultPathOptions(), ioStreams))
	cmds.AddCommand(plugin.NewCmdPlugin(ioStreams))
#create.NewCmdCreate(f, ioStreams),
func NewCmdCreate(f cmdutil.Factory, ioStreams genericclioptions.IOStreams) *cobra.Command { 
   
	o := NewCreateOptions(ioStreams)
	
	cmd := &cobra.Command{ 
   
		Use:                   "create -f FILENAME",#范例和我们的命令很相似
		DisableFlagsInUseLine: true,
		Short:                 i18n.T("Create a resource from a file or from stdin"),
		Long:                  createLong,
		Example:               createExample,	#提供的其他一些创建的实例
		
		Run: func(cmd *cobra.Command, args []string) { 
   
			#文件名是否为空
			if cmdutil.IsFilenameSliceEmpty(o.FilenameOptions.Filenames, o.FilenameOptions.Kustomize) { 
   
			...
			}
			#验证参数
			cmdutil.CheckErr(o.ValidateArgs(cmd, args))
			#真正的运行create函数
			cmdutil.CheckErr(o.RunCreate(f, cmd))
		},
	}
	...
	#创建create 下面的子命令
	// create subcommands
	cmd.AddCommand(NewCmdCreateNamespace(f, ioStreams))
	...
}
#RunCreate
#f为传入的Factory 主要是封装了与kube-apiserver交互的客户端
func (o *CreateOptions) RunCreate(f cmdutil.Factory, cmd *cobra.Command) error { 
   	
	...
	#验证命令是否合法
	schema, err := f.Validator(cmdutil.GetFlagBool(cmd, "validate"))
	if err != nil { 
   
		return err
	}
	...
	#builder
	r := f.NewBuilder().
		...
		NamespaceParam(cmdNamespace).DefaultNamespace().
		#支持那种类型的filename  支持 管道的 也支持http 和 https的
		FilenameParam(enforceNamespace, &o.FilenameOptions).
		...
		#真正执行代码
		Do()
	err = r.Err()
	if err != nil { 
   
		return err
	}
		...
		count++
		#最后在命令行打印create XXX成功创建
		return o.PrintObj(info.Object)
	})
	...
}

Create->CreateWithOptions->createResource

# createResource
#客户端采用RESTFUL风格的 runtime,object是对资源的抽象
func (m *Helper) createResource(c RESTClient, resource, namespace string, obj runtime.Object, options *metav1.CreateOptions) (runtime.Object, error) { 
   
	#Post对应RestFul里面 post方法
	return c.Post().
		NamespaceIfScoped(namespace, m.NamespaceScoped).
		Resource(resource).
		VersionedParams(options, metav1.ParameterCodec).
		Body(obj).
		#将request转换成result
		Do(context.TODO()).
		#将result转换成为资源对象
		Get()
}
#Do函数
func (r *Request) Do(ctx context.Context) Result { 
   
	var result Result
	#发送请求到server创建资源
	err := r.request(ctx, func(req *http.Request, resp *http.Response) { 
   
		根据返回的resp和req转换对象
		result = r.transformResponse(resp, req)
	})
	return result
}

Do –> r.request->resp, err := client.Do(req) –> resp, err := client.Do(req) –> esp, didTimeout, err = c.send(req, deadline) –> resp, didTimeout, err = send(req, c.transport(), deadline) –> RoundTrip(*Request) (*Response, error) 轮询算法 –> 发送请求给server 获得response

在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/168520.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Pycharm 2021年激活码【注册码】

    Pycharm 2021年激活码【注册码】,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • vscode golang环境搭建「建议收藏」

    vscode golang环境搭建「建议收藏」vscode安装百度下载可执行文件,一路nextgolang安装下载地址为:https://golang.google.cn/dl/如果是linux环境,解压到某个目录。然后配置/etc/profile设置相关环境变量如果是windows环境,下载https://dl.google.com/go/go1.13.5.windows-amd64.msi,然后设置环境变量。环境变量为:G…

  • 基于CBC模式和PKCS5padding的DES加解密模块

    基于CBC模式和PKCS5padding的DES加解密模块

  • 光纤通信视频_光纤传输的信号属于什么

    光纤通信视频_光纤传输的信号属于什么目前,光纤在生产和施工方面较于以前有了很大的提升,价格也降低了很多。再加上光纤的传输质量,光纤无疑将成为发展较快的传输模式。马上为您全面剖析光纤传输技术。  光纤通信的原理:在发送端首先要把传送的信息(如视频)变成电信号,然后调制到激光器发出的激光束上,使光的强度随电信号的幅度(频率)变化而变化,并通过光纤发送出去;在接收端,检测器收到光信号后把它变换成电信号,经解调后恢复原信息。  光纤监…

  • 查看服务器并发连接数_查看数据库当前连接数

    查看服务器并发连接数_查看数据库当前连接数查看Sql Server当前的并发连接数

  • hint什么意思啊_unable to sendviapost to url

    hint什么意思啊_unable to sendviapost to url我先说下我的场景测试号群发图文消息答案是不能但是微信返回的错误信息是{“errcode”:40008,”errmsg”:”invalidmessagetypehint:[6MkYZa03824811]”}但是我检查了我的数据应该没问题,所以应该就是测试号不能群发,后面我在开发社区看到帖子原地址还有问了一下我们技术老大也证实了不能,至于微信的返回的错误码,暂时一米哇干奶…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号