Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for LoadBucketMetadata (1.71 sec)

  1. cmd/bucket-metadata-sys.go

    	if isMinioMetaBucketName(meta.Name) {
    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    	sys.Set(meta.Name, meta)
    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  2. cmd/notification.go

    	}
    	locksResp = append(locksResp, &PeerLocks{
    		Addr:  getHostName(r),
    		Locks: globalLockServer.DupLockMap(),
    	})
    	return locksResp
    }
    
    // LoadBucketMetadata - calls LoadBucketMetadata call on all peers
    func (sys *NotificationSys) LoadBucketMetadata(ctx context.Context, bucketName string) {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    					})
    					writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    					return
    				}
    
    				// Load updated bucket metadata into memory.
    				globalNotificationSys.LoadBucketMetadata(GlobalContext, bucket)
    
    				// Make sure to add Location information here only for bucket
    				w.Header().Set(xhttp.Location, pathJoin(SlashSeparator, bucket))
    
    				writeSuccessResponseHeadersOnly(w)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/object-api-listobjects_test.go

    		err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{
    			VersioningEnabled: true,
    		})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err)
    		}
    		meta, err := loadBucketMetadata(context.Background(), obj, bucket)
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  5. cmd/site-replication.go

    		if !ok1 && !ok2 {
    			return wrapSRErr(c.annotateErr(makeBucketWithVersion, err))
    		}
    	} else {
    		// Load updated bucket metadata into memory as new
    		// bucket was created.
    		globalNotificationSys.LoadBucketMetadata(GlobalContext, bucket)
    	}
    
    	meta, err := globalBucketMetadataSys.Get(bucket)
    	if err != nil {
    		return wrapSRErr(c.annotateErr(makeBucketWithVersion, err))
    	}
    
    	meta.SetCreatedAt(opts.CreatedAt)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top