Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewStaticObjectFilter (0.18 sec)

  1. pkg/revisions/tag_watcher.go

    		p.notifyHandlers()
    		return nil
    	}))
    	p.webhooks = kclient.NewFiltered[*admissionregistrationv1.MutatingWebhookConfiguration](client, kubetypes.Filter{
    		ObjectFilter: kubetypes.NewStaticObjectFilter(isTagWebhook),
    	})
    	p.index = kclient.CreateIndexWithDelegate[string, *admissionregistrationv1.MutatingWebhookConfiguration](p.webhooks,
    		func(o *admissionregistrationv1.MutatingWebhookConfiguration) []string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kube/kclient/crdwatcher.go

    	}
    
    	c.queue = controllers.NewQueue("crd watcher",
    		controllers.WithReconciler(c.Reconcile))
    	c.crds = NewMetadata(client, gvr.CustomResourceDefinition, Filter{
    		ObjectFilter: kubetypes.NewStaticObjectFilter(minimumVersionFilter),
    	})
    	c.crds.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
    	return c
    }
    
    var minimumCRDVersions = map[string]*semver.Version{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top