Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for clusterAliases (0.14 sec)

  1. pilot/pkg/xds/discovery.go

    			enableEDSDebounce: features.EnableEDSDebounce,
    		},
    		Cache:              env.Cache,
    		DiscoveryStartTime: processStartTime,
    	}
    
    	out.ClusterAliases = make(map[cluster.ID]cluster.ID)
    	for alias := range clusterAliases {
    		out.ClusterAliases[cluster.ID(alias)] = cluster.ID(clusterAliases[alias])
    	}
    
    	out.initJwksResolver()
    
    	return out
    }
    
    // initJwkResolver initializes the JWT key resolver to be used.
    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/cmd/pilot-discovery/app/cmd.go

    		"The ID of the cluster that this Istiod instance resides")
    	c.PersistentFlags().StringToStringVar(&serverArgs.RegistryOptions.KubeOptions.ClusterAliases, "clusterAliases", map[string]string{},
    		"Alias names for clusters")
    
    	// using address, so it can be configured as localhost:.. (possibly UDS in future)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:44:32 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller.go

    	DomainSuffix string
    
    	// ClusterID identifies the cluster which the controller communicate with.
    	ClusterID cluster.ID
    
    	// ClusterAliases are alias names for cluster. When a proxy connects with a cluster ID
    	// and if it has a different alias we should use that a cluster ID for proxy.
    	ClusterAliases map[string]string
    
    	// Metrics for capturing node-based metrics.
    	Metrics model.Metrics
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  4. pilot/pkg/xds/ads.go

    	proxy, err := s.initProxyMetadata(node)
    	if err != nil {
    		return err
    	}
    	// Check if proxy cluster has an alias configured, if yes use that as cluster ID for this proxy.
    	if alias, exists := s.ClusterAliases[proxy.Metadata.ClusterID]; exists {
    		proxy.Metadata.ClusterID = alias
    	}
    	// To ensure push context is monotonically increasing, setup LastPushContext before we addCon. This
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pilot/pkg/bootstrap/server.go

    	for _, fn := range initFuncs {
    		fn(s)
    	}
    	// Initialize workload Trust Bundle before XDS Server
    	e.TrustBundle = s.workloadTrustBundle
    	s.XDSServer = xds.NewDiscoveryServer(e, args.RegistryOptions.KubeOptions.ClusterAliases)
    	configGen := core.NewConfigGenerator(s.XDSServer.Cache)
    
    	grpcprom.EnableHandlingTimeHistogram()
    
    	// make sure we have a readiness probe before serving HTTP to avoid marking ready too soon
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top