Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 84 for clusterid (0.09 sec)

  1. istioctl/pkg/writer/pilot/status_test.go

    	proxyID   string
    	clusterID string
    	version   string
    
    	cdsSyncStatus  status.ConfigStatus
    	ldsSyncStatus  status.ConfigStatus
    	rdsSyncStatus  status.ConfigStatus
    	edsSyncStatus  status.ConfigStatus
    	ecdsSyncStatus status.ConfigStatus
    }
    
    func newXdsClientConfig(config clientConfigInput) *status.ClientConfig {
    	meta := model.NodeMetadata{
    		ClusterID:    cluster.ID(config.clusterID),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/pilot/status.go

    			}
    			cds, lds, eds, rds, ecds := getSyncStatus(&clientConfig)
    			cp := multixds.CpInfo(dr)
    			fullStatus = append(fullStatus, &xdsWriterStatus{
    				proxyID:               clientConfig.GetNode().GetId(),
    				clusterID:             meta.ClusterID.String(),
    				istiodID:              cp.ID,
    				istiodVersion:         meta.IstioVersion,
    				clusterStatus:         cds,
    				listenerStatus:        lds,
    				routeStatus:           rds,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 21 22:47:20 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/api.go

    	WorkloadType          string            `json:"workloadType"`
    	CanonicalName         string            `json:"canonicalName"`
    	CanonicalRevision     string            `json:"canonicalRevision"`
    	ClusterID             string            `json:"clusterId"`
    	TrustDomain           string            `json:"trustDomain,omitempty"`
    	Locality              Locality          `json:"locality,omitempty"`
    	Node                  string            `json:"node"`
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 30 17:26:39 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. istioctl/pkg/proxyconfig/clusters.go

    	for istiod, clusters := range statuses {
    		for _, c := range clusters {
    			_, _ = fmt.Fprintf(w, "%s\t%s\t%s\t%s\n", c.ID, c.SecretName, c.SyncStatus, istiod)
    		}
    	}
    	_ = w.Flush()
    	return nil
    }
    
    func parseClusterStatuses(input map[string][]byte) (map[string][]cluster.DebugInfo, error) {
    	statuses := make(map[string][]cluster.DebugInfo, len(input))
    	for istiodKey, bytes := range input {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/pilot/testdata/multiXdsStatusMultiPilot.txt

    NAME       CLUSTER      CDS          LDS         EDS         RDS          ECDS         ISTIOD      VERSION
    proxy1     cluster1     STALE        SYNCED      SYNCED      NOT SENT     SYNCED       istiod1     1.20
    proxy2     cluster2     STALE        SYNCED      STALE       SYNCED       STALE        istiod2     1.19
    proxy3     cluster3     NOT SENT     ERROR       STALE       NOT SENT     NOT SENT     istiod3     1.20
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Mar 06 03:42:52 UTC 2024
    - 522 bytes
    - Viewed (0)
  6. istioctl/pkg/util/configdump/cluster.go

    	for i := range dac {
    		dac[i].Cluster.TypeUrl = v3.ClusterType
    	}
    	sort.Slice(dac, func(i, j int) bool {
    		cluster := &cluster.Cluster{}
    		err = dac[i].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		name := cluster.Name
    		err = dac[j].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		return name < cluster.Name
    	})
    	if stripVersions {
    		for i := range dac {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  7. istioctl/pkg/multicluster/cluster.go

    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/client-go/kubernetes"
    )
    
    // Use UUID of kube-system Namespace as unique identifier for cluster.
    // (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4)
    func clusterUID(client kubernetes.Interface) (types.UID, error) {
    	kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{})
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 02 03:11:58 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/compare/cluster.go

    	}
    	diff := difflib.UnifiedDiff{
    		FromFile: "Istiod Clusters",
    		A:        difflib.SplitLines(istiodBytes.String()),
    		ToFile:   "Envoy Clusters",
    		B:        difflib.SplitLines(envoyBytes.String()),
    		Context:  c.context,
    	}
    	text, err := difflib.GetUnifiedDiffString(diff)
    	if err != nil {
    		return err
    	}
    	if text != "" {
    		fmt.Fprintln(c.w, "Clusters Don't Match")
    		fmt.Fprintln(c.w, text)
    	} else {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. docs/federation/lookup/README.md

    points to the public IP address where each cluster might be accessible, this is unique for each cluster.
    
    NOTE: `mybucket` only exists on one cluster either `cluster1` or `cluster2` this is random and
    is decided by how `domain.com` gets resolved, if there is a round-robin DNS on `domain.com` then
    it is randomized which cluster might provision the bucket.
    
    ### 3. Test your setup
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4K bytes
    - Viewed (0)
  10. cmd/metrics-v3-cluster-config.go

    		"Reduced redundancy storage class parity")
    	configStandardParityMD = NewGaugeMD(configStandardParity,
    		"Standard storage class parity")
    )
    
    // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config
    // such as standard and RRS parity.
    func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	clusterDriveMetrics, err := c.clusterDriveMetrics.Get()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
Back to top