当前位置:

首页 > 编程开发 > Golang监控K8s CRDs实现方法

Golang监控K8s CRDs实现方法

应使用client-go的DynamicClient配合RESTMapper获取GVR后调用Watch,避免硬编码路径、轮询或错误的命名空间处理;事件中用unstructured安全取值,并确保scheme正确注册CRD类型。

本文目录

    应使用 client-go 的 DynamicClient 配合 RESTMapper 获取 GVR 后调用 Watch,避免硬编码路径、轮询或错误的命名空间处理;事件中用 unstructured 安全取值,并确保 scheme 正确注册 CRD 类型。

    使用Golang监控K8s中的Custom Resource Definitions (CRDs)

    怎么用 client-go 监听 CRD 资源变化

    直接用 Watch 方法,但别用 List + 轮询——性能差、易丢事件、K8s server 侧压力大。CRD 对象本质是 REST 资源,client-go 的 DynamicClient 支持泛型监听,不需要为每个 CRD 写结构体。

    • 必须先通过 RESTMapper 获取 CRD 的 GroupVersionResource(GVR),不能硬编码路径;否则遇到多版本 CRD 或 API group 变更就 404
    • DynamicClient.RestaPIs().Get().Namespace(…) 这类写法错:CRD 本身是集群作用域,但它的实例(Custom Resource)可能命名空间级或集群级,得看 CRD 定义里的 scope 字段
    • Watch 返回的 watch.Interface 需手动处理 watch.Event 类型,event.Object 是 *unstructured.Unstructured,字段访问用 object.Object["spec"],别试图转成 struct(除非你生成了 clientset)

    为什么 informer 同步失败常卡在 “no matches for kind”

    这是典型的 GVR 注册缺失。informer 依赖 scheme 知道怎么解码响应体,而默认 scheme 不认识你的 CRD 类型。

    • 别只调 addKnownTypes:得用 scheme.AddKnownTypes(gv, &MyCR{}, &MyCRList{}),且 gv 必须和 CRD 的 spec.group + spec.versions[*].name 严格一致(比如 example.com/v1alpha1)
    • 如果 CRD 启用了多个版本(如 v1alpha1 和 v1),informer 默认只认 storage: true 的那个版本,其他版本 watch 会返回 404 Not Found 或空列表
    • 用 kubectl get crd -o yaml 核对 spec.names.kind 和 spec.group,大小写、复数形式(如 MyResources vs MyResource)错一个就匹配不上

    如何安全处理 CRD 版本升级时的字段变更

    CRD 升级后旧实例仍存在,新 controller 可能读到字段缺失或类型不一致的数据。不能假设 object.Object["spec"] 一定有某个 key。

    • 所有字段访问前加 unstructured.NestedFieldNoCopy 或 unstructured.NestedString 等安全取值函数,它们返回 (value, bool),避免 panic
    • 如果 CRD 从 string 改成 int,旧对象里该字段还是字符串,unstructured.NestedInt64 会返回 0 和 false,得 fallback 处理
    • 别在 Watch 回调里做耗时操作(如 HTTP 请求),用 worker queue 解耦;否则 event 积压导致 resourceVersion 落后,触发 relist,又可能撞上旧数据

    controller-runtime 的 Builder.Watch 为什么没反应

    常见原因是没正确注册 Scheme 或没设置 RBAC 权限。controller-runtime 底层还是 client-go,只是封装了 informer 生命周期。

    • 确保 mgr.GetScheme().AddKnownTypes(...) 在 manager 启动前调用,且传入的类型指针和 CRD 的 kind 一致(比如 &MyCR{},不是 MyCR{})
    • RBAC 的 rules 必须包含 apiGroups: ["example.com"],资源名写 myresources(复数、小写、连字符分隔),不是 CRD 名 myresources.example.com
    • 如果 CRD 是集群作用域,Namespaced: false;若误设为 true,informer 会静默跳过所有事件,日志里连 warning 都没有

    最麻烦的是 resourceVersion 过期后自动 relist 期间,API server 可能返回旧版对象(特别是启用了 conversion webhook 但未生效时)。这时候字段存在性、类型都不可信,得靠业务逻辑兜底校验。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发
    相关文章 更多
    GitHub合并故障的已缓解、监控与已解决有什么不同
    GitHub合并故障的已缓解、监控与已解决有什么不同

    GitHub合并故障中的“已缓解并监控”和“已解决”不能互换。前者表示影响已经采取措施缓解,仍在观察稳定性;后者是供应商正式结束这场事故的状态。11月13日的Pull Requests合并超时事件先进入监控,随后于北京时间11月14日02:29标记为已解决。

    llama.cpp v1.0.0的网页聊天分组与Markdown编辑适合哪些场景
    llama.cpp v1.0.0的网页聊天分组与Markdown编辑适合哪些场景

    llama.cpp v1.0.0改善聊天组织、长消息编辑和附件预览;界面变化与底层API迁移、缓存及访问边界需要分别理解。

    Postman 12.36.4 更新后仍报错,怎么判断是哪一层的问题
    Postman 12.36.4 更新后仍报错,怎么判断是哪一层的问题

    Postman 12.36.4 更新后仍有异常时,可按应用、API请求和平台服务区分问题范围,避免把补丁版本当作故障原因。

    n8n 2.47.6、2.48.3 Beta与1.123.96适合哪些部署环境?
    n8n 2.47.6、2.48.3 Beta与1.123.96适合哪些部署环境?

    按正式、预发布和1.x维护渠道对应补丁,再结合Redis、Agent端点和Pinecone索引判断适用范围。

    Codex CLI 0.169.0与0.171.0-alpha.2怎样选择,终端工作区适合哪些任务
    Codex CLI 0.169.0与0.171.0-alpha.2怎样选择,终端工作区适合哪些任务

    Codex CLI 0.169.0提供有明确说明的终端工作区能力;0.171.0-alpha.2为预发布,当前没有功能清单,选用时应分开评估。

    llama.cpp b12345的Hexagon后端支持哪些Q5量化格式?
    llama.cpp b12345的Hexagon后端支持哪些Q5量化格式?

    llama.cpp b12345的预发布构建为Hexagon HTP后端增加Q5_0和Q5_1支持。选择模型时需要核对完整量化名称及实际运行后端,不能只看到“Q5”就视为同一种格式。

    llama.cpp b12344的MCP工具调用在断连或超时后会怎样处理?
    llama.cpp b12344的MCP工具调用在断连或超时后会怎样处理?

    llama.cpp b12344的预发布构建调整了MCP工具调用的取消行为:客户端断连或调用超时时,服务器会向MCP服务发送带请求ID的取消通知。使用服务端工具的Web界面也属于这项变更范围。

    GitHub Actions与Checks同时排队失败时,如何区分平台故障?
    GitHub Actions与Checks同时排队失败时,如何区分平台故障?

    GitHub对11月5日Actions与Checks事件的新增复盘指出:数据库服务在高并发大读请求下耗尽资源,导致部分运行无法排队或执行失败。检查类似问题时,先比对平台事件时间与失败状态,再决定是否重试自己的工作流。

    GitHub Actions运行卡住占用并发时,应检查哪些状态?
    GitHub Actions运行卡住占用并发时,应检查哪些状态?

    GitHub对11月9日Actions事件的新增复盘说明:数据库迁移后,新区域容量与速率限制不足导致请求被拒,部分运行在服务恢复后仍占用并发。排查自己的工作流时,应把平台状态、运行状态与应用代码错误分开核对。

    llama.cpp b12342的CUDA量化计算适用于哪些GPU,如何构建?
    llama.cpp b12342的CUDA量化计算适用于哪些GPU,如何构建?

    llama.cpp b12342新增面向少列矩阵计算的CUDA量化内核,覆盖2至24个src1列等场景,例如推测解码的验证阶段。新增内核针对Ampere及更新的NVIDIA GPU,并限定于发行说明列出的量化类型;它不是所有硬件与模型都会得到相同收益的通用开关。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。