Kubernetes API CRD 更新

Question

result, err := crdclient.Create(example)
if err == nil {
    fmt.Printf("CREATED: %#v\n", result)
} else if apierrors.IsAlreadyExists(err) {
    fmt.Printf("ALREADY EXISTS: %#v\n", result)
} else {
    panic(err)
}

// List all Example objects
items, err := crdclient.List(meta_v1.ListOptions{})
if err != nil {
    panic(err)
}
fmt.Printf("List:\n%s\n", items)

result, err = crdclient.Get("example123")
if err != nil {
    panic(err)
}
fmt.Printf("Get:\n%v\n", result)

result.Status.Message = "Hello There"
fmt.Println("\n Result is: %v \n", result)
up, uperr := crdclient.Update(result)
if uperr != nil {
    panic(uperr)
}

在上面带有 kubernetes API 的 CRD 示例中，我得到了错误。
“在更新通话中
panic :必须提供名称”

我错过了什么？该代码基于@ https://github.com/yaronha/kube-crd 给出的示例

Answer 1

我看了下代码，需要更新client.go文件中的Update API，代码如下:

func (f *crdclient) Update(obj *crd.Example) (*crd.Example, error) {
    var result crd.Example
    err := f.cl.Put().
        Namespace(f.ns).Resource(f.plural).
        Name(obj.Name).
        Body(obj).Do().Into(&result)
    return &result, err
}

之后，您的代码应该按预期工作。