Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for newServiceInfo (0.22 sec)

  1. pkg/proxy/nftables/proxier.go

    	if err != nil {
    		return nil, err
    	}
    
    	proxier := &Proxier{
    		ipFamily:            ipFamily,
    		svcPortMap:          make(proxy.ServicePortMap),
    		serviceChanges:      proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:        make(proxy.EndpointsMap),
    		endpointsChanges:    proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    		syncPeriod:          syncPeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. pkg/proxy/winkernel/proxier.go

    	if !exists {
    		refCountMap[hnsID] = new(uint16)
    		refCount = refCountMap[hnsID]
    	}
    	return refCount
    }
    
    // returns a new proxy.ServicePort which abstracts a serviceInfo
    func (proxier *Proxier) newServiceInfo(port *v1.ServicePort, service *v1.Service, bsvcPortInfo *proxy.BaseServicePortInfo) proxy.ServicePort {
    	info := &serviceInfo{BaseServicePortInfo: bsvcPortInfo}
    	preserveDIP := service.Annotations["preserve-destination"] == "true"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier_test.go

    		endPointsRefCount:     make(endPointsReferenceCountMap),
    		forwardHealthCheckVip: true,
    		mapStaleLoadbalancers: make(map[string]bool),
    	}
    
    	serviceChanges := proxy.NewServiceChangeTracker(proxier.newServiceInfo, v1.IPv4Protocol, nil, proxier.serviceMapChange)
    	endpointsChangeTracker := proxy.NewEndpointsChangeTracker(hostname, proxier.newEndpointInfo, v1.IPv4Protocol, nil, proxier.endpointsMapChange)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier.go

    	}
    
    	proxier := &Proxier{
    		ipFamily:                 ipFamily,
    		svcPortMap:               make(proxy.ServicePortMap),
    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier.go

    	proxier := &Proxier{
    		ipFamily:              ipFamily,
    		svcPortMap:            make(proxy.ServicePortMap),
    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:          make(proxy.EndpointsMap),
    		endpointsChanges:      proxy.NewEndpointsChangeTracker(hostname, nil, ipFamily, recorder, nil),
    		initialSync:           true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  6. pkg/proxy/nftables/proxier_test.go

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

    		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),
    		endpointsChanges:      proxy.NewEndpointsChangeTracker(testHostname, nil, ipFamily, nil, nil),
    		excludeCIDRs:          excludeCIDRs,
    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/iptables/proxier_test.go

    	p := &Proxier{
    		ipFamily:                 ipfamily,
    		svcPortMap:               make(proxy.ServicePortMap),
    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipfamily, nil, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(testHostname, newEndpointInfo, ipfamily, nil, nil),
    		needFullSync:             true,
    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