5

我正在使用 Kubernetes golang 运算符 sdk 来实现一个管理 RabbitMQ 队列的运算符。我想知道 k8s 是否有办法在我的自定义资源上强制执行特定规范字段的不变性。我有以下 golang 结构,它代表一个 rabbitMQ 队列和一些参数来让它绑定到 rabbitMQ 交换:

type RmqQueueSpec struct {
    VHost string `json:"vhost,required"`
    Exchange string `json:"exchange,required"`
    RoutingKey string `json:"routingKey"`
    SecretConfig map[string]string `json:"secretConfig"`
}

我想要不变性的原因,特别是对于该VHost字段,是因为它是一个用于在 rabbitMQ 中命名队列的参数。如果对现有的已部署队列进行了更改,则 k8s 协调器将无法查询 rabbitMQ 的预期队列,因为它将使用不同的 vhost(实际上是不同的命名空间)进行查询,这可能会导致创建新队列或更新的错误队列。

我正在考虑一些替代方案,例如使用所需的 ObjectMeta.Name 字段来包含串联的 vhost 和队列名称,以确保它们对于已部署的队列是不可变的。或者以某种方式在操作员中缓存较旧的规范(还没有弄清楚如何做到这一点)并在协调器中比较旧规范和当前规范,如果VHost发生更改则返回错误。然而,这些方法似乎都不理想。理想情况下,如果操作员框架可以在字段上强制执行不变性VHost,那将是一种处理此问题的简单方法。

4

2 回答 2

6

通过使用ValidatingAdmissionWebhook可以进行此验证,未来将通过 CRD 的 OpenAPI 验证提供支持。

于 2019-06-25T00:53:13.680 回答
0

AFAIK 这还不适用于 CRD。我们的方法通常是使用对象名称作为被控制对象的默认名称(在本例中为虚拟主机名称),因此它自然可以正常工作。

于 2019-06-24T16:41:16.040 回答