- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for istioEndpoints (0.19 sec)
-
pilot/pkg/serviceregistry/kube/conversion.go
} return istioService } func ExternalNameEndpoints(svc *model.Service) []*model.IstioEndpoint { if svc.Attributes.ExternalName == "" { return nil } out := make([]*model.IstioEndpoint, 0, len(svc.Ports)) discoverabilityPolicy := model.AlwaysDiscoverable if features.EnableMCSServiceDiscovery {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/model/proxy_view_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.7K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
ds := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) sd := ds.MemRegistry sd.AddHTTPService("fortio1.fortio.svc.cluster.local", "10.10.10.1", 8081) sd.SetEndpoints("fortio1.fortio.svc.cluster.local", "", []*model.IstioEndpoint{ { Address: "127.0.0.1", EndpointPort: uint32(14056), ServicePortName: "http-main", }, }) return ds }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/mtls_checker.go
// on the DR, original endpoint TLSMode (based on injection of sidecar), and PeerAuthentication settings. func (c *mtlsChecker) checkMtlsEnabled(ep *model.IstioEndpoint, isWaypoint bool) bool { if drMode := c.destinationRule; drMode != nil { return *drMode == networkingapi.ClientTLSSettings_ISTIO_MUTUAL }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 3.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/mock/discovery.go
return nil } // we make port 80 same as endpoint port, otherwise, it's distinct target := port.Port if target != 80 { target += 1000 } return &model.ServiceInstance{ Endpoint: &model.IstioEndpoint{ Address: MakeIP(service, version), EndpointPort: uint32(target), ServicePortName: port.Name, Labels: map[string]string{"version": fmt.Sprintf("v%d", version)}, Locality: locality,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 3.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
} func (gc GatewayContext) GetService(hostname, namespace string) *model.Service { return gc.ps.ServiceIndex.HostnameAndNamespace[host.Name(hostname)][namespace] } func instancesEmpty(m map[int][]*model.IstioEndpoint) bool { for _, instances := range m { if len(instances) > 0 { return false } } return true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0)