Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 594 for if (0.12 sec)

  1. internal/bucket/lifecycle/rule.go

    func (r Rule) Validate() error {
    	if err := r.validateID(); err != nil {
    		return err
    	}
    	if err := r.validateStatus(); err != nil {
    		return err
    	}
    	if err := r.validateExpiration(); err != nil {
    		return err
    	}
    	if err := r.validateNoncurrentExpiration(); err != nil {
    		return err
    	}
    	if err := r.validatePrefixAndFilter(); err != nil {
    		return err
    	}
    	if err := r.validateTransition(); err != nil {
    		return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  2. cmd/tier-handlers.go

    	if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	err = globalTierConfigMgr.Save(ctx, objAPI)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  3. internal/disk/stat_linux.go

    				}
    			}
    			if devName != "" {
    				info.Name = devName
    				qst, err := bfs.SysBlockDeviceQueueStats(devName)
    				if err != nil { // Mostly not found error
    					// Check if there is a parent device:
    					//   e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the
    					//        real device name (nvme0n1) to get its sysfs information
    					parentDevPath, e := os.Readlink("/sys/class/block/" + devName)
    					if e == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  4. docs/debugging/reorder-disks/main.go

    	if err != nil {
    		return nil, err
    	}
    	exp := argP.Expand()
    
    	if node == "" {
    		for index, e := range exp {
    			result = append(result, localDisk{index: index, path: strings.Join(e, "")})
    		}
    	} else {
    		for index, e := range exp {
    			u, err := url.Parse(strings.Join(e, ""))
    			if err != nil {
    				return nil, err
    			}
    			if strings.Contains(u.Host, node) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  5. cmd/untar.go

    					poolBuf128k.Put(b)
    				}()
    				if err := putObject(&rc, fi, name); err != nil {
    					if o.ignoreErrs {
    						s3LogIf(ctx, err)
    						return
    					}
    					asyncErrMu.Lock()
    					if asyncErr == nil {
    						asyncErr = err
    					}
    					asyncErrMu.Unlock()
    				}
    			}(name, header.FileInfo(), b)
    			continue
    		}
    
    		// If zero or earlier modtime, set to current.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    		ev, ok := s2.MinioEnv[k]
    		if !ok {
    			missing = append(missing, k)
    		} else if v != ev {
    			mismatching = append(mismatching, k)
    		}
    	}
    	var extra []string
    	for k := range s2.MinioEnv {
    		_, ok := s1.MinioEnv[k]
    		if !ok {
    			extra = append(extra, k)
    		}
    	}
    	msg := "Expected same MINIO_ environment variables and values across all servers: "
    	if len(missing) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  7. internal/s3select/sql/jsonpath.go

    		for _, a := range arr {
    			rval, flatten, err := jsonpathEval(p[1:], a)
    			if err != nil {
    				return nil, false, err
    			}
    
    			if flatten {
    				// Flatten if array.
    				if arr, ok := rval.([]interface{}); ok {
    					result = append(result, arr...)
    					continue
    				}
    			}
    			result = append(result, rval)
    		}
    		return result, true, nil
    	}
    	panic("cannot reach here")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  8. internal/config/dns/operator_dns.go

    	defer cancel()
    	e, err := c.endpoint(bucket, false)
    	if err != nil {
    		return newError(bucket, err)
    	}
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, e, nil)
    	if err != nil {
    		return newError(bucket, err)
    	}
    	if err = c.addAuthHeader(req); err != nil {
    		return newError(bucket, err)
    	}
    
    	resp, err := c.httpClient.Do(req)
    	if err != nil {
    		if derr := c.Delete(bucket); derr != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  9. cmd/mrf.go

    			return
    		case u, ok := <-m.opCh:
    			if !ok {
    				return
    			}
    
    			// We might land at .metacache, .trash, .multipart
    			// no need to heal them skip, only when bucket
    			// is '.minio.sys'
    			if u.bucket == minioMetaBucket {
    				// No MRF needed for temporary objects
    				if wildcard.Match("buckets/*/.metacache/*", u.object) {
    					continue
    				}
    				if wildcard.Match("tmp/*", u.object) {
    					continue
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  10. helm/minio/templates/_helper_create_svcacct.txt

      #check accessKey_and_secretKey_tmp file
      if [[ ! -f $MINIO_ACCESSKEY_SECRETKEY_TMP ]];then
        echo "credentials file does not exist"
        return 1
      fi
      if [[ $(cat $MINIO_ACCESSKEY_SECRETKEY_TMP|wc -l) -ne 2 ]];then
        echo "credentials file is invalid"
        rm -f $MINIO_ACCESSKEY_SECRETKEY_TMP
        return 1
      fi
      SVCACCT=$(head -1 $MINIO_ACCESSKEY_SECRETKEY_TMP)
      # Create the svcacct if it does not exist
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 23:20:50 GMT 2024
    - 3.4K bytes
    - Viewed (0)
Back to top