Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 85 for addrtype (0.24 sec)

  1. pkg/controller/endpointslicemirroring/reconciler_helpers.go

    	endpointPorts := epPortsToEpsPorts(subsetPorts)
    	addrTypes := []discovery.AddressType{discovery.AddressTypeIPv4, discovery.AddressTypeIPv6}
    	multiKey := multiAddrTypePortMapKey{}
    
    	for _, addrType := range addrTypes {
    		multiKey[addrType] = newAddrTypePortMapKey(endpointPorts, addrType)
    		if _, ok := d.endpointsByKey[multiKey[addrType]]; !ok {
    			d.endpointsByKey[multiKey[addrType]] = endpointsliceutil.EndpointSet{}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  2. src/cmd/internal/obj/addrtype_string.go

    var _AddrType_index = [...]uint8{0, 9, 20, 33, 41, 51, 62, 73, 81, 90, 100, 111, 123, 133, 145, 157}
    
    func (i AddrType) String() string {
    	if i >= AddrType(len(_AddrType_index)-1) {
    		return "AddrType(" + strconv.FormatInt(int64(i), 10) + ")"
    	}
    	return _AddrType_name[_AddrType_index[i]:_AddrType_index[i+1]]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 01 03:16:26 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/utils_test.go

    				},
    				Ports:       ports,
    				AddressType: addrType,
    				Endpoints:   []discovery.Endpoint{},
    			},
    		},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			ep := endpoints.DeepCopy()
    			tc.tweakEndpoint(ep)
    			generatedSlice := newEndpointSlice(ep, ports, addrType, "")
    			assert.EqualValues(t, tc.expectedSlice, *generatedSlice)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 23 15:40:23 UTC 2022
    - 7.5K bytes
    - Viewed (0)
  4. pkg/controller/endpointslicemirroring/utils.go

    // address types.
    type addrTypePortMapKey string
    
    // newAddrTypePortMapKey generates a PortMapKey from endpoint ports.
    func newAddrTypePortMapKey(endpointPorts []discovery.EndpointPort, addrType discovery.AddressType) addrTypePortMapKey {
    	pmk := fmt.Sprintf("%s-%s", addrType, endpointsliceutil.NewPortMapKey(endpointPorts))
    	return addrTypePortMapKey(pmk)
    }
    
    func (pk addrTypePortMapKey) addressType() discovery.AddressType {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 8.8K bytes
    - Viewed (0)
  5. pkg/util/iptables/testing/parse_test.go

    		{
    			name: "local source",
    			rule: `-A KUBE-XLB-GNZBNJ2PO5MGZ6GT -m comment --comment "masquerade LOCAL traffic for ns2/svc2:p80 LB IP" -m addrtype --src-type LOCAL -j KUBE-MARK-MASQ`,
    			parsed: &Rule{
    				Raw:        `-A KUBE-XLB-GNZBNJ2PO5MGZ6GT -m comment --comment "masquerade LOCAL traffic for ns2/svc2:p80 LB IP" -m addrtype --src-type LOCAL -j KUBE-MARK-MASQ`,
    				Chain:      iptables.Chain("KUBE-XLB-GNZBNJ2PO5MGZ6GT"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 26K bytes
    - Viewed (0)
  6. pkg/util/iptables/save_restore_test.go

    		-A PREROUTING -m addrtype --dst-type LOCAL -j DOCKER
    		-A PREROUTING -m addrtype --dst-type LOCAL -m comment --comment "handle service NodePorts; NOTE: this must be the last rule in the chain" -j KUBE-NODEPORT-CONTAINER
    		-A OUTPUT -m comment --comment "handle ClusterIPs; NOTE: this must be before the NodePort rules" -j KUBE-PORTALS-HOST
    		-A OUTPUT ! -d 127.0.0.0/8 -m addrtype --dst-type LOCAL -j DOCKER
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 5K bytes
    - Viewed (0)
  7. pkg/controller/endpointslicemirroring/reconciler_helpers_test.go

    				}
    			}
    		}
    	}
    }
    
    func simpleEndpointSlice(name, ip string, addrType discovery.AddressType) *discovery.EndpointSlice {
    	return &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    		},
    		AddressType: addrType,
    		Endpoints: []discovery.Endpoint{{
    			Addresses: []string{ip},
    		}},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 06 23:58:47 UTC 2021
    - 7K bytes
    - Viewed (0)
  8. pkg/apis/discovery/validation/validation.go

    	return allErrs
    }
    
    func validateEndpoints(endpoints []discovery.Endpoint, addrType discovery.AddressType, fldPath *field.Path) field.ErrorList {
    	allErrs := field.ErrorList{}
    
    	if len(endpoints) > maxEndpoints {
    		allErrs = append(allErrs, field.TooMany(fldPath, len(endpoints), maxEndpoints))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 18 08:49:15 UTC 2021
    - 7.8K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/network.go

    		Cluster: n.clusterID,
    	}
    	newGateways := model.NetworkGatewaySet{}
    	for _, addr := range gw.Spec.Addresses {
    		if addr.Type == nil {
    			continue
    		}
    		if addrType := *addr.Type; addrType != v1beta1.IPAddressType && addrType != v1beta1.HostnameAddressType {
    			continue
    		}
    		for _, l := range slices.Filter(gw.Spec.Listeners, autoPassthrough) {
    			networkGateway := base
    			networkGateway.Addr = addr.Value
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. pkg/proxy/iptables/proxier_test.go

    	if rule.SourceAddress != nil && !addressMatches(tracer.t, rule.SourceAddress, sourceIP) {
    		return false
    	}
    	if rule.SourceType != nil {
    		addrtype := "not-matched"
    		if tracer.localIPs.Has(sourceIP) {
    			addrtype = "LOCAL"
    		}
    		if !rule.SourceType.Matches(addrtype) {
    			return false
    		}
    	}
    
    	if rule.Protocol != nil && !rule.Protocol.Matches(protocol) {
    		return false
    	}
    
    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