Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 82 for objs (2.27 sec)

  1. cmd/data-usage_test.go

    			}
    			if e.Size != int64(w.size) {
    				t.Error("got size", e.Size, "want", w.size)
    			}
    			if e.Objects != uint64(w.objs) {
    				t.Error("got objects", e.Objects, "want", w.objs)
    			}
    			if e.Versions != uint64(w.objs) {
    				t.Error("got versions", e.Versions, "want", w.objs)
    			}
    			if e.ObjSizes != w.oSizes {
    				t.Error("got histogram", e.ObjSizes, "want", w.oSizes)
    			}
    		})
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  2. cmd/erasure-sets_test.go

    		{"Cost Benefit Analysis (2009-2010).pptx", objs[13]},
    		{"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", objs[1]},
    		{"SHØRT", objs[9]},
    		{"There are far too many object names, and far too few bucket names!", objs[13]},
    		{"a/b/c/", objs[1]},
    		{"/a/b/c", objs[4]},
    		{string([]byte{0xff, 0xfe, 0xfd}), objs[13]},
    	}
    
    	// Tests hashing order to be consistent.
    	for i, testCase := range testCases {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/metacache-stream_test.go

    	r := loadMetacacheSample(t)
    	defer r.Close()
    	var readErr error
    	objs := make(chan metaCacheEntry, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readErr = r.readAll(context.Background(), objs)
    		wg.Done()
    	}()
    	want := loadMetacacheSampleNames
    	i := 0
    	for entry := range objs {
    		if entry.name != want[i] {
    			t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		wg.Add(len(z.serverPools))
    		for idx, pool := range z.serverPools {
    			go func(idx int, pool *erasureSets) {
    				defer wg.Done()
    				objs := poolObjIdxMap[idx]
    				if len(objs) > 0 {
    					orgIndexes := origIndexMap[idx]
    					deletedObjects, errs := pool.DeleteObjects(ctx, bucket, objs, opts)
    					mu.Lock()
    					for i, derr := range errs {
    						if derr != nil {
    							derrs[orgIndexes[i]] = derr
    						}
    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)
  5. cmd/object_api_suite_test.go

    		}
    		if result.Objects[2].Name != "obj1" {
    			t.Errorf("%s: Expected the object name to be `%s`, but instead found `%s`", instanceType, "obj1", result.Objects[2].Name)
    		}
    	}
    	// check ordering of results with prefix.
    	{
    		result, err = obj.ListObjects(context.Background(), "bucket", "obj", "", "", 1000)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  6. cmd/erasure-object_test.go

    	}
    
    	bucketName := "bucket"
    	testCases := []testCaseType{
    		{bucketName, "dir/obj1"},
    		{bucketName, "dir/obj2"},
    		{bucketName, "obj3"},
    		{bucketName, "obj_4"},
    	}
    
    	if err = obj.MakeBucket(ctx, bucketName, MakeBucketOptions{}); err != nil {
    		t.Fatal(err)
    	}
    
    	for _, testCase := range testCases {
    		_, err = obj.PutObject(ctx, testCase.bucket, testCase.object,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  7. cmd/data-scanner_test.go

    	close(workers[0])
    	wg.Wait()
    	for _, obj := range expired {
    		switch obj.ObjectV.VersionID {
    		case uuids[2].String(), uuids[3].String(), uuids[4].String():
    		default:
    			t.Errorf("Unexpected versionID being expired: %#v\n", obj)
    		}
    	}
    }
    
    func TestEvalActionFromLifecycle(t *testing.T) {
    	// Tests cover only ExpiredObjectDeleteAllVersions and DelMarkerExpiration actions
    	obj := ObjectInfo{
    		Name:        "foo",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  8. docs/sts/custom-token-identity.go

    	objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{})
    	for obj := range objCh {
    		if obj.Err != nil {
    			log.Fatalf("Listing error: %v", obj.Err)
    		}
    		fmt.Printf("Key: %s\nSize: %d\nLast Modified: %s\n===\n", obj.Key, obj.Size, obj.LastModified)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  9. docs/sts/assume-role.go

    	objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{})
    	for obj := range objCh {
    		if obj.Err != nil {
    			log.Fatalf("Listing error: %v", obj.Err)
    		}
    		fmt.Printf("Key: %s\nSize: %d\nLast Modified: %s\n===\n", obj.Key, obj.Size, obj.LastModified)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 16:09:55 GMT 2024
    - 4K bytes
    - Viewed (1)
  10. cmd/object-api-deleteobject_test.go

    			[]string{"object0"},
    		},
    	}
    
    	for i, testCase := range testCases {
    		err := obj.MakeBucket(context.Background(), testCase.bucketName, MakeBucketOptions{})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err.Error())
    		}
    
    		for _, object := range testCase.objectToUploads {
    			md5Bytes := md5.Sum([]byte(object.content))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
Back to top