- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for notified (0.39 sec)
-
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) -
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)