- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NewWatchedResource (0.22 sec)
-
pkg/xds/server_test.go
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} } func (p *TestProxy) UpdateWatchedResource(url string, f func(*WatchedResource) *WatchedResource) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/xds/server.go
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. GetID() string }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
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() w.watch = &xds.WatchedResource{TypeUrl: typeURL, ResourceNames: names} }
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/model/context.go
node.RLock() defer node.RUnlock() wr := node.WatchedResources[v3.EndpointType] if wr != nil { return wr.ResourceNames } return nil } func (node *Proxy) NewWatchedResource(typeURL string, names []string) { node.Lock() defer node.Unlock() node.WatchedResources[typeURL] = &WatchedResource{TypeUrl: typeURL, ResourceNames: names}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0)