Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 197 for unmarshal (0.12 seconds)

  1. cmd/bucket-replication-utils_gen.go

    	o = append(o, 0xa2, 0x69, 0x64)
    	o = msgp.AppendInt(o, z.ID)
    	// string "lu"
    	o = append(o, 0xa2, 0x6c, 0x75)
    	o = msgp.AppendTime(o, z.LastUpdate)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BucketReplicationResyncStatus) 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
    - 59.3K bytes
    - Click Count (0)
  2. cmd/local-locker_gen.go

    			o, err = zb0007[zb0008].MarshalMsg(o)
    			if err != nil {
    				err = msgp.WrapError(err, zb0006, zb0008)
    				return
    			}
    		}
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *localLockMap) 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
    - 16.6K bytes
    - Click Count (0)
  3. cmd/storage-datatypes_gen.go

    func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 0
    	_ = z
    	o = append(o, 0x80)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BaseOptions) 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
    - 151.7K bytes
    - Click Count (0)
  4. cmd/bucket-notification-handlers.go

    				// never reach a stage where we will have stale
    				// notification configs.
    			}
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(config)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseXML(w, configData)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  5. cmd/bucket-encryption-handlers.go

    				writeErrorResponse(ctx, w, toAPIError(ctx, errKMSKeyNotFound), r.URL)
    				return
    			}
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(encConfig)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Store the bucket encryption configuration in the object layer
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  6. cmd/batch-rotate_gen.go

    	o = msgp.AppendString(o, z.Key)
    	// string "Context"
    	o = append(o, 0xa7, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74)
    	o = msgp.AppendString(o, z.Context)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobKeyRotateEncryption) 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
    - 27.1K bytes
    - Click Count (0)
  7. internal/bucket/versioning/versioning_test.go

    func TestMarshalXML(t *testing.T) {
    	// Validates if Versioning with no excluded prefixes omits
    	// ExcludedPrefixes tags
    	v := Versioning{
    		Status: Enabled,
    	}
    	buf, err := xml.Marshal(v)
    	if err != nil {
    		t.Fatalf("Failed to marshal %v: %v", v, err)
    	}
    
    	str := string(buf)
    	if strings.Contains(str, "ExcludedPrefixes") {
    		t.Fatalf("XML shouldn't contain ExcludedPrefixes tag - %s", str)
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun May 08 05:06:44 GMT 2022
    - 8.8K bytes
    - Click Count (0)
  8. cmd/xl-storage-format-v1_gen.go

    func (z BitrotAlgorithm) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint(o, uint(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BitrotAlgorithm) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint
    		zb0001, bts, err = msgp.ReadUintBytes(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
    - 41.2K bytes
    - Click Count (0)
  9. cmd/storage-rest-common_gen.go

    		o = msgp.AppendNil(o)
    	} else {
    		o, err = z.Cache.MarshalMsg(o)
    		if err != nil {
    			err = msgp.WrapError(err, "Cache")
    			return
    		}
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *nsScannerOptions) 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
    - 7.9K bytes
    - Click Count (0)
  10. cmd/bucket-policy-handlers.go

    		return
    	}
    
    	// Version in policy must not be empty
    	if bucketPolicy.Version == "" {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPolicyInvalidVersion), r.URL)
    		return
    	}
    
    	configData, err := json.Marshal(bucketPolicy)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketPolicyConfig, configData)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.1K bytes
    - Click Count (0)
Back to Top