我一直在使用 kubebuilder 编写自定义控制器,并且知道它提供的 Get()、Update()、Delete() 方法。但现在我正在寻找一种模仿kubectl rollout restart deployment
. 如果没有这样的直接方法,那么我正在寻找正确的方法来模仿。
type CustomReconciler struct {
client.Client
Log logr.Logger
Scheme *runtime.Scheme
}
func (r *CustomReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
configMap := &v1.ConfigMap{}
err = r.Get(ctx, req.namespacedName, configMap)
if err != nil {
logger.Error(err, "Failed to GET configMap")
return ctrl.Result{}, err
}
说在上面的代码中,我从 configmap 中读取了一个部署名称,然后 rollout 重新启动,如下所示:
val := configMap.Data["config.yml"]
config := Config{}
if err := yaml.Unmarshal([]byte(val), &config); err != nil {
logger.Error(err, "failed to unmarshal config data")
return ctrl.Result{}, err
}
// Need equivalent of following
// r.RolloutRestart(config.DeploymentName)