Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for bucketsInfo (0.27 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 17 01:15:57 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/bucket-targets.go

    		}
    
    		if !tgts.Empty() {
    			sys.targetsMap[bucket] = tgts.Targets
    		}
    	}
    }
    
    // create minio-go clients for buckets having remote targets
    func (sys *BucketTargetSys) set(bucket BucketInfo, meta BucketMetadata) {
    	cfg := meta.bucketTargetConfig
    	if cfg == nil || cfg.Empty() {
    		return
    	}
    	sys.Lock()
    	defer sys.Unlock()
    	for _, tgt := range cfg.Targets {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  6. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    	if objectAPI == nil {
    		return
    	}
    
    	var (
    		buckets []BucketInfo
    		err     error
    	)
    	if bucket != "" {
    		// Check if bucket exists.
    		if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    			writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		buckets = append(buckets, BucketInfo{Name: bucket})
    	} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  8. cmd/api-response.go

    			u.Path = path.Join(SlashSeparator, object)
    			break
    		}
    	}
    	return u.String()
    }
    
    // generates ListBucketsResponse from array of BucketInfo which can be
    // serialized to match XML and JSON API spec output.
    func generateListBucketsResponse(buckets []BucketInfo) ListBucketsResponse {
    	listbuckets := make([]Bucket, 0, len(buckets))
    	data := ListBucketsResponse{}
    	owner := Owner{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  9. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  10. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
Back to top