主页 / coding / 问题 / 79119212
Accepted
Dhiwakar Ravikumar
Asked: 2024-10-24 02:20:56 +0800 CST

使用 Operator 更新自定义资源 (CR) 的最佳方法

  • 772

我开发了一个操作员来监控我开发的 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）的正确方法是什么？

elasticsearch

1 个回答

  1. Best Answer

    ECK 操作符是一个普通的 Go Kubebuilder 操作符。这意味着可以导入其 API 类型。只要它们已在您的 Scheme 中注册，您就可以正常与它们交互。

    在你的main.go文件中，将其与其他 Scheme 初始化放在一起

    import elasticsearchv1 "github.com/elastic/cloud-on-k8s/v2/pkg/apis/elasticsearch/v1"

func init() {
    utilruntime.Must(elasticsearchv1.AddToScheme(scheme))

    utilruntime.Must(yourgroupv1.AddToScheme(scheme))
    // +kubebuilder:scaffold:scheme
}

    然后在您的协调器中，您可以将此类型与（控制器运行时风格的）Kubernetes 操作员正常一起使用。

    func (r *YourReconciler) updateElasticSearch(ctx context.Context, obj *yourgroupv1.Object) error {
    es := &elasticsearchv1.Elasticsearch{}
    name := types.NamespacedName{
        Namespace: obj.GetNamespace(),
        Name: obj.GetName()  // this will be the name of the Elasticsearch object, change if needed
    }
    err := r.Get(ctx, name, es)
    if err != nil {
        return err
    }
    ...
    err = r.Update(ctx, es)
    if err != nil {
        return err
    }
}

    这与您与任何核心 Kubernetes API 对象交互的方式相同，但您需要先将它们导入控制器运行时环境。

    这里有一个强制性的法律说明。ECK操作员许可证是 Elasticsearch 特有的非标准定制许可证；它不是“标准”开源许可证。将其作为库合并到您的操作员中将附带一些义务，并且“限制”下的第一段可能适用于您。请咨询您当地的法律团队。（许多东西都是 Apache 或 BSD 许可的，这些许可证更容易理解。）

    • 1

相关问题