kubectl源码分析之rollout restart
欢迎关注我的公众号:
目前刚开始写一个月,一共写了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完全手册
加qq群,请联系:
————————————————
type RestartOptions struct {//restart结构体PrintFlags *genericclioptions.PrintFlagsToPrinter func(string) (printers.ResourcePrinter, error)Resources []stringBuilder func() *resource.BuilderRestarter polymorphichelpers.ObjectRestarterFuncNamespace stringEnforceNamespace boolresource.FilenameOptionsgenericclioptions.IOStreams
}
func NewRolloutRestartOptions(streams genericclioptions.IOStreams) *RestartOptions {return &RestartOptions{//初始化结构体PrintFlags: genericclioptions.NewPrintFlags("restarted").WithTypeSetter(scheme.Scheme),IOStreams: streams,}
}
//创建restart命令
func NewCmdRolloutRestart(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command {o := NewRolloutRestartOptions(streams)//初始化结构体validArgs := []string{"deployment", "daemonset", "statefulset"}cmd := &cobra.Command{//创建cobra命令Use: "restart RESOURCE",DisableFlagsInUseLine: true,Short: i18n.T("Restart a resource"),Long: restartLong,Example: restartExample,Run: func(cmd *cobra.Command, args []string) {cmdutil.CheckErr(o.Complete(f, cmd, args))//准备cmdutil.CheckErr(o.Validate())//校验cmdutil.CheckErr(o.RunRestart())//运行},ValidArgs: validArgs,//有效参数}usage := "identifying the resource to get from a server."cmdutil.AddFilenameOptionFlags(cmd, &o.FilenameOptions, usage)//文件选项o.PrintFlags.AddFlags(cmd)//打印选项return cmd
}
//准备函数
func (o *RestartOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, args []string) error {o.Resources = args//设置资源o.Restarter = polymorphichelpers.ObjectRestarterFn//设置Restarter函数var err erroro.Namespace, o.EnforceNamespace, err = f.ToRawKubeConfigLoader().Namespace()//设置namespace和enforceNamespaceif err != nil {return err}o.ToPrinter = func(operation string) (printers.ResourcePrinter, error) {//print flag 转printer函数o.PrintFlags.NamePrintFlags.Operation = operationreturn o.PrintFlags.ToPrinter()}o.Builder = f.NewBuilder//设置builderreturn nil
}//校验
func (o *RestartOptions) Validate() error {if len(o.Resources) == 0 && cmdutil.IsFilenameSliceEmpty(o.Filenames, o.Kustomize) {//资源和文件至少有一个return fmt.Errorf("required resource not specified")}return nil
}
//运行
func (o RestartOptions) RunRestart() error {r := o.Builder().WithScheme(scheme.Scheme, scheme.Scheme.PrioritizedVersionsAllGroups()...).NamespaceParam(o.Namespace).DefaultNamespace().FilenameParam(o.EnforceNamespace, &o.FilenameOptions).ResourceTypeOrNameArgs(true, o.Resources...).ContinueOnError().Latest().Flatten().Do()//构造result对象if err := r.Err(); err != nil {return err}allErrs := []error{}infos, err := r.Infos()//获取info对象if err != nil {// restore previous command behavior where// an error caused by retrieving infos due to// at least a single broken object did not result// in an immediate return, but rather an overall// aggregation of errors.allErrs = append(allErrs, err)}for _, patch := range set.CalculatePatches(infos, scheme.DefaultJSONEncoder(), set.PatchFn(o.Restarter)) {//计算info补丁,并遍历info := patch.Infoif patch.Err != nil {//补丁有错误,append错误继续resourceString := info.Mapping.Resource.Resourceif len(info.Mapping.Resource.Group) > 0 {resourceString = resourceString + "." + info.Mapping.Resource.Group}allErrs = append(allErrs, fmt.Errorf("error: %s %q %v", resourceString, info.Name, patch.Err))continue}if string(patch.Patch) == "{}" || len(patch.Patch) == 0 {//如果补丁为空,则append错误allErrs = append(allErrs, fmt.Errorf("failed to create patch for %v: empty patch", info.Name))}obj, err := resource.NewHelper(info.Client, info.Mapping).Patch(info.Namespace, info.Name, types.StrategicMergePatchType, patch.Patch, nil)//用helper应用补丁到服务端if err != nil {allErrs = append(allErrs, fmt.Errorf("failed to patch: %v", err))continue}info.Refresh(obj, true)//刷新obj对象printer, err := o.ToPrinter("restarted")//printflag转printerif err != nil {allErrs = append(allErrs, err)continue}if err = printer.PrintObj(info.Object, o.Out); err != nil {//打印结果allErrs = append(allErrs, err)}}return utilerrors.NewAggregate(allErrs)
}
kubectl源码分析之rollout restart相关推荐
- kubectl源码分析之config delete-context
欢迎关注我的公众号: 目前刚开始写一个月,一共写了18篇原创文章,文章目录如下: istio多集群探秘,部署了50次多集群后我得出的结论 istio多集群链路追踪,附实操视频 istio防故障利器,你 ...
- kubectl源码分析之cordon and uncordon
欢迎关注我的公众号: 目前刚开始写一个月,一共写了18篇原创文章,文章目录如下: istio多集群探秘,部署了50次多集群后我得出的结论 istio多集群链路追踪,附实操视频 istio防故障利器,你 ...
- kubectl源码分析之auth reconcile
欢迎关注我的公众号: 目前刚开始写一个月,一共写了18篇原创文章,文章目录如下: istio多集群探秘,部署了50次多集群后我得出的结论 istio多集群链路追踪,附实操视频 istio防故障利器,你 ...
- kubectl源码分析之taint
欢迎关注我的公众号: 目前刚开始写一个月,一共写了18篇原创文章,文章目录如下: istio多集群探秘,部署了50次多集群后我得出的结论 istio多集群链路追踪,附实操视频 istio防故障利器,你 ...
- Scheduling restart of crashed service解决方案与源码分析
测试发现一个bug,service中某个方法由于空指针导致程序挂掉,接着触发程序的保活机制触发程序重启,但是这个异常service先启动访问未初始化资源导致程序连续循环重启. 下面代码模拟了servi ...
- kubeadm源码分析(内含kubernetes离线包,三步安装)
k8s离线安装包 三步安装,简单到难以置信 kubeadm源码分析 说句实在话,kubeadm的代码写的真心一般,质量不是很高. 几个关键点来先说一下kubeadm干的几个核心的事: kubeadm ...
- Kube Controller Manager 源码分析
Kube Controller Manager 源码分析 Controller Manager 在k8s 集群中扮演着中心管理的角色,它负责Deployment, StatefulSet, Repli ...
- kubeadm源码分析(kubernetes离线安装包,三步安装)
k8s离线安装包 三步安装,简单到难以置信 kubeadm源码分析 说句实在话,kubeadm的代码写的真心一般,质量不是很高. 几个关键点来先说一下kubeadm干的几个核心的事: kubeadm ...
- istio源码分析——pilot-agent如何管理envoy生命周期
原文:istio源码分析--pilot-agent如何管理envoy生命周期 声明 分析的源码为0.7.1版本 环境为k8s 由于没有C++ 基础,所以源码分析止步于 C++,但也学到很多东西 pil ...
- Hhadoop-2.7.0中HDFS写文件源码分析(二):客户端实现(1)
一.综述 HDFS写文件是整个Hadoop中最为复杂的流程之一,它涉及到HDFS中NameNode.DataNode.DFSClient等众多角色的分工与合作. 首先上一段代码,客户端是如何写文件的: ...
最新文章
- Arduino产生PWM的3种方法
- 深入理解 Java 线程池:ThreadPoolExecutor
- ESP8266的一个小问题
- 高二计算机水平测试题,高二计算机学业水平测试 模拟试题(附答案)
- python22起作业答案_python第22天作业
- 关于怎么获取jsp的web站点的目录问题
- Java Web项目 配置 ueditor心得
- UVA494 Kindergarten Counting Game【输入输出+水题】
- B00005 函数atoi()(去空格,带符号)
- python+opencv打开摄像头、拍摄指定次数的照片_python+openCV调用摄像头拍摄和处理图片的实现...
- 机器学习—数据清洗总结
- 中国期货交易技术的逆袭之路
- 信号处理VMD 变分模态分解,示例+完整代码
- MYSQL8.0 OCP考试题库(如需完整版请留言)
- Android开发之局域网聊天软件
- 人脸识别系统落地酒店 刷脸入住更安全
- 微信小程序文档api
- client-go实战之三:Clientset
- 新颖的自我介绍_三句有创意的自我介绍 简短有创意的自我介绍
- mac系统如何管理桌面图标