Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 197 for unmarshal (0.27 seconds)

  1. cmd/bucket-replication-metrics_gen.go

    	o = append(o, 0xa3, 0x41, 0x76, 0x67)
    	o = msgp.AppendFloat32(o, z.Avg)
    	// string "Max"
    	o = append(o, 0xa3, 0x4d, 0x61, 0x78)
    	o = msgp.AppendInt(o, z.Max)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *ActiveWorkerStat) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33.3K bytes
    - Click Count (0)
  2. cmd/bucket-stats_gen.go

    	// string "FailedCount"
    	o = append(o, 0xab, 0x46, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74)
    	o = msgp.AppendInt64(o, z.FailedCount)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BucketReplicationStat) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 57.3K bytes
    - Click Count (0)
  3. internal/grid/grid_types_msgp_test.go

    	o = msgp.AppendInt(o, z.Num)
    	// string "String"
    	o = append(o, 0xa6, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67)
    	o = msgp.AppendString(o, z.String)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *testRequest) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  4. cmd/fmt-gen.go

    				if deploymentID != "" {
    					newFormat.ID = deploymentID
    				}
    				drive := pool.Endpoints[i*setDriveCount+j]
    				fmtBytes, err := json.Marshal(newFormat)
    				if err != nil {
    					//nolint:gocritic
    					log.Fatalf("failed to marshal format.json for %s: %v", drive.String(), err)
    				}
    				fmtJSON := filepath.Join(drive.Host, drive.Path, minioMetaBucket, "format.json")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  5. cmd/bucket-versioning-handler.go

    			Description:    "A replication configuration is present on this bucket, bucket wide versioning cannot be suspended.",
    			HTTPStatusCode: http.StatusBadRequest,
    		}, r.URL)
    		return
    	}
    
    	configData, err := xml.Marshal(v)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5K bytes
    - Click Count (0)
  6. cmd/erasure-server-pool-decom_gen.go

    	o = append(o, 0xa2, 0x62, 0x64)
    	o = msgp.AppendInt64(o, z.BytesDone)
    	// string "bf"
    	o = append(o, 0xa2, 0x62, 0x66)
    	o = msgp.AppendInt64(o, z.BytesFailed)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *PoolDecommissionInfo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  7. cmd/object-api-datatypes_gen.go

    // MarshalMsg implements msgp.Marshaler
    func (z BackendType) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendInt(o, int(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BackendType) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 int
    		zb0001, bts, err = msgp.ReadIntBytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 71.7K bytes
    - Click Count (0)
  8. internal/bucket/encryption/bucket-sse-config.go

    	// AWSKms is used with SSE-KMS
    	AWSKms Algorithm = "aws:kms"
    )
    
    // Algorithm - represents valid SSE algorithms supported; currently only AES256 is supported
    type Algorithm string
    
    // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm
    func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	switch s {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 4.9K bytes
    - Click Count (0)
  9. cmd/bucket-replication-handlers.go

    	}
    	// Validate the received bucket replication config
    	if err = replicationConfig.Validate(bucket, sameTarget); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	configData, err := xml.Marshal(replicationConfig)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketReplicationConfig, configData); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 23.3K bytes
    - Click Count (0)
  10. cmd/tier-last-day-stats_gen.go

    			}
    		}
    		// string "UpdatedAt"
    		o = append(o, 0xa9, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x41, 0x74)
    		o = msgp.AppendTime(o, zb0008.UpdatedAt)
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *DailyAllTierStats) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0004 uint32
    	zb0004, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
Back to Top