Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for servicePortMap (0.32 sec)

  1. pkg/config/analysis/analyzers/deployment/services.go

    		}
    
    		return true
    	})
    
    	return matchingSvcs
    }
    
    // servicePortMap build a map of ports and protocols for each Service. e.g. m[80]["TCP"] -> svcA, svcB, svcC
    func servicePortMap(svcs []ServiceSpecWithName) PortMap {
    	portMap := PortMap{}
    
    	for _, swn := range svcs {
    		svc := swn.Spec
    		for _, sPort := range svc.Ports {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. pkg/proxy/servicechangetracker_test.go

    	endpointsChanges *EndpointsChangeTracker
    	serviceChanges   *ServiceChangeTracker
    	svcPortMap       ServicePortMap
    	endpointsMap     EndpointsMap
    	hostname         string
    }
    
    func newFakeProxier(ipFamily v1.IPFamily, t time.Time) *FakeProxier {
    	return &FakeProxier{
    		svcPortMap:     make(ServicePortMap),
    		serviceChanges: NewServiceChangeTracker(nil, ipFamily, nil, nil),
    		endpointsMap:   make(EndpointsMap),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier.go

    				epInfo, ok := ep.(*endpointInfo)
    
    				if ok {
    					epInfo.Cleanup()
    				}
    
    			}
    		}
    	}
    }
    
    func (proxier *Proxier) serviceMapChange(previous, current proxy.ServicePortMap) {
    	for svcPortName := range current {
    		proxier.onServiceMapChange(&svcPortName)
    	}
    
    	for svcPortName := range previous {
    		if _, ok := current[svcPortName]; ok {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    	endpointsChanges *proxy.EndpointsChangeTracker
    	serviceChanges   *proxy.ServiceChangeTracker
    
    	mu           sync.Mutex // protects the following fields
    	svcPortMap   proxy.ServicePortMap
    	endpointsMap proxy.EndpointsMap
    	nodeLabels   map[string]string
    	// endpointSlicesSynced, and servicesSynced are set to true
    	// when corresponding objects are synced after startup. This is used to avoid
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/iptables/proxier.go

    	endpointsChanges *proxy.EndpointsChangeTracker
    	serviceChanges   *proxy.ServiceChangeTracker
    
    	mu           sync.Mutex // protects the following fields
    	svcPortMap   proxy.ServicePortMap
    	endpointsMap proxy.EndpointsMap
    	nodeLabels   map[string]string
    	// endpointSlicesSynced, and servicesSynced are set to true
    	// when corresponding objects are synced after startup. This is used to avoid
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier.go

    	endpointsChanges *proxy.EndpointsChangeTracker
    	serviceChanges   *proxy.ServiceChangeTracker
    
    	mu           sync.Mutex // protects the following fields
    	svcPortMap   proxy.ServicePortMap
    	endpointsMap proxy.EndpointsMap
    	nodeLabels   map[string]string
    	// initialSync is a bool indicating if the proxier is syncing for the first time.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  7. pkg/proxy/ipvs/proxier_test.go

    	ipsetList := make(map[string]*IPSet)
    	for _, is := range ipsetInfo {
    		ipsetList[is.name] = NewIPSet(ipset, is.name, is.setType, false, is.comment)
    	}
    	p := &Proxier{
    		svcPortMap:            make(proxy.ServicePortMap),
    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, nil, nil),
    		endpointsMap:          make(proxy.EndpointsMap),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  8. pkg/proxy/nftables/proxier_test.go

    		nodeIP = netutils.ParseIPSloppy(testNodeIP)
    	} else {
    		nodeIP = netutils.ParseIPSloppy(testNodeIPv6)
    	}
    	p := &Proxier{
    		ipFamily:            ipFamily,
    		svcPortMap:          make(proxy.ServicePortMap),
    		serviceChanges:      proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, nil, nil),
    		endpointsMap:        make(proxy.EndpointsMap),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  9. pkg/proxy/iptables/proxier_test.go

    	}
    	networkInterfacer.AddInterfaceAddr(&itf1, addrs1)
    
    	p := &Proxier{
    		ipFamily:                 ipfamily,
    		svcPortMap:               make(proxy.ServicePortMap),
    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipfamily, nil, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
Back to top