Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 277 for bucket22 (0.1 sec)

  1. cmd/object_api_suite_test.go

    	}
    	if len(buckets) != 2 {
    		t.Errorf("%s: Expected number of bucket to be `%d`, but instead found `%d`", instanceType, 2, len(buckets))
    	}
    
    	if buckets[0].Name != "bucket1" {
    		t.Errorf("%s: Expected bucket name to be `%s`, but instead found `%s`", instanceType, "bucket1", buckets[0].Name)
    	}
    	if buckets[1].Name != "bucket2" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  2. cmd/bucket-metadata-sys.go

    	return len(sys.metadataMap)
    }
    
    // Remove bucket metadata from memory.
    func (sys *BucketMetadataSys) Remove(buckets ...string) {
    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. cmd/admin-bucket-handlers.go

    				if err != nil {
    					rpt.SetStatus(bucket, fileName, err)
    					continue
    				}
    				v, _ := globalBucketMetadataSys.Get(bucket)
    				bucketMap[bucket] = &v
    			}
    
    			bucketMap[bucket].ObjectLockConfigXML = configData
    			bucketMap[bucket].ObjectLockConfigUpdatedAt = updatedAt
    			rpt.SetStatus(bucket, fileName, nil)
    		}
    	}
    
    	// import versioning metadata
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    }
    
    // RemoveTarget - removes a remote bucket target for this source bucket.
    func (sys *BucketTargetSys) RemoveTarget(ctx context.Context, bucket, arnStr string) error {
    	if arnStr == "" {
    		return BucketRemoteArnInvalid{Bucket: bucket}
    	}
    
    	arn, err := madmin.ParseARN(arnStr)
    	if err != nil {
    		return BucketRemoteArnInvalid{Bucket: bucket}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/bucket-stats.go

    		idx := (l.LastMin + 1) % 60
    		l.Totals[idx] = AccElem{}
    		l.LastMin++
    	}
    }
    
    // BucketStatsMap captures bucket statistics for all buckets
    type BucketStatsMap struct {
    	Stats     map[string]BucketStats
    	Timestamp time.Time
    }
    
    // BucketStats bucket statistics
    type BucketStats struct {
    	Uptime           int64                  `json:"uptime"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. cmd/bucket-metadata.go

    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	bucketsse "github.com/minio/minio/internal/bucket/encryption"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	objectlock "github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/event"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. cmd/erasure.go

    		Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)),
    	}
    
    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. cmd/bucket-handlers_test.go

    		6: {
    			bucket:             bucketName,
    			objects:            anonRequestWithPartialPublicAccess,
    			accessKey:          "",
    			secretKey:          "",
    			expectedContent:    encodedAnonResponseWithPartialPublicAccess,
    			expectedRespStatus: http.StatusOK,
    		},
    		// Test case - 7.
    		// Bucket does not exist.
    		7: {
    			bucket:             "unknown-bucket-name",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    			s3LogIf(ctx, err)
    			return opts, InvalidVersionID{
    				Bucket:    bucket,
    				Object:    object,
    				VersionID: vid,
    			}
    		}
    		if !versioned && !versionSuspended {
    			return opts, InvalidArgument{
    				Bucket: bucket,
    				Object: object,
    				Err:    fmt.Errorf("version-id specified %s but versioning is not enabled on %s", opts.VersionID, bucket),
    			}
    		}
    	}
    	return ObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  10. cmd/bucket-replication-stats.go

    	return r.calculateBucketReplicationStats(bucket, bucketStats)
    }
    
    func (r *ReplicationStats) incQ(bucket string, sz int64, isDeleteRepl bool, opType replication.Type) {
    	r.qCache.Lock()
    	defer r.qCache.Unlock()
    	v, ok := r.qCache.bucketStats[bucket]
    	if !ok {
    		v = newInQueueStats(r.registry, bucket)
    	}
    	atomic.AddInt64(&v.nowBytes, sz)
    	atomic.AddInt64(&v.nowCount, 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top