Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for setBucket (0.04 sec)

  1. cmd/postpolicyform_test.go

    func (f formValues) Clone() formValues {
    	return formValues{f.Header.Clone()}
    }
    
    // Test Post Policy parsing and checking conditions
    func TestPostPolicyForm(t *testing.T) {
    	pp := minio.NewPostPolicy()
    	pp.SetBucket("testbucket")
    	pp.SetContentType("image/jpeg")
    	pp.SetUserMetadata("uuid", "14365123651274")
    	pp.SetKeyStartsWith("user/user1/filename")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    func (h *healingTracker) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h *healingTracker) getBucket() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Bucket
    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Bucket = bucket
    }
    
    func (h *healingTracker) getObject() string {
    	h.mu.RLock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    	if o.ID != "" && !o.Transient {
    		// Create or ping with handout...
    		rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    		var c *metacache
    		if rpc == nil {
    			resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o)
    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top