Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for bucketsInfo (0.32 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(globalLocalDrives)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K 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)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K 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{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Feb 17 01:15:57 GMT 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 {
    		idx := idx
    		client := client
    		g.Go(func() error {
    			if client == nil {
    				return errPeerOffline
    			}
    			bucketInfo, err := client.GetBucketInfo(ctx, bucket, opts)
    			if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  5. cmd/bucket-metadata-sys.go

    		}
    		return nil, time.Time{}, err
    	}
    
    	if meta.replicationConfig == nil {
    		return nil, time.Time{}, BucketReplicationConfigNotFound{Bucket: bucket}
    	}
    	if reloaded {
    		globalBucketTargetSys.set(BucketInfo{
    			Name: bucket,
    		}, meta)
    	}
    	return meta.replicationConfig, meta.ReplicationConfigUpdatedAt, nil
    }
    
    // GetBucketTargetsConfig returns configured bucket targets for this bucket
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    	"github.com/minio/pkg/v2/logger/message/log"
    )
    
    // To abstract a node over network.
    type peerRESTServer struct{}
    
    var (
    	// Types & Wrappers
    	aoBucketInfo           = grid.NewArrayOf[*BucketInfo](func() *BucketInfo { return &BucketInfo{} })
    	aoMetricsGroup         = grid.NewArrayOf[*MetricV2](func() *MetricV2 { return &MetricV2{} })
    	madminBgHealState      = grid.NewJSONPool[madmin.BgHealState]()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    	bucketInfo, err = z.s3Peer.GetBucketInfo(ctx, bucket, opts)
    	if err != nil {
    		return bucketInfo, toObjectErr(err, bucket)
    	}
    
    	meta, err := globalBucketMetadataSys.Get(bucket)
    	if err == nil {
    		bucketInfo.Created = meta.Created
    		bucketInfo.Versioning = meta.Versioning()
    		bucketInfo.ObjectLocking = meta.ObjectLocking()
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
  9. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  10. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top