mirror of
https://github.com/open-cluster-management-io/ocm.git
synced 2026-08-19 20:26:48 +00:00
33 lines
860 B
Go
33 lines
860 B
Go
package v1alpha1
|
|
|
|
import (
|
|
"k8s.io/client-go/kubernetes"
|
|
ctrl "sigs.k8s.io/controller-runtime"
|
|
|
|
"open-cluster-management.io/api/work/v1alpha1"
|
|
)
|
|
|
|
type ManifestWorkReplicaSetWebhook struct {
|
|
kubeClient kubernetes.Interface
|
|
}
|
|
|
|
func (r *ManifestWorkReplicaSetWebhook) Init(mgr ctrl.Manager) error {
|
|
err := r.SetupWebhookWithManager(mgr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
r.kubeClient, err = kubernetes.NewForConfig(mgr.GetConfig())
|
|
return err
|
|
}
|
|
|
|
// SetExternalKubeClientSet is function to enable the webhook injecting to kube admssion
|
|
func (r *ManifestWorkReplicaSetWebhook) SetExternalKubeClientSet(client kubernetes.Interface) {
|
|
r.kubeClient = client
|
|
}
|
|
|
|
func (r *ManifestWorkReplicaSetWebhook) SetupWebhookWithManager(mgr ctrl.Manager) error {
|
|
return ctrl.NewWebhookManagedBy(mgr, &v1alpha1.ManifestWorkReplicaSet{}).
|
|
WithValidator(r).
|
|
Complete()
|
|
}
|