Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetClusterId (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top