filter

Documentation

Index

• func DeletingPredicate() predicate.Predicate
• func HasLabel(label string) predicate.Predicate
• func KernelDTKReconcilerPredicate() predicate.Predicate
• func ListModulesForNMC(_ context.Context, obj client.Object) []reconcile.Request
• func MatchesNamespacedNamePredicate(nsn types.NamespacedName) predicate.Predicate
• func ModuleNMCReconcileBuildPredicate() predicate.Predicate
• func ModuleNMCReconcilerNodePredicate() predicate.Predicate
• func NodeLabelModuleVersionUpdatePredicate(logger logr.Logger) predicate.Predicate
• func NodeUpdateKernelChangedPredicate() predicate.Predicate
• func PodReadinessChangedPredicate(logger logr.Logger) predicate.Predicate
• func PreflightOCPReconcilerUpdatePredicate() predicate.Predicate
• func PreflightReconcilerUpdatePredicate() predicate.Predicate
• func SkipDeletions() predicate.Predicate
• type Filter
  • func New(client client.Client, nmcHelper nmc.Helper) *Filter
  • func (f *Filter) EnqueueAllPreflightValidations(ctx context.Context, mod client.Object) []reconcile.Request
  • func (f *Filter) FindManagedClusterModulesForCluster(ctx context.Context, cluster client.Object) []reconcile.Request
  • func (f *Filter) FindModulesForNMCNodeChange(ctx context.Context, node client.Object) []reconcile.Request
  • func (f *Filter) FindModulesForNode(ctx context.Context, node client.Object) []reconcile.Request
  • func (f *Filter) ImageStreamReconcilerPredicate() predicate.Predicate
  • func (f *Filter) ManagedClusterModuleReconcilerManagedClusterPredicate() predicate.Predicate
  • func (f *Filter) ModuleReconcilerNodePredicate(kernelLabel string) predicate.Predicate

Functions

func DeletingPredicate

func DeletingPredicate() predicate.Predicate

DeletingPredicate returns a predicate that returns true if the object is being deleted.

func HasLabel

func HasLabel(label string) predicate.Predicate

func KernelDTKReconcilerPredicate

func KernelDTKReconcilerPredicate() predicate.Predicate

NodeKernelReconcilePredicate will queue the request in the following cases: CREATE: always, as we need to make sure we add a new entry to 'kernelToOS' mapping UPDATE: only if the kernel version or the os image version changed DELETE: never

func ListModulesForNMC

func ListModulesForNMC(_ context.Context, obj client.Object) []reconcile.Request

func MatchesNamespacedNamePredicate

func MatchesNamespacedNamePredicate(nsn types.NamespacedName) predicate.Predicate

func ModuleNMCReconcileBuildPredicate

func ModuleNMCReconcileBuildPredicate() predicate.Predicate

func ModuleNMCReconcilerNodePredicate

func ModuleNMCReconcilerNodePredicate() predicate.Predicate

func NodeLabelModuleVersionUpdatePredicate

func NodeLabelModuleVersionUpdatePredicate(logger logr.Logger) predicate.Predicate

func NodeUpdateKernelChangedPredicate

func NodeUpdateKernelChangedPredicate() predicate.Predicate

func PodReadinessChangedPredicate

func PodReadinessChangedPredicate(logger logr.Logger) predicate.Predicate

PodReadinessChangedPredicate returns a predicate for Update events that only returns true if the Ready condition changed.

func PreflightOCPReconcilerUpdatePredicate

func PreflightOCPReconcilerUpdatePredicate() predicate.Predicate

func PreflightReconcilerUpdatePredicate

func PreflightReconcilerUpdatePredicate() predicate.Predicate

func SkipDeletions

func SkipDeletions() predicate.Predicate

Types

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func New

func New(client client.Client, nmcHelper nmc.Helper) *Filter

func (*Filter) EnqueueAllPreflightValidations

func (f *Filter) EnqueueAllPreflightValidations(ctx context.Context, mod client.Object) []reconcile.Request

func (*Filter) FindManagedClusterModulesForCluster

func (f *Filter) FindManagedClusterModulesForCluster(ctx context.Context, cluster client.Object) []reconcile.Request

func (*Filter) FindModulesForNMCNodeChange

func (f *Filter) FindModulesForNMCNodeChange(ctx context.Context, node client.Object) []reconcile.Request

FindModulesForNMCNodeChange finds the modules that are affected by node changes that result in ModuleNMCReconcilerNodePredicate predicate. First it find all the Module that can run on the node, based on the Modules' Selector field and on node's labels. Then, in case NMC for the node exists, it adds all the Modules already set in NMC ( in case they were not added in a previous step).

func (*Filter) FindModulesForNode

func (f *Filter) FindModulesForNode(ctx context.Context, node client.Object) []reconcile.Request

func (*Filter) ImageStreamReconcilerPredicate

func (f *Filter) ImageStreamReconcilerPredicate() predicate.Predicate

func (*Filter) ManagedClusterModuleReconcilerManagedClusterPredicate

func (f *Filter) ManagedClusterModuleReconcilerManagedClusterPredicate() predicate.Predicate

func (*Filter) ModuleReconcilerNodePredicate

func (f *Filter) ModuleReconcilerNodePredicate(kernelLabel string) predicate.Predicate