k8s 将k8s作为module使用，进行二开，解决k8s replace的staging本地依赖问题

2024-01-06 09:18
文章标签 进行 云原生 问题 使用 依赖 解决 k8s 本地 module replace 二开 staging

本文主要是介绍k8s 将k8s作为module使用，进行二开，解决k8s replace的staging本地依赖问题，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

go版本，相比bash版本加强了并发能力

/** hack-go-get-kubernetes-version-xx.xx.xx.go* example:* go run $s4y/hack-go-get-kubernetes-version-xx.xx.xx.go v1.22.6* 1. 依赖的kubernetes版本号*/// Package main is the entry of script.
package mainimport ("bytes""errors""fmt""os""os/exec""strconv""strings""sync""syscall"
)func main() {fmt.Println("hack-go-get-kubernetes-version-xx.xx.xx begin")defer fmt.Println("hack-go-get-kubernetes-version-xx.xx.xx end")var err errorvar strExample = "go run $s4y/hack-go-get-kubernetes-version-xx.xx.xx.go v1.22.6"defer func() { fmt.Printf("err: %v, example: %s\n", err, strExample) }()var errParamWrong = errors.New("param wrong")// 获取当前目录var pwd stringif pwd, err = os.Getwd(); err != nil {return}fmt.Printf("pwd: %s\n", pwd)// 获取命令行参数var lenOsArgs = len(os.Args)fmt.Printf("command-args-cnt: %d, command-args: %v\n", lenOsArgs, os.Args)if lenOsArgs != 2 {err = errors.New("lenOsArgs != 2")return}// 获取依赖的kubernetes版本号var version = os.Args[1]var idxV = strings.IndexByte(version, 'v')if idxV == -1 {err = errParamWrongreturn}var versionTrimV = version[idxV+1:]// 解析k8s的go.mod文件var strCmd = fmt.Sprintf(`curl -x $http_proxy -sS https://raw.githubusercontent.com/kubernetes/kubernetes/v%s/go.mod | grep "staging" | sed -n 's|.*k8s.io/\(.*\) => ./staging/src/k8s.io/.*|k8s.io/\1|p'`, versionTrimV)var cmd = NewCommand(strCmd)if err = cmd.Exec(); err != nil {return}var stdOut = cmd.GetStdOut()if stdOut == "" {err = fmt.Errorf("%s stdOut is null", strCmd)return}var stageRepos = strings.Split(stdOut, "\n")var lenStageRepos = len(stageRepos)var stageVersions = make([]string, lenStageRepos)// 并发下载k8s依赖的包缓存到本地var wg sync.WaitGroupwg.Add(lenStageRepos)for idx, repo := range stageRepos {go func(idx int, repo string) {defer wg.Done()if repo == "" {return}var strCmd = fmt.Sprintf(`go mod download -json "%s@kubernetes-%s" | grep "Version" | sed -n 's|.*"Version": "\(.*\)".*|\1|p'`, repo, versionTrimV)var cmd = NewCommand(strCmd)if err := cmd.Exec(); err != nil {fmt.Printf("strCmd: %s, err: %s\n", strCmd, err.Error())return}var stdOut = cmd.GetStdOut()if stdOut == "" {fmt.Printf("strCmd: %s, stdOut is null\n", strCmd)return}stageVersions[idx] = fmt.Sprintf("\t%s => %s %s\n",repo, repo, stdOut,)}(idx, repo)}wg.Wait()// 以追加方式写入到go.mod文件末尾, 并获取k8s包var strToWrite strings.BuilderstrToWrite.Grow(1024)strToWrite.WriteString("\nreplace(\n")for _, str := range stageVersions {strToWrite.WriteString(str)}strToWrite.WriteString(")\n")fmt.Printf("write to %s/go.mod\n", pwd)strCmd = fmt.Sprintf(`echo "%s" >> ./go.mod && go get "k8s.io/kubernetes@v%s"`, strToWrite.String(), versionTrimV)cmd = NewCommand(strCmd)err = cmd.Exec()fmt.Println(cmd.StringWithExecErr(err))return
}//Command defines commands to be executed and captures std out and std error
type Command struct {Cmd      *exec.CmdStdOut   []byteStdErr   []byteExitCode int
}func NewCommand(command string) *Command {return &Command{Cmd: exec.Command("bash", "-c", command)}
}// Exec run command and exit formatted error, callers can print err directly
// Any running error or non-zero exitcode is consider as error
func (cmd *Command) Exec() error {var stdoutBuf, stderrBuf bytes.Buffercmd.Cmd.Stdout = &stdoutBufcmd.Cmd.Stderr = &stderrBuferrString := fmt.Sprintf("failed to exec '%s'", cmd.GetCommand())err := cmd.Cmd.Start()if err != nil {errString = fmt.Sprintf("%s, err: %v", errString, err)return errors.New(errString)}err = cmd.Cmd.Wait()if err != nil {cmd.StdErr = stderrBuf.Bytes()if exit, ok := err.(*exec.ExitError); ok {cmd.ExitCode = exit.Sys().(syscall.WaitStatus).ExitStatus()errString = fmt.Sprintf("%s, err: %s", errString, stderrBuf.Bytes())} else {cmd.ExitCode = 1}errString = fmt.Sprintf("%s, err: %v", errString, err)return errors.New(errString)}cmd.StdOut, cmd.StdErr = stdoutBuf.Bytes(), stderrBuf.Bytes()return nil
}func (cmd Command) GetCommand() string {return strings.Join(cmd.Cmd.Args, " ")
}func (cmd Command) GetStdOut() string {if len(cmd.StdOut) != 0 {return strings.TrimSuffix(string(cmd.StdOut), "\n")}return ""
}func (cmd Command) GetStdErr() string {if len(cmd.StdErr) != 0 {return strings.TrimSuffix(string(cmd.StdErr), "\n")}return ""
}func (cmd Command) StringWithExecErr(errExec error) (res string) {var resBuild strings.BuilderresBuild.Grow(1024)// 写入执行的命令resBuild.WriteString("strCmd: ")for _, args := range cmd.Cmd.Args {resBuild.WriteByte(' ')resBuild.WriteString(args)}resBuild.WriteByte('\n')// 写入执行的errif errExec == nil {resBuild.WriteString("err: nil\n")} else {resBuild.WriteString("err: ")resBuild.WriteString(errExec.Error())resBuild.WriteByte('\n')}// 写入stdOutif len(cmd.StdOut) == 0 {resBuild.WriteString("stdOut is null\n")} else {resBuild.WriteString("stdOut: ")resBuild.Write(cmd.StdOut)}// 写入stdErrif len(cmd.StdErr) == 0 {resBuild.WriteString("stdErr is null\n")} else {resBuild.WriteString("stdErr: ")resBuild.Write(cmd.StdErr)}// 写入exitCoderesBuild.WriteString("exitCode: ")resBuild.WriteString(strconv.Itoa(cmd.ExitCode))res = resBuild.String()return
}

