- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ShouldRespond (0.13 sec)
-
security/pkg/nodeagent/sds/sdsservice.go
if res == secretName { return true } } } return false } func (c *Context) Process(req *discovery.DiscoveryRequest) error { shouldRespond, delta := xds.ShouldRespond(c.Watcher(), c.XdsConnection().ID(), req) if !shouldRespond { return nil } resources := req.ResourceNames if !delta.IsEmpty() { resources = delta.Subscribed.UnsortedList() } res, err := c.s.generate(resources)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/xds/server.go
return } } } // ShouldRespond determines whether this request needs to be responded back. It applies the ack/nack rules as per xds protocol // using WatchedResource for previous state and discovery request for the current state. func ShouldRespond(w Watcher, id string, request *discovery.DiscoveryRequest) (bool, ResourceDelta) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
} if s.StatusReporter != nil { s.StatusReporter.RegisterEvent(con.ID(), req.TypeUrl, req.ResponseNonce) } shouldRespond, delta := xds.ShouldRespond(con.proxy, con.ID(), req) if !shouldRespond { return nil } request := &model.PushRequest{ Full: true, Push: con.proxy.LastPushContext, Reason: model.NewReasonStats(model.ProxyRequest),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} if s.StatusReporter != nil { s.StatusReporter.RegisterEvent(con.ID(), req.TypeUrl, req.ResponseNonce) } shouldRespond := s.shouldRespondDelta(con, req) if !shouldRespond { return nil } subs, _ := deltaWatchedResources(nil, req) request := &model.PushRequest{ Full: true, Push: con.proxy.LastPushContext,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)