Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for serviceTargets (0.45 sec)

  1. pilot/pkg/networking/core/cluster_builder.go

    }
    
    // NewClusterBuilder builds an instance of ClusterBuilder.
    func NewClusterBuilder(proxy *model.Proxy, req *model.PushRequest, cache model.XdsCache) *ClusterBuilder {
    	cb := &ClusterBuilder{
    		serviceTargets:     proxy.ServiceTargets,
    		proxyID:            proxy.ID,
    		proxyType:          proxy.Type,
    		proxyVersion:       proxy.Metadata.IstioVersion,
    		sidecarScope:       proxy.SidecarScope,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster.go

    type buildClusterOpts struct {
    	mesh            *meshconfig.MeshConfig
    	mutable         *clusterWrapper
    	policy          *networking.TrafficPolicy
    	port            *model.Port
    	serviceAccounts []string
    	serviceTargets  []model.ServiceTarget
    	// Used for traffic across multiple network clusters
    	// the east-west gateway in a remote cluster will use this value to route
    	// traffic to the appropriate service
    	istioMtlsSni    string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_inbound.go

    	ingressPortListSet := sets.New[int]()
    	sidecarScope := lb.node.SidecarScope
    	if sidecarScope.HasIngressListener() {
    		ingressPortListSet = getSidecarIngressPortList(lb.node)
    	}
    	for _, i := range lb.node.ServiceTargets {
    		bindToPort := getBindToPort(networking.CaptureMode_DEFAULT, lb.node)
    		// Skip ports we cannot bind to
    		if !lb.node.CanBindToPort(bindToPort, i.Port.TargetPort) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster_test.go

    		name      string
    		direction model.TrafficDirection
    		cluster   *cluster.Cluster
    		svcInsts  []model.ServiceTarget
    		service   *model.Service
    		want      *core.Metadata
    	}{
    		{
    			name:      "no cluster",
    			direction: model.TrafficDirectionInbound,
    			cluster:   nil,
    			svcInsts: []model.ServiceTarget{
    				{
    					Service: &model.Service{
    						Attributes: model.ServiceAttributes{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  5. pilot/pkg/model/gateway.go

    				if s.GetTls().GetMode() == networking.ServerTLSSettings_AUTO_PASSTHROUGH {
    					hosts.InsertAll(s.Hosts...)
    				}
    			}
    		}
    	}
    	return hosts
    }
    
    func udpSupportedPort(number uint32, instances []ServiceTarget) bool {
    	for _, w := range instances {
    		if int(number) == w.Port.Port && w.Port.Protocol == protocol.UDP {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster_builder_test.go

    		t.Run(tc.name, func(t *testing.T) {
    			test.SetForTest(t, &features.EnableAutoSni, tc.enableAutoSni)
    			test.SetForTest(t, &features.VerifyCertAtClient, tc.enableVerifyCertAtClient)
    
    			targets := []model.ServiceTarget{
    				{
    					Service: tc.service,
    					Port: model.ServiceInstancePort{
    						ServicePort: tc.port,
    						TargetPort:  10001,
    					},
    				},
    			}
    
    			var cfg *config.Config
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
Back to top