- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 228 for svcs (0.2 sec)
-
istioctl/pkg/writer/ztunnel/configdump/services.go
for _, svc := range svcs { var ip string if len(svc.Addresses) > 0 { _, ip, _ = strings.Cut(svc.Addresses[0], "/") } waypoint := serviceWaypointName(svc, zDump.Services) fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", svc.Namespace, svc.Name, ip, waypoint) } return w.Flush() } // PrintServiceDump prints the relevant services in the config dump to the ConfigWriter stdout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
if len(svcs) != test.services { t.Fatalf("expected %d service, received %d", test.services, len(svcs)) } if len(eps) != test.services { t.Fatalf("expected %d endpoint slice , received %d", test.services, len(eps)) } for i := 0; i < test.services; i++ { if svcs[i].Spec.Type != test.svcType { t.Fatalf("expected Service Type %s, got %s", test.svcType, svcs[i].Spec.Type) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/config/analysis/analyzers/deployment/services.go
}) return matchingSvcs } // servicePortMap build a map of ports and protocols for each Service. e.g. m[80]["TCP"] -> svcA, svcB, svcC func servicePortMap(svcs []ServiceSpecWithName) PortMap { portMap := PortMap{} for _, swn := range svcs { svc := swn.Spec for _, sPort := range svc.Ports { // If it is the first occurrence of this port, create a ProtocolMap if _, ok := portMap[sPort.Port]; !ok {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 6.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_waypoint.go
clusters := []*cluster.Cluster{} for _, svc := range svcs { for _, port := range svc.Ports { if port.Protocol == protocol.UDP { continue } if port.Protocol.IsUnsupported() || port.Protocol.IsTCP() { clusters = append(clusters, cb.buildWaypointInboundVIPCluster(proxy, svc, *port, "tcp").build()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
svcs := sortMCSServices(s.Env.MCSServices()) writeJSON(w, svcs, req) } func sortMCSServices(svcs []model.MCSServiceInfo) []model.MCSServiceInfo { sort.Slice(svcs, func(i, j int) bool { if strings.Compare(svcs[i].Cluster.String(), svcs[j].Cluster.String()) < 0 { return true } if strings.Compare(svcs[i].Namespace, svcs[j].Namespace) < 0 { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
framework.NewTest(t). Run(func(t framework.TestContext) { svcs := apps.All for _, svc := range svcs { if svc.Config().IsUncaptured() || svc.Config().HasSidecar() { continue } t.NewSubTestf("ALLOW_ANY %v to external service", svc.Config().Service).Run(func(t framework.TestContext) { svc.CallOrFail(t, echo.CallOptions{ Address: apps.MockExternal.ClusterLocalFQDN(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
func (c *Controller) updateServiceNodePortAddresses(svcs ...*model.Service) bool { // node event, update all nodePort gateway services if len(svcs) == 0 { svcs = c.getNodePortGatewayServices() } // no nodePort gateway service found, no update if len(svcs) == 0 { return false } for _, svc := range svcs { c.RLock() nodeSelector := c.nodeSelectorsForServices[svc.Hostname] c.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
// Locking Registries list while walking it to prevent inconsistent results for _, r := range c.GetRegistries() { svcs := r.Services() if r.Provider() != provider.Kubernetes { index += len(svcs) services = append(services, svcs...) } else { for _, s := range svcs { previous, ok := smap[s.Hostname] if !ok { // First time we see a service. The result will have a single service per hostname
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store.go
} // getAllServices return all the services. func (s *serviceStore) getAllServices() []*model.Service { out := make([]*model.Service, 0, countSliceValue(s.servicesBySE)) for _, svcs := range s.servicesBySE { out = append(out, svcs...) } return model.SortServicesByCreationTime(out) } func (s *serviceStore) getServices(key types.NamespacedName) []*model.Service { return s.servicesBySE[key] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
) // NewServiceDiscovery builds an in-memory ServiceDiscovery func NewServiceDiscovery(services ...*model.Service) *ServiceDiscovery { svcs := map[host.Name]*model.Service{} for _, svc := range services { svcs[svc.Hostname] = svc } return &ServiceDiscovery{ services: svcs, instancesByPortNum: map[string][]*model.ServiceInstance{}, instancesByPortName: map[string][]*model.ServiceInstance{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0)