Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for notified (0.39 sec)

  1. pkg/revisions/tag_watcher.go

    func (p *tagWatcher) GetMyTags() sets.String {
    	res := sets.New(p.revision)
    	for _, wh := range p.index.Lookup(p.revision) {
    		res.Insert(wh.GetLabels()[IstioTagLabel])
    	}
    	return res
    }
    
    // notifyHandlers notifies all registered handlers on tag change.
    func (p *tagWatcher) notifyHandlers() {
    	myTags := p.GetMyTags()
    	for _, handler := range p.handlers {
    		handler(myTags)
    	}
    }
    
    func isTagWebhook(uobj any) bool {
    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/xds/deltatest.go

    				wantDeleted.Insert(c.Name)
    			}
    		} else if diff := cmp.Diff(c.Resource, n.Resource, protocmp.Transform()); diff != "" {
    			// Resource was modified
    			wantChanged.Insert(c.Name)
    		} else {
    			// No diff. Ideally delta doesn't send any update here
    			wantUnchanged.Insert(c.Name)
    		}
    	}
    	for _, v := range sotwRes {
    		if _, f := curByName[v.Name]; !f {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top