我开发了一个操作员来监控我开发的 CR,假设它的类型是MyCustomResource1。然后它基本上会执行任何操作员所做的操作,在协调循环中,它使当前集群状态更接近所需状态。
现在,在我的 CR 规范中,有一个类似这样的字段
elastic_configuration:
cpu: 2
memory: 4Gi
作为其协调循环的一部分,CR 可确保启动具有 N 个 pod 的 Elasticsearch 集群,内存和 CPU 字段分别由字段elastic_configuration.cpu和elastic_configuration.memory决定。
现在,K8S 中的实际Elasticsearch集群由 ECK 操作员启动(它监视其自己的Elasticsearch类型的 CR ),但我希望内存和 CPU 的值成为MyCustomResource1规范的一部分
每当用户想要增加Elasticsearch pod 的 CPU 和内存时,他们都应该编辑我的 CR 中字段 elastic_configuration.cpu和elastic_configuration.memory的值。我编写的运算符在其协调循环中将识别出这些值已更改,并将更新 Elasticsearch 资源规范的相应字段,该规范由 ECK 运算符监控。
问题是,我的操作员更新 CR 的最佳方法是什么?
网上最流行的解决方案建议使用非结构化对象,但我发现反复将所有内容转换为 map[string]interface{},然后将其转换为某种所需类型有点繁琐。
我想到另一个解决方案是,因为我使用的是 ECK 版本 2.13.0,所以我可以克隆整个 repo 或者复制代表Elasticsearch资源的相关结构(当然是从 2.13.0 开始),更新操作员协调循环中结构的字段,然后以某种方式通过某些 K8S 客户端使用这个结构来更新 CR,我知道我在这里缺乏细节,但这是一个高层次的想法,我想到过但我不确定是否可以实现)
TLDR;以编程方式更新自定义资源(比如 Go 中的 K8S 中的Elasticsearch)的正确方法是什么?