- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getClusterID (0.18 sec)
-
pilot/pkg/xds/discovery.go
func (s *DiscoveryServer) SortedClients() []*Connection { clients := s.Clients() sort.Slice(clients, func(i, j int) bool { if clients[i].proxy.GetClusterID().String() < clients[j].proxy.GetClusterID().String() { return true } if clients[i].proxy.GetNamespace() < clients[j].proxy.GetNamespace() { return true } return clients[i].proxy.GetID() < clients[j].proxy.GetID()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/networking/core/tracing.go
pushCtx *model.PushContext, ) (*core.TypedExtensionConfig, error) { dsc := &otelsamplers.DynatraceSamplerConfig{ Tenant: sampler.DynatraceSampler.GetTenant(), ClusterId: sampler.DynatraceSampler.GetClusterId(), RootSpansPerMinute: sampler.DynatraceSampler.GetRootSpansPerMinute(), } if sampler.DynatraceSampler.HttpService == nil { // The Dynatrace sampler can re-use the same Dynatrace service/cluster/headers
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 24.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
e.SetLedger(buildLedger(args.RegistryOptions)) ac := aggregate.NewController(aggregate.Options{ MeshHolder: e, }) e.ServiceDiscovery = ac s := &Server{ clusterID: getClusterID(args), environment: e, fileWatcher: filewatcher.NewWatcher(), httpMux: http.NewServeMux(), monitoringMux: http.NewServeMux(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/context.go
// this can happen for an "old" proxy with no `Metadata.NodeName` set // TODO: remove this when 1.16 is EOL? return node.Labels[label.LabelHostname] } func (node *Proxy) GetClusterID() cluster.ID { if node == nil || node.Metadata == nil { return "" } return node.Metadata.ClusterID } func (node *Proxy) GetNamespace() string { if node == nil || node.Metadata == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
if node != nil && (namespace == "" || node.GetNamespace() == namespace) { syncz = append(syncz, SyncStatus{ ProxyID: node.ID, ProxyType: node.Type, ClusterID: node.GetClusterID().String(), IstioVersion: node.GetIstioVersion(), ClusterSent: con.NonceSent(v3.ClusterType), ClusterAcked: con.NonceAcked(v3.ClusterType),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pilot/pkg/model/service.go
key := WaypointKey{ Network: node.Metadata.Network.String(), } for _, svct := range node.ServiceTargets { ips := svct.Service.ClusterVIPs.GetAddressesFor(node.GetClusterID()) key.Addresses = append(key.Addresses, ips...) } return key } // NoopAmbientIndexes provides an implementation of AmbientIndexes that always returns nil, to easily "skip" it.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
} return nil } func (x *Workload) GetStatus() WorkloadStatus { if x != nil { return x.Status } return WorkloadStatus_HEALTHY } func (x *Workload) GetClusterId() string { if x != nil { return x.ClusterId } return "" } func (x *Workload) GetLocality() *Locality { if x != nil { return x.Locality } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0)