Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 68 for delimiter (0.37 sec)

  1. cmd/s3-zip-handlers.go

    			continue
    		}
    		if strings.HasPrefix(objName, prefix) {
    			if count == maxKeys {
    				isTruncated = true
    				break
    			}
    			if delimiter != "" {
    				i := strings.Index(objName[len(prefix):], delimiter)
    				if i >= 0 {
    					commonPrefix := objName[:len(prefix)+i+1]
    					if len(listObjectsInfo.Prefixes) == 0 || commonPrefix != listObjectsInfo.Prefixes[len(listObjectsInfo.Prefixes)-1] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  2. cmd/object-api-input-checks.go

    			Bucket: bucket,
    			Object: prefix,
    		}
    	}
    	return nil
    }
    
    // Checks for all ListMultipartUploads arguments validity.
    func checkListMultipartArgs(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string) error {
    	if err := checkListObjsArgs(ctx, bucket, prefix, keyMarker); err != nil {
    		return err
    	}
    	if uploadIDMarker != "" {
    		if HasSuffix(keyMarker, SlashSeparator) {
    			return InvalidUploadIDKeyCombination{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt

      }
    }
    
    /**
     * Consumes and returns a non-empty token, terminating at special characters in
     * [TOKEN_DELIMITERS]. Returns null if the buffer is empty or prefixed with a delimiter.
     */
    private fun Buffer.readToken(): String? {
      var tokenSize = indexOfElement(TOKEN_DELIMITERS)
      if (tokenSize == -1L) tokenSize = size
    
      return when {
        tokenSize != 0L -> readUtf8(tokenSize)
        else -> null
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

        assertThat(part.headers).isEqualTo(headersOf())
        assertThat(part.body.readUtf8()).isEqualTo("abcd")
    
        assertThat(parts.nextPart()).isNull()
      }
    
      @Test fun `skip whitespace after close delimiter`() {
        val multipart =
          """
          |--simple boundary
          |
          |abcd
          |--simple boundary--
          """.trimMargin()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  5. cmd/warm-backend-gcs.go

    	return gcsToObjectError(err, gcs.Bucket, key)
    }
    
    func (gcs *warmBackendGCS) InUse(ctx context.Context) (bool, error) {
    	it := gcs.client.Bucket(gcs.Bucket).Objects(ctx, &storage.Query{
    		Delimiter: "/",
    		Prefix:    gcs.Prefix,
    		Versions:  false,
    	})
    	pager := iterator.NewPager(it, 1, "")
    	gcsObjects := make([]*storage.ObjectAttrs, 0)
    	_, err := pager.NextPage(&gcsObjects)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  6. cmd/httprange.go

    	}
    
    	// Trim byte range prefix.
    	byteRangeString := strings.TrimPrefix(rangeString, byteRangePrefix)
    
    	// Check if range string contains delimiter '-', else return error. eg. "bytes=8"
    	sepIndex := strings.Index(byteRangeString, "-")
    	if sepIndex == -1 {
    		return nil, fmt.Errorf("'%s' does not have a valid range value", rangeString)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  7. cmd/object_api_suite_test.go

    			t.Errorf("%s: Expected the object name to be `%s`, but instead found `%s`", instanceType, "newPrefix", result.Objects[4].Name)
    		}
    	}
    
    	// check delimited results with delimiter and prefix.
    	{
    		_, err = obj.PutObject(context.Background(), "bucket", "this/is/delimited", mustGetPutObjReader(t, bytes.NewBufferString(uploadContent), int64(len(uploadContent)), "", ""), opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    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)
  8. cmd/object-api-datatypes_gen.go

    		case "Prefix":
    			z.Prefix, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Prefix")
    				return
    			}
    		case "Delimiter":
    			z.Delimiter, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Delimiter")
    				return
    			}
    		case "CommonPrefixes":
    			var zb0003 uint32
    			zb0003, bts, err = msgp.ReadArrayHeaderBytes(bts)
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 69.8K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    			return
    		}
    	}
    
    	if s3Error == ErrAccessDenied {
    		// Set prefix value for "s3:prefix" policy conditionals.
    		r.Header.Set("prefix", "")
    
    		// Set delimiter value for "s3:delimiter" policy conditionals.
    		r.Header.Set("delimiter", SlashSeparator)
    
    		n := 0
    		// Use the following trick to filter in place
    		// https://github.com/golang/go/wiki/SliceTricks#filter-in-place
    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)
  10. cmd/erasure-multipart.go

    func (er erasureObjects) ListMultipartUploads(ctx context.Context, bucket, object, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (result ListMultipartsInfo, err error) {
    	auditObjectErasureSet(ctx, object, &er)
    
    	result.MaxUploads = maxUploads
    	result.KeyMarker = keyMarker
    	result.Prefix = object
    	result.Delimiter = delimiter
    
    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top