- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 124 for EndpointPort (0.19 sec)
-
pilot/pkg/networking/grpcgen/grpcgen_test.go
Protocol: protocol.GRPC, // SetEndpoints hardcodes this }, }, }) sd.SetEndpoints(testSvcHost, "istio-system", []*model.IstioEndpoint{ { Address: "127.0.0.1", EndpointPort: uint32(xdsPort), ServicePortName: "grpc-main", }, }) } // initPersistent creates echo-persistent.test:9999, type GRPC with one drained endpoint func initPersistent(sd *memory.ServiceDiscovery) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/printers/json_test.go
"nonEmptyPodList": &v1.PodList{Items: []v1.Pod{{}}}, "endpoints": &v1.Endpoints{ Subsets: []v1.EndpointSubset{{ Addresses: []v1.EndpointAddress{{IP: "127.0.0.1"}, {IP: "localhost"}}, Ports: []v1.EndpointPort{{Port: 8080}}, }}}, } // Test PrintObj() success. for pName, p := range genericPrinters { for oName, obj := range objects { b := &bytes.Buffer{} if err := p.PrintObj(obj, b); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
// Hack up some instances for each Service for _, s := range o.Services { i := &model.ServiceInstance{ Service: s, Endpoint: &model.IstioEndpoint{ Address: "1.1.1.1", EndpointPort: 8080, // service port is 80, target port is 8080 }, ServicePort: s.Ports[0], } cg.MemRegistry.AddInstance(i) } l := cg.Listeners(cg.SetupProxy(p)) xdstest.ValidateListeners(t, l) return l }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// 1. ep.Address can be empty since https://github.com/istio/istio/pull/45150, in this case we will replace it with gateway ip. // 2. ep.Address can be uds when EndpointPort = 0 if ep.Address != "" && ep.EndpointPort != 0 && !netutil.IsValidIPAddress(ep.Address) { return false } // filter out endpoints that don't match the subset if !b.subsetLabels.SubsetOf(ep.Labels) { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
slice := sliceList.Items[0] assert.Regexp(t, "^"+serviceName, slice.Name) assert.Equal(t, serviceName, slice.Labels[discovery.LabelServiceName]) assert.EqualValues(t, []discovery.EndpointPort{}, slice.Ports) assert.EqualValues(t, []discovery.Endpoint{}, slice.Endpoints) assert.NotEmpty(t, slice.Annotations["endpoints.kubernetes.io/last-change-trigger-time"]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
func addEndpointSubset(logger klog.Logger, subsets []v1.EndpointSubset, pod *v1.Pod, epa v1.EndpointAddress, epp *v1.EndpointPort, tolerateUnreadyEndpoints bool) ([]v1.EndpointSubset, int, int) { var readyEps int var notReadyEps int ports := []v1.EndpointPort{} if epp != nil { ports = append(ports, *epp) } if tolerateUnreadyEndpoints || podutil.IsPodReady(pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
tests/integration/pilot/testdata/mcs-serviceimport-crd.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 17 00:51:29 UTC 2021 - 7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/model/service.go
// Network holds the network where this endpoint is present Network network.ID // The locality where the endpoint is present. Locality Locality // EndpointPort is the port where the workload is listening, can be different // from the service port. EndpointPort uint32 // The load balancing weight associated with this endpoint. LbWeight uint32
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
ServicePort: servicePort, Endpoint: &model.IstioEndpoint{ Address: "1.1.1.1", EndpointPort: 10001, }, }, { Service: service, ServicePort: servicePort, Endpoint: &model.IstioEndpoint{ Address: "2001:1::1", EndpointPort: 10001, }, }, } inboundFilter := func(c *cluster.Cluster) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0)