Documentation
¶
Index ¶
- Variables
- func ConfigMapPredicates(logger logr.Logger) predicate.Funcs
- func FluxSourcePredicates(s *runtime.Scheme, logger logr.Logger) predicate.Funcs
- func InitScheme() (*runtime.Scheme, error)
- func SecretPredicates(logger logr.Logger) predicate.Funcs
- type JsonnetSourceReconciler
- func (s *JsonnetSourceReconciler) Close(ctx context.Context, jsonnetSource *extensionv1alpha1.JsonnetSource, ...) error
- func (r *JsonnetSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
- func (r *JsonnetSourceReconciler) SetupWithManager(mgr ctrl.Manager) (controller.Controller, error)
- func (r *JsonnetSourceReconciler) WatchForFlux(mgr ctrl.Manager, c controller.Controller) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( CreateFuncTrue = func(e event.CreateEvent, logger logr.Logger) bool { log := logger.WithValues("predicate", "createEvent", e.Object.GetObjectKind(), e.Object.GetName(), ) log.V(logs.LogVerbose).Info(fmt.Sprintf( "%s did match expected conditions. Will attempt to reconcile associated JsonnetSources.", e.Object.GetObjectKind())) return true } DeleteFuncTrue = func(e event.DeleteEvent, logger logr.Logger) bool { log := logger.WithValues("predicate", "deleteEvent", e.Object.GetObjectKind(), e.Object.GetName(), ) log.V(logs.LogVerbose).Info(fmt.Sprintf( "%s did match expected conditions. Will attempt to reconcile associated JsonnetSources.", e.Object.GetObjectKind())) return true } GenericFuncFalse = func(e event.GenericEvent, logger logr.Logger) bool { log := logger.WithValues("predicate", "genericEvent", e.Object.GetObjectKind(), e.Object.GetName(), ) log.V(logs.LogVerbose).Info(fmt.Sprintf( "%s did not match expected conditions. Will not attempt to reconcile associated JsonnetSources.", e.Object.GetObjectKind())) return false } )
Functions ¶
func ConfigMapPredicates ¶
ConfigMapPredicates predicates for ConfigMaps. ClusterSummaryReconciler watches ConfigMap events and react to those by reconciling itself based on following predicates
func FluxSourcePredicates ¶
FluxSourcePredicates predicates for GitRepository/OCIRepository/Bucket. JsonnetSourceReconciler watches GitRepository/OCIRepository/Bucket events and react to those by reconciling itself based on following predicates
func InitScheme ¶
Types ¶
type JsonnetSourceReconciler ¶
type JsonnetSourceReconciler struct {
client.Client
Scheme *runtime.Scheme
ConcurrentReconciles int
PolicyMux sync.Mutex // use a Mutex to update Map as MaxConcurrentReconciles is higher than one
ReferenceMap map[corev1.ObjectReference]*libsveltosset.Set // key: Referenced object; value: set of all JsonnetSources referencing the resource
JsonnetSourceMap map[types.NamespacedName]*libsveltosset.Set // key: JsonnetSource namespace/name; value: set of referenced resources
}
JsonnetSourceReconciler reconciles a JsonnetSource object
func (*JsonnetSourceReconciler) Close ¶
func (s *JsonnetSourceReconciler) Close(ctx context.Context, jsonnetSource *extensionv1alpha1.JsonnetSource, patchHelper *patch.Helper) error
Close closes the current scope persisting the JsonnetSource status.
func (*JsonnetSourceReconciler) SetupWithManager ¶
func (r *JsonnetSourceReconciler) SetupWithManager(mgr ctrl.Manager, ) (controller.Controller, error)
SetupWithManager sets up the controller with the Manager.
func (*JsonnetSourceReconciler) WatchForFlux ¶
func (r *JsonnetSourceReconciler) WatchForFlux(mgr ctrl.Manager, c controller.Controller) error
Source Files
Click to show internal directories.
Click to hide internal directories.