Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Res (0.02 sec)

  1. cmd/xl-storage.go

    			if len(fivs.FreeVersions) > 0 {
    				res["free-versions"] = strconv.Itoa(len(fivs.FreeVersions))
    			}
    
    			if sizeS.versions > 0 {
    				res["versions"] = strconv.FormatUint(sizeS.versions, 10)
    			}
    			res["size"] = strconv.FormatInt(sizeS.totalSize, 10)
    			for name, tier := range sizeS.tiers {
    				res["tier-size-"+name] = strconv.FormatUint(tier.TotalSize, 10)
    				res["tier-versions-"+name] = strconv.Itoa(tier.NumVersions)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	res := make([]*MetricV2, 0, len(resourceMetricsGroups))
    	populateAndPublish(resourceMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  3. cmd/object-api-multipart_test.go

    	if err != nil {
    		// failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	res, err := obj.NewMultipartUpload(context.Background(), bucket, "\\", opts)
    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	err = obj.AbortMultipartUpload(context.Background(), bucket, "\\", res.UploadID, opts)
    	if err != nil {
    		switch err.(type) {
    		case InvalidUploadID:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    	cache := store.rlock()
    	defer store.runlock()
    
    	var res []auth.Credentials
    	for _, u := range cache.iamUsersMap {
    		cred := u.Credentials
    		if cred.IsServiceAccount() {
    			res = append(res, cred)
    		}
    	}
    	for _, u := range cache.iamSTSAccountsMap {
    		res = append(res, u.Credentials)
    	}
    
    	return res
    }
    
    // UpdateUserIdentity - updates a user credential.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    				}
    			}
    			xioutil.SafeClose(walkCh)
    		}()
    
    		prevObj := ""
    
    		skipReplicate := false
    		for res := range slowCh {
    			if res.Err != nil {
    				ri.Failed = true
    				batchLogOnceIf(ctx, res.Err, job.ID+"res.Err")
    				continue
    			}
    			result := res.Item
    			if result.Name != prevObj {
    				prevObj = result.Name
    				skipReplicate = result.DeleteMarker && s3Type
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    	// part number.
    	res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    		t.Fatalf("Failed to create a multipart upload - %v", err)
    	}
    
    	var uploadedParts []CompletePart
    	for _, partID := range []int{2, 1} {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. internal/s3select/select_test.go

    				StatusCode:    http.StatusOK,
    				Body:          io.NopCloser(bytes.NewReader(w.response)),
    				ContentLength: int64(len(w.response)),
    			}
    			res, err := minio.NewSelectResults(&resp, "testbucket")
    			if err != nil {
    				t.Error(err)
    				return
    			}
    			got, err := io.ReadAll(res)
    			if err != nil {
    				t.Error(err)
    				return
    			}
    			gotS := strings.TrimSpace(string(got))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  8. tests/query_test.go

    		Nickname string
    		Age      uint
    	}
    	var res result
    	DB.Table("users").Where("name = ?", user.Name).MapColumns(map[string]string{"name": "nickname"}).Scan(&res)
    	if res.Nickname != user.Name {
    		t.Errorf("Expected res.Nickname to be %s, but got %s", user.Name, res.Nickname)
    	}
    	if res.Name != "" {
    		t.Errorf("Expected res.Name to be empty, but got %s", res.Name)
    	}
    	if res.Age != user.Age {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    		}
    		return a.oi.ModTime.After(b.oi.ModTime)
    	})
    
    	for _, res := range results {
    		err := res.err
    		if err == nil {
    			return res.oi, res.zIdx, nil
    		}
    		if !isErrObjectNotFound(err) && !isErrVersionNotFound(err) {
    			// some errors such as MethodNotAllowed for delete marker
    			// should be returned upwards.
    			return res.oi, res.zIdx, err
    		}
    		// When its a delete marker and versionID is empty
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    	// which will look like "outbound|9080||productpage.default.svc.cluster.local"
    	res := fmt.Sprintf(`outbound\|%d\|[^\|]*\|(?P<service>[^\.]+)\.(?P<namespace>[^\.]+)\.svc\.cluster\.local$`, port)
    	re = regexp.MustCompile(res)
    
    	ss := re.FindStringSubmatch(clusterName)
    	if ss != nil {
    		if ss[1] == svc.ObjectMeta.Name && ss[2] == svc.ObjectMeta.Namespace {
    			return true
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top