Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Tres (0.17 sec)

  1. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		}
    		pReader := NewPutObjReader(hashReader)
    		_, err = er.PutObject(ctx, bucket, object, pReader, ropts)
    		return setRestoreHeaderFn(oi, toObjectErr(err, bucket, object))
    	}
    
    	res, err := er.NewMultipartUpload(ctx, bucket, object, ropts)
    	if err != nil {
    		return setRestoreHeaderFn(oi, err)
    	}
    
    	var uploadedParts []CompletePart
    	var rs *HTTPRangeSpec
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/sts-handlers_test.go

    			{
    				AccessKey:  "u4ccRswj62HV3Ifwima7",
    				Expiration: &epochTime,
    			},
    		},
    	}
    
    	if !reflect.DeepEqual(expectedAccKeys, res) {
    		c.Fatalf("access keys mismatch: expected: %v, got: %v", expectedAccKeys, res)
    	}
    
    	accKeyInfo, err := s.adm.InfoServiceAccount(ctx, "u4ccRswj62HV3Ifwima7")
    	if err != nil {
    		c.Fatalf("Unable to get service account info: %v", err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  4. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  5. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  6. 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:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K 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))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  8. 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
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    					}
    				}
    
    			}
    		})
    	}
    }
    
    func objInfoNames(o []ObjectInfo) []string {
    	res := make([]string, len(o))
    	for i := range o {
    		res[i] = o[i].Name
    	}
    	return res
    }
    
    func TestDeleteObjectVersionMarker(t *testing.T) {
    	ExecObjectLayerTest(t, testDeleteObjectVersion)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    	}
    	var uploadedParts []CompletePart
    	res, err := api.NewMultipartUpload(context.Background(), tgtBucket, tgtObject, opts)
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    			for attempts <= 3 {
    				aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{})
    				if aerr == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top