Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for bucketsInfo (0.08 sec)

  1. cmd/peer-s3-server.go

    		return BucketInfo{}, err
    	}
    
    	var bucketInfo BucketInfo
    	for i, err := range errs {
    		if err == nil {
    			bucketInfo = bucketsInfo[i]
    			break
    		}
    	}
    
    	return bucketInfo, nil
    }
    
    func deleteBucketLocal(ctx context.Context, bucket string, opts DeleteBucketOptions) error {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    			}) {
    				bucketsInfo[n] = bucketInfo
    				n++
    			}
    		}
    		bucketsInfo = bucketsInfo[:n]
    		// No buckets can be filtered return access denied error.
    		if len(bucketsInfo) == 0 {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	}
    
    	// Generate response.
    	response := generateListBucketsResponse(bucketsInfo)
    	encodedSuccessResponse := encodeResponse(response)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  3. docs/debugging/s3-check-md5/main.go

    		s3Client.TraceOn(os.Stderr)
    	}
    
    	var buckets []string
    	if bucket != "" {
    		buckets = append(buckets, bucket)
    	} else {
    		bucketsInfo, err := s3Client.ListBuckets(context.Background())
    		if err != nil {
    			log.Fatalln(err)
    		}
    		for _, b := range bucketsInfo {
    			buckets = append(buckets, b.Name)
    		}
    	}
    
    	for _, bucket := range buckets {
    		opts := minio.ListObjectsOptions{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. cmd/peer-s3-client.go

    	g := errgroup.WithNErrs(len(sys.peerClients))
    
    	bucketInfos := make([]BucketInfo, len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		client := client
    		g.Go(func() error {
    			if client == nil {
    				return errPeerOffline
    			}
    			bucketInfo, err := client.GetBucketInfo(ctx, bucket, opts)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	bucketDeleted := mss.Get(peerS3BucketDeleted) == "true"
    
    	bucketInfo, err := getBucketInfoLocal(context.Background(), bucket, BucketOptions{
    		Deleted: bucketDeleted,
    	})
    	if err != nil {
    		return info, grid.NewRemoteErr(err)
    	}
    
    	return &VolInfo{
    		Name:    bucketInfo.Name,
    		Created: bucketInfo.Created,
    		Deleted: bucketInfo.Deleted, // needed for site replication
    	}, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  6. cmd/erasure.go

    // nsScanner will start scanning buckets and send updated totals as they are traversed.
    // Updates are sent on a regular basis and the caller *must* consume them.
    func (er erasureObjects) nsScanner(ctx context.Context, buckets []BucketInfo, wantCycle uint32, updates chan<- dataUsageCache, healScanMode madmin.HealScanMode) error {
    	if len(buckets) == 0 {
    		return nil
    	}
    
    	// Collect disks we can use.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  7. cmd/object-api-datatypes.go

    	{"BETWEEN_10_AND_100", 10, 99},
    	{"BETWEEN_100_AND_1000", 100, 999},
    	{"BETWEEN_1000_AND_10000", 1000, 9999},
    	{"GREATER_THAN_10000", 10000, math.MaxInt64},
    }
    
    // BucketInfo - represents bucket metadata.
    type BucketInfo struct {
    	// Name of the bucket.
    	Name string
    
    	// Date and time when the bucket was created.
    	Created time.Time
    	Deleted time.Time
    
    	// Bucket features enabled
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  8. cmd/background-newdisks-heal-ops.go

    	buckets, _ := z.ListBuckets(ctx, BucketOptions{})
    	// Buckets data are dispersed in multiple pools/sets, make
    	// sure to heal all bucket metadata configuration.
    	buckets = append(buckets, BucketInfo{
    		Name: pathJoin(minioMetaBucket, minioConfigPrefix),
    	}, BucketInfo{
    		Name: pathJoin(minioMetaBucket, bucketMetaPrefix),
    	})
    
    	// Heal latest buckets first.
    	sort.Slice(buckets, func(i, j int) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  9. cmd/site-replication.go

    		for _, bucketInfo := range buckets {
    			bucket := bucketInfo.Name
    			bucketExists := bucketInfo.Deleted.IsZero() || (!bucketInfo.Created.IsZero() && bucketInfo.Created.After(bucketInfo.Deleted))
    			bms := madmin.SRBucketInfo{
    				Bucket:    bucket,
    				CreatedAt: bucketInfo.Created.UTC(),
    				DeletedAt: bucketInfo.Deleted.UTC(),
    			}
    			if !bucketExists {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    	// Bucket operations.
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error)
    	ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error)
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
Back to top