bash版本

#########################################################################
# File Name: hack-go-get-kubernetes-version-xx.xx.xx.sh
# Author: xiaoyang.chen
# mail: xiaoyang.chen@???.com
# Created Time: 五  3/25 17:01:05 2022
#########################################################################
#!/bin/bash# using example: hack-go-get-kubernetes-version-xx.xx.xx.sh v1.22.6
# from https://github.com/kubernetes/kubernetes/issues/79384
# abursavich commented on 15 Aug 2019# '-e': 当一个命令失败时, 立即退出
# '-u': 遇到未定义的变量, 报错并立即退出
# '-o pipefail': 在运行脚本时, 通常我们只看最后一个命令的退出码, 例如'invalid_command || echo "invalid command"', 我们获得退出码为0, 因为我们获得整个管道的最后一个命令, 加上'-o pipefail', 则会根据整个管道链的退出码来判断, 只有所有退出码为0, 退出码才会为0
set -euo pipefailVERSION=${1#"v"}
# -z True if the length of $VERSION is zero.
if [ -z "$VERSION" ]; thenecho "Must specify version!"exit 1
fi
# curl -sS -s silent, -S with -s, will print error message when curl fail
# in k8s go.mod:
#	k8s.io/api => ./staging/src/k8s.io/api
#	k8s.io/apiextensions-apiserver => ./staging/src/k8s.io/apiextensions-apiserver
#	k8s.io/apimachinery => ./staging/src/k8s.io/apimachinery
#	k8s.io/apiserver => ./staging/src/k8s.io/apiserver
# s为substitution替换, |为分界符, p指仅将替换后的行输出到标准输出, 其他不输出
# \1是()中匹配到的内容的第一个匹配项, ()会将匹配到的内容保存进缓冲区, 缓冲区编号从1开始, 最多可存储99个捕获的子表达式, 每个缓冲区都可以使用\n访问, 其中n为一个标识特定缓冲区的一位或两位十进制数
# 解析k8s的go.mod文件
MODS=($(curl -x $http_proxy -sS https://raw.githubusercontent.com/kubernetes/kubernetes/v${VERSION}/go.mod | grep "staging" | sed -n 's|.*k8s.io/\(.*\) => ./staging/src/k8s.io/.*|k8s.io/\1|p'
))
# 并发下载k8s依赖的包缓存到本地
declare -a versions
for MOD in "${MODS[@]}"; doversions+=("$MOD => $MOD `go mod download -json "${MOD}@kubernetes-${VERSION}" | grep "Version" | sed -n 's|.*"Version": "\(.*\)".*|\1|p' &`");
done
wait
# 以追加方式写入到go.mod文件末尾
stringToWrite="\nreplace(\n"
for v in "${versions[@]}"; dostringToWrite+="\t$v\n";
done
stringToWrite+=")\n"
echo "write to `pwd`/go.mod";
echo "$stringToWrite" >> ./go.mod;
go get "k8s.io/kubernetes@v${VERSION}"

这篇关于k8s 将k8s作为module使用，进行二开，解决k8s replace的staging本地依赖问题的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/575886。

相关文章

使用Java将DOCX文档解析为Markdown文档的代码实现

使用Java将DOCX文档解析为Markdown文档的代码实现

《使用Java将DOCX文档解析为Markdown文档的代码实现》在现代文档处理中,Markdown（MD）因其简洁的语法和良好的可读性,逐渐成为开发者、技术写作者和内容创作者的首选格式,然而,许多文... 目录引言1. 工具和库介绍2. 安装依赖库3. 使用Apache POI解析DOCX文档4. 将解析
阅读更多...
QT进行CSV文件初始化与读写操作

QT进行CSV文件初始化与读写操作

《QT进行CSV文件初始化与读写操作》这篇文章主要为大家详细介绍了在QT环境中如何进行CSV文件的初始化、写入和读取操作,本文为大家整理了相关的操作的多种方法,希望对大家有所帮助... 目录前言一、CSV文件初始化二、CSV写入三、CSV读取四、QT 逐行读取csv文件五、Qt如何将数据保存成CSV文件前言
阅读更多...
Qt中QUndoView控件的具体使用

Qt中QUndoView控件的具体使用

《Qt中QUndoView控件的具体使用》QUndoView是Qt框架中用于可视化显示QUndoStack内容的控件,本文主要介绍了Qt中QUndoView控件的具体使用,具有一定的参考价值,感兴趣的... 目录引言一、QUndoView 的用途二、工作原理三、 如何与 QUnDOStack 配合使用四、自
阅读更多...
C++使用printf语句实现进制转换的示例代码

C++使用printf语句实现进制转换的示例代码

《C++使用printf语句实现进制转换的示例代码》在C语言中,printf函数可以直接实现部分进制转换功能,通过格式说明符（formatspecifier）快速输出不同进制的数值,下面给大家分享C+... 目录一、printf 原生支持的进制转换1. 十进制、八进制、十六进制转换2. 显示进制前缀3. 指
阅读更多...
Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,：本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖？1.2 核心危害二、Spring的三级缓存机制2.1 三
阅读更多...
如何解决idea的Module:‘:app‘platform‘android-32‘not found.问题

如何解决idea的Module:‘:app‘platform‘android-32‘not found.问题

《如何解决idea的Module:‘:app‘platform‘android-32‘notfound.问题》：本文主要介绍如何解决idea的Module:‘:app‘platform‘andr... 目录idea的Module:‘:app‘pwww.chinasem.cnlatform‘android-32
阅读更多...
使用Python构建一个Hexo博客发布工具

使用Python构建一个Hexo博客发布工具

《使用Python构建一个Hexo博客发布工具》虽然Hexo的命令行工具非常强大,但对于日常的博客撰写和发布过程,我总觉得缺少一个直观的图形界面来简化操作,下面我们就来看看如何使用Python构建一个... 目录引言Hexo博客系统简介设计需求技术选择代码实现主框架界面设计核心功能实现1. 发布文章2. 加
阅读更多...
Python如何自动生成环境依赖包requirements

Python如何自动生成环境依赖包requirements

《Python如何自动生成环境依赖包requirements》：本文主要介绍Python如何自动生成环境依赖包requirements问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑... 目录生成当前 python 环境 安装的所有依赖包1、命令2、常见问题只生成当前 项目 的所有依赖包1、
阅读更多...
kali linux 无法登录root的问题及解决方法

kali linux 无法登录root的问题及解决方法

《kalilinux无法登录root的问题及解决方法》：本文主要介绍kalilinux无法登录root的问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,... 目录kali linux 无法登录root1、问题描述1.1、本地登录root1.2、ssh远程登录root2、
阅读更多...
shell编程之函数与数组的使用详解

shell编程之函数与数组的使用详解

《shell编程之函数与数组的使用详解》：本文主要介绍shell编程之函数与数组的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录shell函数函数的用法俩个数求和系统资源监控并报警函数函数变量的作用范围函数的参数递归函数shell数组获取数组的长度读取某下的
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2