如何在 kubebuilder 中监视外部自定义资源更改而不导入外部类型

Question

假设我有以下代码片段，它设置了一个监视外部资源“外部”的协调器：

// SetupWithManager sets up the controller with the Manager.
func (r *SomethingReconciler) SetupWithManager(mgr ctrl.Manager) error {
    return ctrl.NewControllerManagedBy(mgr).
        For(&api.Something{}).
        WithOptions(controller.Options{
            MaxConcurrentReconciles: stdruntime.NumCPU(),
            RecoverPanic:            true,
        }).
        Watches(
            &source.Kind{Type: &somev1.External{}},
            handler.EnqueueRequestsFromMapFunc(r.findInternalObjectsForExternal),
            builder.WithPredicates(predicate.Funcs{
                UpdateFunc: func(ue event.UpdateEvent) bool { return true },
                DeleteFunc: func(de event.DeleteEvent) bool { return true },
            }),
        ).
        Complete(r)
}

我的问题是我无法将somev1.External类型导入到我的项目中，因为导入包含此类型的 go 模块会破坏我当前项目的依赖关系。
kubebuilder 中有没有一种方法可以监视外部资源，而无需显式导入其类型？比如GVK之类的？

Answer 1

是的，这是可能的。

您可以为您的资源创建一个 REST 客户端，main.go如下所示：

gvkExternal := schema.GroupVersionKind{
    Group:   "some.group.io",
    Version: "v1",
    Kind:    "External",
}

restClient, err := apiutil.RESTClientForGVK(gvkExternal, false, mgr.GetConfig(), serializer.NewCodecFactory(mgr.GetScheme()))
if err != nil {
    setupLog.Error(err, "unable to create REST client")
}

rest.Interface然后将此 REST 客户端 ( )的字段添加到您的协调器 ( yournativeresource_controller.go) 结构中，例如：

type YourNativeResourceReconciler struct {
    client.Client
    Scheme        *runtime.Scheme
    // add this
    RESTClient    rest.Interface
}

最后，使用此 REST 客户端 ( main.go) 初始化您的协调器：

if err = (&controllers.YourNativeResourceReconciler{
    Client:        mgr.GetClient(),
    Scheme:        mgr.GetScheme(),
    RESTClient:    restClient,
}).SetupWithManager(mgr); err != nil {
    setupLog.Error(err, "unable to create controller", "controller", "YourNativeResource")
    os.Exit(1)
}

不要忘记将 RBAC 标记添加到您的项目（最好是协调器），这将生成 RBAC 规则，允许您操作External资源：

//+kubebuilder:rbac:groups=some.group.io,resources=externals,verbs=get;list;watch;create;update;patch;delete

完成这些步骤后，您可以使用 REST 客户端通过协调器操作External资源。YourNativeResourcer.RESTClient

编辑：

如果您想观看资源，动态客户端可能会有所帮助。在以下位置创建动态客户端main.go：

//+kubebuilder:rbac:groups=some.group.io,resources=externals,verbs=get;list;watch;create;update;patch;delete

应用上述步骤，将其添加到您的协调器等。然后您将能够观看External资源，如下所示：

dynamicClient, err := dynamic.NewForConfig(mgr.GetConfig())
if err != nil {
    setupLog.Error(err, "unable to create dynamic client")
}