- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for GetWatchedResource (0.26 sec)
-
pkg/xds/server_test.go
) type TestProxy struct { WatchedResources map[string]*WatchedResource } func (p *TestProxy) DeleteWatchedResource(url string) { delete(p.WatchedResources, url) } func (p *TestProxy) GetWatchedResource(url string) *WatchedResource { return p.WatchedResources[url] } func (p *TestProxy) NewWatchedResource(url string, names []string) { p.WatchedResources[url] = &WatchedResource{ResourceNames: names} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
w *model.WatchedResource, sotwRes model.Resources, deltaRes model.Resources, deleted model.DeletedResources, usedDelta bool, delta model.ResourceDelta, incremental bool, ) { current := con.proxy.GetWatchedResource(w.TypeUrl).LastResources if current == nil { log.Debugf("ADS:%s: resources initialized", v3.GetShortType(w.TypeUrl)) return } if deltaRes == nil && deleted == nil && len(sotwRes) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/xds/server.go
// This field is extremely expensive to maintain and is typically disabled LastResources Resources } type Watcher interface { DeleteWatchedResource(url string) GetWatchedResource(url string) *WatchedResource NewWatchedResource(url string, names []string) UpdateWatchedResource(string, func(*WatchedResource) *WatchedResource) // GetID identifies an xDS client. This is different from a connection ID.
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/delta.go
if con.proxy.SidecarScope != nil && con.proxy.SidecarScope.Version != request.Push.PushVersion { s.computeProxyState(con.proxy, request) } err := s.pushDeltaXds(con, con.proxy.GetWatchedResource(req.TypeUrl), request) if err != nil { return err } // Anytime we get a CDS request on reconnect, we should always push EDS as well.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
} func (c *Context) Watcher() xds.Watcher { return c.w } func (w *Watch) DeleteWatchedResource(string) { w.Lock() defer w.Unlock() w.watch = nil } func (w *Watch) GetWatchedResource(string) *xds.WatchedResource { w.Lock() defer w.Unlock() return w.watch } func (w *Watch) NewWatchedResource(typeURL string, names []string) { w.Lock() defer w.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
// computation. if con.proxy.SidecarScope != nil && con.proxy.SidecarScope.Version != request.Push.PushVersion { s.computeProxyState(con.proxy, request) } return s.pushXds(con, con.proxy.GetWatchedResource(req.TypeUrl), request) } // StreamAggregatedResources implements the ADS interface. func (s *DiscoveryServer) StreamAggregatedResources(stream DiscoveryStream) error { return s.Stream(stream) }
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/model/context.go
defer node.RUnlock() ret := sets.NewWithLength[string](len(node.WatchedResources)) for typeURL := range node.WatchedResources { ret.Insert(typeURL) } return ret } func (node *Proxy) GetWatchedResource(typeURL string) *WatchedResource { node.RLock() defer node.RUnlock() return node.WatchedResources[typeURL] } func (node *Proxy) NonceSent(typeURL string) string { node.RLock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
if req == nil { req = &model.PushRequest{Push: conn.proxy.LastPushContext, Start: time.Now(), Full: true} } for _, resourceType := range ts { w := conn.proxy.GetWatchedResource(resourceType) if w == nil { // Not watched, skip continue } gen := s.findGenerator(resourceType, conn) if gen == nil { // No generator found, skip continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)