- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 145 for ClusterID (0.15 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go
CanonicalName: "name", CanonicalRevision: "latest", WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "name", Status: workloadapi.WorkloadStatus_UNHEALTHY, ClusterId: testC, }, }, { name: "simple pod not ready", inputs: []any{}, pod: &v1.Pod{ TypeMeta: metav1.TypeMeta{}, ObjectMeta: metav1.ObjectMeta{ Name: "name",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
Ports: []*workloadapi.Port{ { ServicePort: 80, TargetPort: 8081, // port is overridden by inlined WE port }, }, }, }, ClusterId: testC, }, }, }, }}) s.deleteServiceEntry(t, "name1", testNS) s.assertEvent(t, s.seIPXdsName("name1", "127.0.0.1"), "ns1/se.istio.io") assert.Equal(t, s.lookup(s.addrXdsName("127.0.0.1")), nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion_test.go
} ips := service.ClusterVIPs.GetAddressesFor(clusterID) if len(ips) != 1 { t.Fatalf("number of ips incorrect => %q, want 1", len(ips)) } if ips[0] != ip { t.Fatalf("service IP incorrect => %q, want %q", ips[0], ip) } actualIPs := service.ClusterVIPs.GetAddressesFor(clusterID) expectedIPs := []string{ip} if !reflect.DeepEqual(actualIPs, expectedIPs) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
type Component[T ComponentConstraint] struct { mu sync.RWMutex constructor func(cluster *Cluster) T clusters map[cluster.ID]T } func (m *Component[T]) ForCluster(clusterID cluster.ID) *T { m.mu.RLock() defer m.mu.RUnlock() t, f := m.clusters[clusterID] if !f { return nil } return &t } func (m *Component[T]) All() []T { m.mu.RLock() defer m.mu.RUnlock() return maps.Values(m.clusters) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
} labels := labelutil.AugmentLabels(we.Labels, clusterID, locality, "", networkID) return &model.WorkloadInstance{ Endpoint: &model.IstioEndpoint{ Address: addr, // Not setting ports here as its done by k8s controller Network: network.ID(we.Network), Locality: model.Locality{ Label: locality, ClusterID: clusterID, }, LbWeight: we.Weight, Namespace: cfg.Namespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
model.NetworkGatewaysHandler } func initNetworkManager(c *Controller, options Options) *networkManager { n := &networkManager{ clusterID: options.ClusterID, meshNetworksWatcher: options.MeshNetworksWatcher, // zero values are a workaround structcheck issue: https://github.com/golangci/golangci-lint/issues/826 ranger: nil,
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/credentials/kube/multicluster.go
}) return m } func (m *Multicluster) ForCluster(clusterID cluster.ID) (credentials.Controller, error) { cc := m.component.ForCluster(clusterID) if cc == nil { return nil, fmt.Errorf("cluster %v is not configured", clusterID) } agg := &AggregateController{} agg.controllers = []*CredentialsController{} agg.authController = *cc if clusterID != m.configCluster {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 4.2K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
clusterID := cluster.ID(fmt.Sprintf("cluster%d", networkNum)) networkID := network.ID(fmt.Sprintf("network%d", networkNum)) memRegistry := memory.NewServiceDiscovery() memRegistry.XdsUpdater = server.Discovery memRegistry.ClusterID = clusterID reg := serviceregistry.Simple{ ClusterID: clusterID, ProviderID: provider.Mock,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/label/label.go
out[LabelTopologyRegion] = region } if len(zone) > 0 { out[LabelTopologyZone] = zone } if len(subzone) > 0 { out[label.TopologySubzone.Name] = subzone } if len(clusterID) > 0 { out[label.TopologyCluster.Name] = clusterID.String() } if len(k8sNode) > 0 { out[LabelHostname] = k8sNode } if len(networkID) > 0 { out[label.TopologyNetwork.Name] = networkID.String() } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 03:56:40 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/multicluster_analyzers_test.go
return sa, nil } type fakeClientImpl struct { kube.CLIClient clusterID cluster.ID } func (f *fakeClientImpl) ClusterID() cluster.ID { return f.clusterID } func addStore(sa *local.IstiodAnalyzer, clusterName string, yamls []string) error { client := &fakeClientImpl{ CLIClient: kube.NewFakeClient(), clusterID: cluster.ID(clusterName), } // Gather test files
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0)