Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ConnectionsForGroup (0.51 sec)

  1. pilot/pkg/autoregistration/connections.go

    	byProxy map[proxyKey]map[string]connection
    }
    
    func newAdsConnections() *adsConnections {
    	return &adsConnections{byProxy: map[proxyKey]map[string]connection{}}
    }
    
    func (m *adsConnections) ConnectionsForGroup(wg types.NamespacedName) []connection {
    	// collect the proxies that should be disconnected (don't remove them, OnDisconnect will)
    	m.Lock()
    	defer m.Unlock()
    	var conns []connection
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 19 20:41:55 UTC 2023
    - 3K bytes
    - Viewed (0)
  2. pilot/pkg/autoregistration/controller.go

    			// WorkloadGroup doesn't exist anymore, skip this.
    			if c.store.Get(gvk.WorkloadGroup, key.Name, key.Namespace) == nil {
    				return nil
    			}
    			conns := c.adsConnections.ConnectionsForGroup(key)
    			for _, conn := range conns {
    				proxy := conn.Proxy()
    				entryName := autoregisteredWorkloadEntryName(proxy)
    				if entryName == "" {
    					continue
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 26.4K bytes
    - Viewed (0)
Back to top