Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for existent (0.24 sec)

  1. cmd/object_api_suite_test.go

    func TestNonExistentBucketOperations(t *testing.T) {
    	ExecObjectLayerTest(t, testNonExistentBucketOperations)
    }
    
    // Tests validate that bucket operation on non-existent bucket fails.
    func testNonExistentBucketOperations(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	var opts ObjectOptions
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    		return
    	}
    	opts := ObjectOptions{}
    	if err := abortMultipartUpload(ctx, bucket, object, uploadID, opts); err != nil {
    		switch err.(type) {
    		case InvalidUploadID:
    			// Do not have return an error for non-existent upload-id
    		default:
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	writeSuccessNoContent(w)
    }
    
    // ListObjectPartsHandler - List object parts
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    				VersionID:  objInfo.VersionID,
    			},
    		}
    
    	}
    	names = append(names, ObjectToDelete{
    		ObjectV: ObjectV{
    			ObjectName: "dir/obj1",
    			VersionID:  mustGetUUID(), // add a non-existent UUID.
    		},
    	})
    
    	_, delErrs := obj.DeleteObjects(ctx, bucketName, names, ObjectOptions{
    		Versioned: true,
    	})
    	for i := range delErrs {
    		if delErrs[i] != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  4. cmd/bucket-policy-handlers_test.go

    			expectedRespStatus: http.StatusBadRequest,
    		},
    		// Test case - 8.
    		// non-existent bucket is used.
    		// writing BucketPolicy should fail.
    		// should result in 404 StatusNotFound
    		{
    			bucketName:         "non-existent-bucket",
    			bucketPolicyReader: bytes.NewReader([]byte(fmt.Sprintf(bucketPolicyTemplate, "non-existent-bucket", "non-existent-bucket"))),
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K bytes
    - Viewed (0)
  5. internal/config/identity/openid/openid.go

    		if err = c.PopulatePublicKey(arnKey); err != nil {
    			return c, err
    		}
    	}
    
    	c.Enabled = true
    
    	return c, nil
    }
    
    // ErrProviderConfigNotFound - represents a non-existing provider error.
    var ErrProviderConfigNotFound = errors.New("provider configuration not found")
    
    // GetConfigInfo - returns configuration and related info for the given IDP
    // provider.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  6. cmd/bucket-targets.go

    		ARN:                 tcfg.Arn,
    		ResetID:             tcfg.ResetID,
    		Endpoint:            tcfg.Endpoint,
    		Secure:              tcfg.Secure,
    	}
    	return tc, nil
    }
    
    // getRemoteARN gets existing ARN for an endpoint or generates a new one.
    func (sys *BucketTargetSys) getRemoteARN(bucket string, target *madmin.BucketTarget, deplID string) (arn string, exists bool) {
    	if target == nil {
    		return
    	}
    	sys.RLock()
    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)
  7. cmd/update.go

    	// binary's ModTime as release time:
    	return getModTime(os.Args[0])
    }
    
    // IsDocker - returns if the environment minio is running in docker or
    // not. The check is a simple file existence check.
    //
    // https://github.com/moby/moby/blob/master/daemon/initlayer/setup_unix.go
    // https://github.com/containers/podman/blob/master/libpod/runtime.go
    //
    //	"/.dockerenv":        "file",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  8. internal/s3select/sql/value.go

    // the type may not be determined yet. In these cases, a byte-slice is
    // used.
    type Value struct {
    	value interface{}
    }
    
    // Missing is used to indicate a non-existing value.
    type Missing struct{}
    
    // MarshalJSON provides json marshaling of values.
    func (v Value) MarshalJSON() ([]byte, error) {
    	if b, ok := v.ToBytes(); ok {
    		return b, nil
    	}
    	return json.Marshal(v.value)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    }
    
    // GetMetacacheListing - get a new or existing metacache.
    func (client *peerRESTClient) GetMetacacheListing(ctx context.Context, o listPathOptions) (*metacache, error) {
    	if client == nil {
    		resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(o)
    		return &resp, nil
    	}
    	return getMetacacheListingRPC.Call(ctx, client.gridConn(), &o)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  10. cmd/admin-heal-ops.go

    	defer ahs.Unlock()
    
    	// Check if new heal sequence to be started overlaps with any
    	// existing, running sequence
    	hpath := pathJoin(h.bucket, h.object)
    	for k, hSeq := range ahs.healSeqMap {
    		if !hSeq.hasEnded() && (HasPrefix(k, hpath) || HasPrefix(hpath, k)) {
    			errMsg = "The provided heal sequence path overlaps with an existing " +
    				fmt.Sprintf("heal path: %s", k)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
Back to top