controllers

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

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 YttSources.",
			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 YttSources.",
			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 YttSources.",
			e.Object.GetObjectKind()))
		return false
	}
)

Functions

func ConfigMapPredicates 

func ConfigMapPredicates(logger logr.Logger) predicate.Funcs

ConfigMapPredicates predicates for ConfigMaps. YttSourceReconciler watches ConfigMap events and react to those by reconciling itself based on following predicates

func InitScheme 

func InitScheme() (*runtime.Scheme, error)

func SecretPredicates 

func SecretPredicates(logger logr.Logger) predicate.Funcs

SecretPredicates predicates for Secrets. YttSourceReconciler watches Secret events and react to those by reconciling itself based on following predicates

Types

type FluxBucketPredicate added in v0.3.0 

type FluxBucketPredicate struct {
	Logger logr.Logger
}

func (FluxBucketPredicate) Create added in v0.3.0 

func (p FluxBucketPredicate) Create(obj event.TypedCreateEvent[*sourcev1b2.Bucket]) bool

func (FluxBucketPredicate) Delete added in v0.3.0 

func (p FluxBucketPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1b2.Bucket]) bool

func (FluxBucketPredicate) Generic added in v0.3.0 

func (p FluxBucketPredicate) Generic(obj event.TypedGenericEvent[*sourcev1b2.Bucket]) bool

func (FluxBucketPredicate) Update added in v0.3.0 

func (p FluxBucketPredicate) Update(obj event.TypedUpdateEvent[*sourcev1b2.Bucket]) bool

type FluxGitRepositoryPredicate added in v0.3.0 

type FluxGitRepositoryPredicate struct {
	Logger logr.Logger
}

func (FluxGitRepositoryPredicate) Create added in v0.3.0 

func (p FluxGitRepositoryPredicate) Create(obj event.TypedCreateEvent[*sourcev1.GitRepository]) bool

func (FluxGitRepositoryPredicate) Delete added in v0.3.0 

func (p FluxGitRepositoryPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1.GitRepository]) bool

func (FluxGitRepositoryPredicate) Generic added in v0.3.0 

func (p FluxGitRepositoryPredicate) Generic(obj event.TypedGenericEvent[*sourcev1.GitRepository]) bool

func (FluxGitRepositoryPredicate) Update added in v0.3.0 

func (p FluxGitRepositoryPredicate) Update(obj event.TypedUpdateEvent[*sourcev1.GitRepository]) bool

type FluxOCIRepositoryPredicate added in v0.3.0 

type FluxOCIRepositoryPredicate struct {
	Logger logr.Logger
}

func (FluxOCIRepositoryPredicate) Create added in v0.3.0 

func (p FluxOCIRepositoryPredicate) Create(obj event.TypedCreateEvent[*sourcev1b2.OCIRepository]) bool

func (FluxOCIRepositoryPredicate) Delete added in v0.3.0 

func (p FluxOCIRepositoryPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1b2.OCIRepository]) bool

func (FluxOCIRepositoryPredicate) Generic added in v0.3.0 

func (p FluxOCIRepositoryPredicate) Generic(obj event.TypedGenericEvent[*sourcev1b2.OCIRepository]) bool

func (FluxOCIRepositoryPredicate) Update added in v0.3.0 

func (p FluxOCIRepositoryPredicate) Update(obj event.TypedUpdateEvent[*sourcev1b2.OCIRepository]) bool

type YttSourceReconciler 

type YttSourceReconciler 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 YTTSources referencing the resource
	YttSourceMap         map[types.NamespacedName]*libsveltosset.Set   // key: YTTSource namespace/name; value: set of referenced resources
}

YttSourceReconciler reconciles a YttSource object

func (*YttSourceReconciler) Close 

func (s *YttSourceReconciler) Close(ctx context.Context, yttSource *extensionv1beta1.YttSource,
	patchHelper *patch.Helper) error

Close closes the current scope persisting the YttSource status.

func (*YttSourceReconciler) Reconcile 

func (r *YttSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*YttSourceReconciler) SetupWithManager 

func (r *YttSourceReconciler) SetupWithManager(mgr ctrl.Manager,
) (controller.Controller, error)

SetupWithManager sets up the controller with the Manager.

func (*YttSourceReconciler) WatchForFlux 

func (r *YttSourceReconciler) WatchForFlux(mgr ctrl.Manager, c controller.Controller) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.