Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 143 for unmarshalV1 (0.62 seconds)

  1. cmd/batch-job-common-types_gen.go

    	o = msgp.AppendString(o, z.Key)
    	// string "Value"
    	o = append(o, 0xa5, 0x56, 0x61, 0x6c, 0x75, 0x65)
    	o = msgp.AppendString(o, z.Value)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobKV) 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  2. cmd/xl-storage-format-v2.go

    	}
    	return decodeVersions(buf, versions, func(i int, hdr, meta []byte) error {
    		ver := &x.versions[i]
    		_, err = ver.header.unmarshalV(headerV, hdr)
    		if err != nil {
    			return err
    		}
    		ver.meta = meta
    
    		// Fix inconsistent compression index due to https://github.com/minio/minio/pull/20575
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  3. internal/config/identity/openid/jwks_test.go

    	var jk JWKS
    	if err := json.Unmarshal([]byte(jsonkey), &jk); err != nil {
    		t.Fatal("Unmarshal: ", err)
    	} else if len(jk.Keys) != 3 {
    		t.Fatalf("Expected 3 keys, got %d", len(jk.Keys))
    	}
    
    	var kids []string
    	for ii, jks := range jk.Keys {
    		_, err := jks.DecodePublicKey()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 9.8K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool-rebalance_gen.go

    func (z rebalSaveOpts) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint8(o, uint8(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *rebalSaveOpts) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    		zb0001, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  5. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33.3K bytes
    - Click Count (0)
  6. internal/grid/handlers.go

    	return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil
    }
    
    // RoundTripper provides an interface for type roundtrip serialization.
    type RoundTripper interface {
    	msgp.Unmarshaler
    	msgp.Marshaler
    	msgp.Sizer
    
    	comparable
    }
    
    // SingleHandler is a type safe handler for single roundtrip requests.
    type SingleHandler[Req, Resp RoundTripper] struct {
    	id            HandlerID
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  7. schema/serializer.go

    		case []byte:
    			bytes = v
    		case string:
    			bytes = []byte(v)
    		default:
    			bytes, err = json.Marshal(v)
    			if err != nil {
    				return err
    			}
    		}
    
    		if len(bytes) > 0 {
    			err = json.Unmarshal(bytes, fieldValue.Interface())
    		}
    	}
    
    	field.ReflectValueOf(ctx, dst).Set(fieldValue.Elem())
    	return
    }
    
    // Value implements serializer interface
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun Oct 26 12:29:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  8. internal/bucket/bandwidth/monitor_gen.go

    func (z BucketBandwidthReport) 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 *BucketBandwidthReport) 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  9. internal/bucket/lifecycle/expiration_test.go

    			expectedErr: errLifecycleDateNotMidnight,
    		},
    	}
    
    	for i, tc := range testCases {
    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var expiration Expiration
    			err := xml.Unmarshal([]byte(tc.inputXML), &expiration)
    			if err != tc.expectedErr {
    				t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err)
    			}
    		})
    	}
    
    	validationTestCases := []struct {
    		inputXML    string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  10. internal/bucket/lifecycle/transition.go

    	errTransitionDateNotMidnight = Errorf("'Date' must be at midnight GMT")
    )
    
    // TransitionDate is a embedded type containing time.Time to unmarshal
    // Date in Transition
    type TransitionDate struct {
    	time.Time
    }
    
    // UnmarshalXML parses date from Transition and validates date format
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top