Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 124 for EndpointPort (0.18 sec)

  1. pilot/pkg/model/service_test.go

    			ServiceAccount:  "service-account",
    			Network:         "Network",
    			Locality: Locality{
    				ClusterID: "cluster-id",
    				Label:     "region1/zone1/subzone1",
    			},
    			EndpointPort: 22,
    			LbWeight:     100,
    			TLSMode:      "mutual",
    		},
    	}
    	differingAddr := exampleInstance.DeepCopy()
    	differingAddr.Endpoint.Address = "another-address"
    	differingNetwork := exampleInstance.DeepCopy()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster_builder.go

    		}
    	}
    
    	return ec
    }
    
    // buildInboundCluster constructs a single inbound cluster. The cluster will be bound to
    // `inbound|clusterPort||`, and send traffic to <bind>:<instance.Endpoint.EndpointPort>. A workload
    // will have a single inbound cluster per port. In general this works properly, with the exception of
    // the Service-oriented DestinationRule, and upstream protocol selection. Our documentation currently
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/conversion_test.go

    			for _, svc := range services {
    				instances = append(instances, &model.ServiceInstance{
    					Service:     svc,
    					ServicePort: ports[0],
    					Endpoint:    &model.IstioEndpoint{EndpointPort: 8080},
    				}, &model.ServiceInstance{
    					Service:     svc,
    					ServicePort: ports[1],
    					Endpoint:    &model.IstioEndpoint{},
    				}, &model.ServiceInstance{
    					Service:     svc,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 20:24:52 UTC 2024
    - 34.9K bytes
    - Viewed (0)
  4. pkg/dns/server/name_table_test.go

    	for _, p := range svc.Ports {
    		if p.Port != servicePort {
    			continue
    		}
    		ret = append(ret, &model.IstioEndpoint{
    			Address:         proxy.IPAddresses[0],
    			ServicePortName: p.Name,
    			EndpointPort:    uint32(targetPort),
    		})
    	}
    	return ret
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jan 25 04:26:03 UTC 2024
    - 16K bytes
    - Viewed (0)
  5. pkg/proxy/iptables/number_generated_rules_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "ep",
    			Namespace: "namespace",
    		},
    		AddressType: discovery.AddressTypeIPv4,
    		Endpoints:   []discovery.Endpoint{},
    		Ports: []discovery.EndpointPort{{
    			Name:     ptr.To(fmt.Sprintf("%d", epPort)),
    			Port:     ptr.To(int32(epPort)),
    			Protocol: ptr.To(v1.ProtocolTCP),
    		}},
    	}
    
    	for j := 0; j < nEndpoints; j++ {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. pkg/apis/core/v1/zz_generated.conversion.go

    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*v1.EndpointPort)(nil), (*core.EndpointPort)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_EndpointPort_To_core_EndpointPort(a.(*v1.EndpointPort), b.(*core.EndpointPort), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*core.EndpointPort)(nil), (*v1.EndpointPort)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 472.1K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    				}
    				si := model.ServiceTarget{
    					Service: svc,
    					Port: model.ServiceInstancePort{
    						ServicePort: port,
    						TargetPort:  instance.EndpointPort,
    					},
    				}
    				out = append(out, si)
    			}
    		}
    	}
    	return out
    }
    
    func (esc *endpointSliceController) deleteEndpointSlice(slice *v1.EndpointSlice) {
    	key := config.NamespacedName(slice)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/controller.go

    	// by default, use the numbered targetPort
    	istioEndpoint.EndpointPort = uint32(targetPort.num)
    
    	if targetPort.name != "" {
    		// This is a named port, find the corresponding port in the port map
    		matchedPort := wi.PortMap[targetPort.name]
    		if matchedPort != 0 {
    			istioEndpoint.EndpointPort = matchedPort
    		} else if targetPort.explicitName {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  9. pilot/pkg/xds/endpoints/ep_filters_test.go

    	}}
    	// apply common properties
    	for sk, shard := range shards.Shards {
    		for i, ep := range shard {
    			ep.ServicePortName = "http"
    			ep.Namespace = "ns"
    			ep.HostName = "example.ns.svc.cluster.local"
    			ep.EndpointPort = 8080
    			ep.TLSMode = "istio"
    			if ep.Labels == nil {
    				ep.Labels = make(map[string]string)
    			}
    			ep.Labels["app"] = "example"
    			ep.Locality.ClusterID = sk.Cluster
    			shards.Shards[sk][i] = ep
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  10. pilot/pkg/xds/mesh_network_test.go

    					Namespace:  podMeta.Namespace,
    				},
    				DeprecatedTopology: nil,
    				NodeName:           nil,
    				Zone:               nil,
    				Hints:              nil,
    			}},
    			Ports: []discoveryv1.EndpointPort{{
    				Name:     ptr.Of("http"),
    				Port:     ptr.Of(w.port),
    				Protocol: ptr.Of(corev1.ProtocolTCP),
    			}},
    		},
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 24.6K bytes
    - Viewed (0)
Back to top