- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewWatchedResource (1.41 sec)
-
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)