Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for isRemove (0.19 sec)

  1. 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)
  2. 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)
  3. cmd/erasure-metadata.go

    			}
    
    			if !meta.Deleted && meta.Size != 0 {
    				fmt.Fprintf(h, "%v+%v", meta.Erasure.DataBlocks, meta.Erasure.ParityBlocks)
    				fmt.Fprintf(h, "%v", meta.Erasure.Distribution)
    			}
    
    			if meta.IsRemote() {
    				// ILM transition fields
    				fmt.Fprint(h, meta.TransitionStatus)
    				fmt.Fprint(h, meta.TransitionTier)
    				fmt.Fprint(h, meta.TransitionedObjName)
    				fmt.Fprint(h, meta.TransitionVersionID)
    			}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/erasure-server-pool-decom.go

    					continue
    				}
    
    				var failure, ignore bool
    				// gr.Close() is ensured by decommissionObject().
    				for try := 0; try < 3; try++ {
    					if version.IsRemote() {
    						if err := z.DecomTieredObject(ctx, bi.Name, version.Name, version, ObjectOptions{
    							VersionID:   versionID,
    							MTime:       version.ModTime,
    							UserDefined: version.Metadata,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 14:30:43 UTC 2024
    - 41.5K bytes
    - Viewed (1)
  7. pkg/proxy/winkernel/proxier.go

    	if klog.V(logLevel).Enabled() {
    		var epInfo string
    		for _, v := range eps {
    			epInfo = epInfo + fmt.Sprintf("\n  %s={Ready:%v,Serving:%v,Terminating:%v,IsRemote:%v}", v.String(), v.IsReady(), v.IsServing(), v.IsTerminating(), !v.IsLocal())
    		}
    		klog.V(logLevel).InfoS(logMsg, "svcPortName", svcPortName, "endpoints", epInfo)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    				ObjInfo: objInfo,
    			}, err
    		}
    
    		// Zero byte objects don't even need to further initialize pipes etc.
    		return NewGetObjectReaderFromReader(bytes.NewReader(nil), objInfo, opts)
    	}
    
    	if objInfo.IsRemote() {
    		gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts)
    		if err != nil {
    			return nil, err
    		}
    		unlockOnDefer = false
    		return gr.WithCleanupFuncs(nsUnlocker), nil
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    	dstFilePath := pathutil.Join(dstVolumeDir, pathJoin(dstPath, xlStorageFormatFile))
    
    	var srcDataPath string
    	var dstDataPath string
    	var dataDir string
    	if !fi.IsRemote() {
    		dataDir = retainSlash(fi.DataDir)
    	}
    	if dataDir != "" {
    		srcDataPath = retainSlash(pathJoin(srcVolumeDir, srcPath, dataDir))
    		// make sure to always use path.Join here, do not use pathJoin as
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top