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)
blank

相关推荐

  • phpstorm 2021激活码3月最新在线激活

    phpstorm 2021激活码3月最新在线激活,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • ft232芯片怎么样_引脚悬空是什么电平

    ft232芯片怎么样_引脚悬空是什么电平概述:FF4232H芯片一款专门用于USB到RS232/RS485/RS422之间的电平转换芯片,数据收发和协议转换工作全由芯片独立完成,无需人工干预,不用编写芯片的固件,给设计者带来了极大的便利。利用该芯片只需要加少量的外围电路就可以实现相应的转换。FT4232H采用64-LDLeadFreeLQFPorQFN封装工艺。一、FT4232H功能和特性1、单芯片到4路串口的转换,整个接口协…

  • 华为ensp安装步骤_网购200多的平板电脑靠谱吗

    华为ensp安装步骤_网购200多的平板电脑靠谱吗华为ENSP安装教程有需要的请点击这个连接下载自行下载:https://pan.baidu.com/s/1ORprW88r5RBKfHFmEzimow?pwd=0118提取码:0118下载好了可以看到以下这四个程序:软件安装顺序:WinPcap、Wireshark、VirtualBox、eNSP前三个建议均采用默认安装路径安装特别提示:不准出现中文路径,如果可以四个都默认安装路径的话,那最好!注………..

    2022年10月15日
  • Java分页查询(真分页)

    Java分页查询(真分页)Java分页查询(真分页)

  • Proteus使用教程并仿真51程序——LED流水灯

    Proteus使用教程并仿真51程序——LED流水灯目录一、安装Proteus软件二、熟悉Proteus软件三、51程序设计和仿真四、总结五、参考资料Proteus是LabCenterElectronics公司推出的一个EDA工具软件。Proteus具有原理布图、PCB自动或人工布线、SPICE电路仿真、互动电路仿真、仿真处理器及其外围电路等特点功能。一、安装Proteus软件下面来了解下如何安装Proteus软件,安装过程也十分简单。首先需要下载Proteus的压缩包,链接如下。链接:https://pan.baidu.com/s/1e

发表回复

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

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