109 lines
4.1 KiB
Go
109 lines
4.1 KiB
Go
package controllers
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"reflect"
|
|
|
|
"github.com/jenkinsci/kubernetes-operator/api/v1alpha2"
|
|
"github.com/jenkinsci/kubernetes-operator/pkg/constants"
|
|
"github.com/jenkinsci/kubernetes-operator/pkg/log"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"k8s.io/client-go/util/workqueue"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/event"
|
|
"sigs.k8s.io/controller-runtime/pkg/handler"
|
|
"sigs.k8s.io/controller-runtime/pkg/reconcile"
|
|
)
|
|
|
|
// enqueueRequestForJenkins enqueues a Request for Secrets and ConfigMaps created by jenkins-operator.
|
|
type enqueueRequestForJenkins struct{}
|
|
|
|
var _ handler.TypedEventHandler[client.Object, reconcile.Request] = &enqueueRequestForJenkins{}
|
|
|
|
func (e *enqueueRequestForJenkins) Create(ctx context.Context, evt event.TypedCreateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
if req := e.getOwnerReconcileRequests(ctx, evt.Object); req != nil {
|
|
q.Add(*req)
|
|
}
|
|
}
|
|
|
|
func (e *enqueueRequestForJenkins) Update(ctx context.Context, evt event.TypedUpdateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
req1 := e.getOwnerReconcileRequests(ctx, evt.ObjectOld)
|
|
req2 := e.getOwnerReconcileRequests(ctx, evt.ObjectNew)
|
|
|
|
if req1 != nil || req2 != nil {
|
|
jenkinsName := "unknown"
|
|
if req1 != nil {
|
|
jenkinsName = req1.Name
|
|
}
|
|
if req2 != nil {
|
|
jenkinsName = req2.Name
|
|
}
|
|
|
|
log.Log.WithValues("cr", jenkinsName).Info(
|
|
fmt.Sprintf("%T/%s has been updated", evt.ObjectNew, evt.ObjectNew.GetName()))
|
|
}
|
|
|
|
if req1 != nil {
|
|
q.Add(*req1)
|
|
return
|
|
}
|
|
if req2 != nil {
|
|
q.Add(*req2)
|
|
}
|
|
}
|
|
|
|
func (e *enqueueRequestForJenkins) Delete(ctx context.Context, evt event.TypedDeleteEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
if req := e.getOwnerReconcileRequests(ctx, evt.Object); req != nil {
|
|
q.Add(*req)
|
|
}
|
|
}
|
|
|
|
func (e *enqueueRequestForJenkins) Generic(ctx context.Context, evt event.TypedGenericEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
if req := e.getOwnerReconcileRequests(ctx, evt.Object); req != nil {
|
|
q.Add(*req)
|
|
}
|
|
}
|
|
|
|
func (e *enqueueRequestForJenkins) getOwnerReconcileRequests(_ context.Context, object metav1.Object) *reconcile.Request {
|
|
if object.GetLabels()[constants.LabelAppKey] == constants.LabelAppValue &&
|
|
object.GetLabels()[constants.LabelWatchKey] == constants.LabelWatchValue &&
|
|
len(object.GetLabels()[constants.LabelJenkinsCRKey]) > 0 {
|
|
return &reconcile.Request{NamespacedName: types.NamespacedName{
|
|
Namespace: object.GetNamespace(),
|
|
Name: object.GetLabels()[constants.LabelJenkinsCRKey],
|
|
}}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type jenkinsDecorator struct {
|
|
handler handler.TypedEventHandler[client.Object, reconcile.Request]
|
|
}
|
|
|
|
var _ handler.TypedEventHandler[client.Object, reconcile.Request] = &jenkinsDecorator{}
|
|
|
|
func (e *jenkinsDecorator) Create(ctx context.Context, evt event.TypedCreateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
log.Log.WithValues("cr", evt.Object.GetName()).Info(fmt.Sprintf("%T/%s was created", evt.Object, evt.Object.GetName()))
|
|
e.handler.Create(ctx, evt, q)
|
|
}
|
|
|
|
func (e *jenkinsDecorator) Update(ctx context.Context, evt event.TypedUpdateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
if !reflect.DeepEqual(evt.ObjectOld.(*v1alpha2.Jenkins).Spec, evt.ObjectNew.(*v1alpha2.Jenkins).Spec) {
|
|
log.Log.WithValues("cr", evt.ObjectNew.GetName()).Info(
|
|
fmt.Sprintf("%T/%s has been updated", evt.ObjectNew, evt.ObjectNew.GetName()))
|
|
}
|
|
e.handler.Update(ctx, evt, q)
|
|
}
|
|
|
|
func (e *jenkinsDecorator) Delete(ctx context.Context, evt event.TypedDeleteEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
log.Log.WithValues("cr", evt.Object.GetName()).Info(fmt.Sprintf("%T/%s was deleted", evt.Object, evt.Object.GetName()))
|
|
e.handler.Delete(ctx, evt, q)
|
|
}
|
|
|
|
func (e *jenkinsDecorator) Generic(ctx context.Context, evt event.TypedGenericEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
|
|
e.handler.Generic(ctx, evt, q)
|
|
}
|