Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ExtractObject (0.26 sec)

  1. pkg/revisions/tag_watcher.go

    func (p *tagWatcher) notifyHandlers() {
    	myTags := p.GetMyTags()
    	for _, handler := range p.handlers {
    		handler(myTags)
    	}
    }
    
    func isTagWebhook(uobj any) bool {
    	obj := controllers.ExtractObject(uobj)
    	if obj == nil {
    		return false
    	}
    	_, ok := obj.GetLabels()[IstioTagLabel]
    	return ok
    }
    
    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. pilot/pkg/config/kube/crdclient/client.go

    func (cl *Client) inRevision(obj any) bool {
    	object := controllers.ExtractObject(obj)
    	if object == nil {
    		return false
    	}
    	return config.LabelsInRevision(object.GetLabels(), cl.revision)
    }
    
    func (cl *Client) onEvent(resourceGVK config.GroupVersionKind, old controllers.Object, curr controllers.Object, event model.Event) {
    	currItem := controllers.ExtractObject(curr)
    	if currItem == nil {
    		return
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  3. pkg/kube/namespace/filter.go

    	return d.discoveryNamespaces.Contains(ns)
    }
    
    func extractObjectNamespace(obj any) (string, bool) {
    	if ns, ok := obj.(string); ok {
    		return ns, true
    	}
    	object := controllers.ExtractObject(obj)
    	if object == nil {
    		// When an object is deleted, obj could be a DeletionFinalStateUnknown marker item.
    		return "", false
    	}
    	if _, ok := object.(*corev1.Namespace); ok {
    		return object.GetName(), true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top