Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewWatchedResource (0.81 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top