- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 356 for svcs (0.04 sec)
-
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/kube/controller/serviceexportcache_test.go
} hostName := host.Name(event.ID) svc := ec.GetService(hostName) if svc == nil { return fmt.Errorf("unable to find service for host %s", hostName) } return ec.checkEndpoint(exported, event.Endpoints[0]) }, serviceExportTimeout) } func (ec *serviceExportCacheImpl) getEndpoint(endpoints *model.EndpointIndex) *model.IstioEndpoint { svcs := ec.Services() for _, s := range svcs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.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) -
pilot/pkg/networking/core/cluster.go
var deleted []string var svcs []*model.Service switch key.Kind { case kind.ServiceEntry: svcs, deleted = configgen.deltaFromServices(key, proxy, updates.Push, serviceClusters, servicePortClusters, subsetClusters) case kind.DestinationRule: svcs, deleted = configgen.deltaFromDestinationRules(key, proxy, subsetClusters) } services = append(services, svcs...) deletedClusters.InsertAll(deleted...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
// Adding a pod in the service should not trigger an update for that pod - we didn't explicitly subscribe createPod(s, "pod5", "not-sa", "127.0.0.5", "not-node") ads.ExpectNoResponse() // And if the service changes to no longer select them, we should see them *removed* (not updated) createService(s, "svc1", "default", map[string]string{"app": "nothing"})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
printPod(writer, pod, opts.Revision) svcs, err := client.Kube().CoreV1().Services(ns).List(context.TODO(), metav1.ListOptions{}) if err != nil { return err } matchingServices := make([]corev1.Service, 0, len(svcs.Items)) for _, svc := range svcs.Items { if len(svc.Spec.Selector) > 0 { svcSelector := klabels.SelectorFromSet(svc.Spec.Selector) if svcSelector.Matches(podLabels) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
func checkExternalNameAlias(cli kube.CLIClient, messages *diag.Messages) error { svcs, err := cli.Kube().CoreV1().Services(metav1.NamespaceAll).List(context.Background(), metav1.ListOptions{}) if err != nil { return err } for _, svc := range svcs.Items { if svc.Spec.Type != corev1.ServiceTypeExternalName { continue } res := ObjectToInstance(&svc) messages.Add(msg.NewUpdateIncompatibility(res,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 02:57:30 UTC 2024 - 19.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
}, }, []*model.Service{svc1, svc2, svc3}, 2, meshWatcher, fx, controller, ) // permit all discovery namespaces by omitting discovery selectors (1 create event should trigger for the nsC service) updateMeshConfig( &meshconfig.MeshConfig{ DiscoverySelectors: []*meshconfig.LabelSelector{}, }, []*model.Service{svc1, svc2, svc3, svc4}, 1, meshWatcher, fx,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
}, }, }, } return pods, svc } func streamTestData() (io.Reader, *v1.PodList, *v1.ServiceList) { pods, svc := testData() r, w := io.Pipe() go func() { defer w.Close() w.Write([]byte(runtime.EncodeOrDie(corev1Codec, pods))) w.Write([]byte(runtime.EncodeOrDie(corev1Codec, svc))) }() return r, pods, svc } func subresourceTestData(name string) *v1.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
for _, svc := range gotServices { if v, ok := gotIPMap[svc.AutoAllocatedIPv4Address]; ok && v != svc.Hostname.String() { t.Errorf("multiple allocations of same IP address to different services with different hostname: %s", svc.AutoAllocatedIPv4Address) } gotIPMap[svc.AutoAllocatedIPv4Address] = svc.Hostname.String() serviceIPMap[svc.Hostname.String()] = svc.AutoAllocatedIPv4Address }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0)