Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for Destinations (0.17 sec)

  1. pkg/proxy/iptables/proxier.go

    	if proxier.nodePortAddresses.MatchAll() {
    		destinations := []string{"-m", "addrtype", "--dst-type", "LOCAL"}
    		// Block localhost nodePorts if they are not supported. (For IPv6 they never
    		// work, and for IPv4 they only work if we previously set `route_localnet`.)
    		if isIPv6 {
    			destinations = append(destinations, "!", "-d", "::1/128")
    		} else if !proxier.localhostNodePorts {
    			destinations = append(destinations, "!", "-d", "127.0.0.0/8")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  2. pilot/pkg/model/sidecar_test.go

    			},
    			Spec: &networking.VirtualService{
    				Hosts: []string{"virtualbar"},
    				Http: []*networking.HTTPRoute{
    					{
    						Mirror: &networking.Destination{Host: "foo.svc.cluster.local"},
    						Route:  []*networking.HTTPRouteDestination{{Destination: &networking.Destination{Host: "baz.svc.cluster.local"}}},
    					},
    				},
    			},
    		},
    	}
    
    	virtualServices2 = []config.Config{
    		{
    			Meta: config.Meta{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 07 09:38:49 UTC 2024
    - 74.3K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/proxier.go

    						proxier.localDetector.IfNotLocalNFT(),
    						"jump", markMasqChain,
    					),
    				})
    			}
    		}
    
    		// Set up external traffic handling (if any "external" destinations are
    		// enabled). All captured traffic for all external destinations should
    		// jump to externalTrafficChain, which will handle some special cases and
    		// then jump to externalPolicyChain.
    		if usesExternalTrafficChain {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    		return errors.New("IPVS virtual service does not exist")
    	}
    
    	// curEndpoints represents IPVS destinations listed from current system.
    	curEndpoints := sets.New[string]()
    	curDests, err := proxier.ipvs.GetRealServers(appliedVirtualServer)
    	if err != nil {
    		proxier.logger.Error(err, "Failed to list IPVS destinations")
    		return err
    	}
    	for _, des := range curDests {
    		curEndpoints.Insert(des.String())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/route/route.go

    		}
    	}
    
    	// Now group these Services by port so that we can infer the destination.port if the user
    	// doesn't specify any port for a multiport service. We need to know the destination port in
    	// order to build the cluster name (outbound|<port>|<subset>|<serviceFQDN>)
    	// If the destination service is being accessed on port X, we set that as the default
    	// destination port
    	serviceByPort := make(map[int][]*model.Service)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  6. pilot/pkg/model/push_context.go

    			addDestination(h.Mirror.Host, h.Mirror.GetPort())
    		}
    		for _, m := range h.Mirrors {
    			if m.Destination != nil {
    				addDestination(m.Destination.Host, m.Destination.GetPort())
    			}
    		}
    	}
    	for _, t := range v.Tcp {
    		for _, r := range t.Route {
    			if r.Destination != nil {
    				addDestination(r.Destination.Host, r.Destination.GetPort())
    			}
    		}
    	}
    	for _, t := range v.Tls {
    		for _, r := range t.Route {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  7. tests/integration/ambient/baseline_test.go

    				t.ConfigIstio().Eval(apps.Namespace.Name(), map[string]string{
    					"Destination": dst.Config().Service,
    				}, `apiVersion: networking.istio.io/v1alpha3
    kind: VirtualService
    metadata:
      name: route
    spec:
      hosts:
      - "{{.Destination}}"
      http:
      - route:
        - destination:
            host: "{{.Destination}}"
            subset: v1
    ---
    apiVersion: networking.istio.io/v1beta1
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
  8. pilot/pkg/model/push_context_test.go

    				for _, dst := range route.Route {
    					gotHTTPHosts = append(gotHTTPHosts, dst.Destination.Host)
    				}
    			}
    		}
    		if !reflect.DeepEqual(gotHTTPHosts, []string{"private.ns1", "public.ns3", "delegate.ns2"}) {
    			t.Errorf("got %+v", gotHTTPHosts)
    		}
    	})
    
    	t.Run("destinations by gateway", func(t *testing.T) {
    		got := ps.virtualServiceIndex.destinationsByGateway
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
  9. operator/pkg/apis/istio/v1alpha1/values_types.proto

    message OutboundTrafficPolicyConfig {
      // Specifies the sidecar's default behavior when handling outbound traffic from the application.
      enum Mode {
        // Outbound traffic to unknown destinations will be allowed, in case there are no services or ServiceEntries for the destination port
        ALLOW_ANY = 0;
        // Restrict outbound traffic to services defined in the service registry as well as those defined through ServiceEntries
        REGISTRY_ONLY = 1;
      }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  10. src/runtime/map.go

    func bucketEvacuated(t *maptype, h *hmap, bucket uintptr) bool {
    	b := (*bmap)(add(h.oldbuckets, bucket*uintptr(t.BucketSize)))
    	return evacuated(b)
    }
    
    // evacDst is an evacuation destination.
    type evacDst struct {
    	b *bmap          // current destination bucket
    	i int            // key/elem index into b
    	k unsafe.Pointer // pointer to current key storage
    	e unsafe.Pointer // pointer to current elem storage
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 57.6K bytes
    - Viewed (0)
Back to top