Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for isRemote (0.28 sec)

  1. pkg/test/framework/components/cluster/cluster.go

    	// IsConfig returns true if this is a config cluster, used as the source of
    	// Istio config for one or more control planes.
    	IsConfig() bool
    
    	// IsRemote returns true if this is a remote cluster, which uses a control plane
    	// residing in another cluster.
    	IsRemote() bool
    
    	// IsExternalControlPlane returns true if this is a cluster containing an instance
    	// of the Istio control plane but with its source of config in another cluster.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. pkg/test/framework/components/cluster/topology.go

    	if _, f := knownClusterNames[c.Name()]; f {
    		return c.Name()
    	}
    	if c.IsPrimary() {
    		if c.IsConfig() {
    			prefix = "primary"
    		} else {
    			prefix = "externalistiod"
    		}
    	} else if c.IsRemote() {
    		if c.IsConfig() {
    			prefix = "config"
    		} else {
    			prefix = "remote"
    		}
    	}
    
    	return fmt.Sprintf("%s-%d", prefix, c.Index)
    }
    
    func (c Topology) IsPrimary() bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    			// Legacy means heal always
    			// always check first.
    			return true, errLegacyXLMeta
    		}
    		if !latestMeta.Equals(meta) {
    			return true, errOutdatedXLMeta
    		}
    		if !meta.Deleted && !meta.IsRemote() {
    			// If xl.meta was read fine but there may be problem with the part.N files.
    			for _, partErr := range partsErrs {
    				if slices.Contains([]int{
    					checkPartFileNotFound,
    					checkPartFileCorrupt,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  4. pkg/test/framework/components/cluster/clusters.go

    	}, exclude(excluded...))
    }
    
    // Remotes returns the subset that are remote clusters.
    func (c Clusters) Remotes(excluded ...Cluster) Clusters {
    	return c.filterClusters(func(cc Cluster) bool {
    		return cc.IsRemote()
    	}, exclude(excluded...))
    }
    
    // MeshClusters returns the subset that are not external control plane clusters.
    func (c Clusters) MeshClusters(excluded ...Cluster) Clusters {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle.go

    }
    
    var errRestoreHDRMalformed = fmt.Errorf("x-amz-restore header malformed")
    
    // IsRemote returns true if this object version's contents are in its remote
    // tier.
    func (fi FileInfo) IsRemote() bool {
    	if fi.TransitionStatus != lifecycle.TransitionComplete {
    		return false
    	}
    	return !isRestoredObjectOnDisk(fi.Metadata)
    }
    
    // IsRemote returns true if this object version's contents are in its remote
    // tier.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common.go

    				dataErrsByPart[p][i] = partErr
    			}
    		}
    	}
    
    	for i, onlineDisk := range onlineDisks {
    		if metaErrs[i] != nil {
    			continue
    		}
    		meta := partsMetadata[i]
    
    		if meta.Deleted || meta.IsRemote() {
    			continue
    		}
    
    		// Always check data, if we got it.
    		if (len(meta.Data) > 0 || meta.Size == 0) && len(meta.Parts) > 0 {
    			checksumInfo := meta.Erasure.GetChecksumInfo(meta.Parts[0].Number)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  7. pkg/test/framework/components/istio/configmap.go

    			if err != nil {
    				return err
    			}
    
    			cfgMap, err := mc.getConfigMap(c, cfgMapName)
    			if err != nil {
    				// Remote clusters typically don't have mesh config, allow it to skip
    				if c.IsRemote() && kerrors.IsNotFound(err) {
    					scopes.Framework.Infof("skipped %s meshconfig patch, as it is a remote", c.Name())
    					return nil
    				}
    				return err
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  8. cmd/storage-datatypes.go

    	// from fi.Metadata when the object was tiered. So, tiered objects
    	// would return true for InlineData() in these versions even though the
    	// object isn't inlined in xl.meta
    	return ok && !fi.IsRemote()
    }
    
    // SetInlineData marks object (version) as inline.
    func (fi *FileInfo) SetInlineData() {
    	if fi.Metadata == nil {
    		fi.Metadata = make(map[string]string, 1)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    			versionsSorter(fivs.Versions).reverse()
    
    			var rebalanced, expired int
    			for _, version := range fivs.Versions {
    				// Skip transitioned objects for now. TBD
    				if version.IsRemote() {
    					continue
    				}
    
    				// Apply lifecycle rules on the objects that are expired.
    				if filterLifecycle(bucket, version.Name, version) {
    					expired++
    					continue
    				}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 03 15:45:54 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  10. pkg/test/framework/components/istio/kube.go

    		var nsLabels map[string]string
    		if i.env.IsMultiNetwork() {
    			nsLabels = map[string]string{label.TopologyNetwork.Name: c.NetworkName()}
    		}
    		var nsAnnotations map[string]string
    		if c.IsRemote() {
    			nsAnnotations = map[string]string{
    				annotation.TopologyControlPlaneClusters.Name: c.Config().Name(),
    				// ^^^ Use config cluster name because external control plane uses config cluster as its cluster ID
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top