Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for decoder (0.3 sec)

  1. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	versions := make([]FileInfoVersions, totalVersions)
    	decoder := msgpNewReader(r.Body)
    	defer readMsgpReaderPoolPut(decoder)
    	for i := 0; i < totalVersions; i++ {
    		dst := &versions[i]
    		if err := dst.DecodeMsg(decoder); err != nil {
    			s.writeErrorResponse(w, err)
    			return
    		}
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  2. cmd/object-handlers_test.go

    		t.Fatalf("%s:  Expected the response status to be `%d`, but instead found `%d`", instanceType, http.StatusOK, rec.Code)
    	}
    
    	// decode the response body.
    	decoder := xml.NewDecoder(rec.Body)
    	multipartResponse := &InitiateMultipartUploadResponse{}
    
    	err = decoder.Decode(multipartResponse)
    	if err != nil {
    		t.Fatalf("Error decoding the recorded response Body")
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions)))
    
    	var buffer bytes.Buffer
    	encoder := msgp.NewWriter(&buffer)
    	for _, version := range versions {
    		version.EncodeMsg(encoder)
    	}
    	storageLogIf(ctx, encoder.Flush())
    
    	errs = make([]error, len(versions))
    
    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    				checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize())
    
    			// Prefer local disks
    			prefer[index] = disk.Hostname() == ""
    		}
    
    		written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer)
    		// Note: we should not be defer'ing the following closeBitrotReaders() call as
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  5. istioctl/pkg/waypoint/waypoint.go

    			kubeClient, err := ctx.CLIClientWithRevision(revision)
    			if err != nil {
    				return fmt.Errorf("failed to create Kubernetes client: %v", err)
    			}
    			ns := ctx.NamespaceOrDefault(ctx.Namespace())
    			// If a user decides to enroll their namespace with a waypoint, verify that they have labeled their namespace as ambient.
    			// If they don't, the user will be warned and be presented with the command to label their namespace as ambient if they
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed May 01 16:16:40 GMT 2024
    - 15.2K bytes
    - Viewed (0)
  6. docs/en/docs/release-notes.md

    * Rename *path operation decorator* parameter `content_type` to `response_class`. PR [#183](https://github.com/tiangolo/fastapi/pull/183).
    
    * Add docs:
        * How to use the `jsonable_encoder` in [JSON compatible encoder](https://fastapi.tiangolo.com/tutorial/encoder/).
        * How to [Return a Response directly](https://fastapi.tiangolo.com/advanced/response-directly/).
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sun Apr 28 00:28:00 GMT 2024
    - 385.5K bytes
    - Viewed (1)
  7. helm-releases/minio-5.2.0.tgz

    template "minio.fullname" . }}-local=http://$(kubectl get secret --namespace {{ .Release.Namespace }} {{ template "minio.secretName" . }} -o jsonpath="{.data.rootUser}" | base64 --decode):$(kubectl get secret --namespace {{ .Release.Namespace }} {{ template "minio.secretName" . }} -o jsonpath="{.data.rootPassword}" | base64 --decode)@localhost:{{ .Values.service.port }} 3. mc ls {{ template "minio.fullname" . }}-local {{- end }} {{- if eq .Values.service.type "LoadBalancer" }} MinIO can be accessed via...
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 10:14:37 GMT 2024
    - 21.7K bytes
    - Viewed (0)
  8. RELEASE.md

            `tf.debugging.is_inf`, `tf.debugging.is_nan`.
        *   New endpoints in `tf.dtypes` namespace: `tf.dtypes.as_string`.
        *   New endpoints in `tf.io` namespace: `tf.io.decode_base64`,
            `tf.io.decode_compressed`, `tf.io.decode_json_example`,
            `tf.io.decode_raw`, `tf.io.encode_base64`, `tf.io.matching_files`,
            `tf.io.parse_tensor`, `tf.io.read_file,`tf.io.write_file`.
    Plain Text
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Mon Apr 29 19:17:57 GMT 2024
    - 727.7K bytes
    - Viewed (8)
  9. doc/go_spec.html

    </p>
    
    <p>
    The return value of <code>recover</code> is <code>nil</code> when the
    goroutine is not panicking or <code>recover</code> was not called directly by a deferred function.
    Conversely, if a goroutine is panicking and <code>recover</code> was called directly by a deferred function,
    the return value of <code>recover</code> is guaranteed not to be <code>nil</code>.
    HTML
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Apr 26 00:39:16 GMT 2024
    - 279.6K bytes
    - Viewed (0)
  10. cmd/bucket-handlers.go

    				dec := json.NewDecoder(part)
    
    				// while the array contains values
    				for dec.More() {
    					var m minio.PutObjectFanOutEntry
    					if err := dec.Decode(&m); err != nil {
    						part.Close()
    						apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest)
    						apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, multipart.ErrMessageTooLarge)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
Back to top