Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 589 for Decoder (0.06 sec)

  1. internal/s3select/jstream/decoder.go

    func (d *Decoder) Pos() int { return int(d.pos) }
    
    // Err returns the most recent decoder error if any, or nil
    func (d *Decoder) Err() error { return d.err }
    
    // MaxDepth will set the maximum recursion depth.
    // If the maximum depth is exceeded, ErrMaxDepth is returned.
    // Less than or 0 means no limit (default).
    func (d *Decoder) MaxDepth(n int) *Decoder {
    	d.maxDepth = n
    	return d
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. internal/event/config.go

    func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if filter.isEmpty() {
    		return nil
    	}
    	type filterRuleWrapper FilterRule
    	return e.EncodeElement(filterRuleWrapper(filter), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  3. internal/store/queuestore.go

    		return
    	}
    
    	var decoder *jsoniter.Decoder
    	if key.Compress {
    		decodedBytes, err := s2.Decode(nil, raw)
    		if err != nil {
    			return nil, err
    		}
    		decoder = jsoniter.ConfigCompatibleWithStandardLibrary.NewDecoder(bytes.NewReader(decodedBytes))
    	} else {
    		decoder = jsoniter.ConfigCompatibleWithStandardLibrary.NewDecoder(bytes.NewReader(raw))
    	}
    
    	for decoder.More() {
    		var item I
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. internal/s3select/jstream/decoder_test.go

    		body    = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]`
    	)
    
    	decoder := NewDecoder(mkReader(body), 1)
    
    	for mv = range decoder.Stream() {
    		counter++
    		t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value)
    	}
    
    	if err := decoder.Err(); err != nil {
    		t.Fatalf("decoder error: %s", err)
    	}
    }
    
    func TestDecoderNested(t *testing.T) {
    	var (
    		counter int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/noncurrentversion.go

    func (n NoncurrentVersionExpiration) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if n.IsNull() {
    		return nil
    	}
    	type noncurrentVersionExpirationWrapper NoncurrentVersionExpiration
    	return e.EncodeElement(noncurrentVersionExpirationWrapper(n), start)
    }
    
    // UnmarshalXML decodes NoncurrentVersionExpiration
    func (n *NoncurrentVersionExpiration) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  6. schema/serializer.go

    		case []byte:
    			bytesValue = v
    		default:
    			return fmt.Errorf("failed to unmarshal gob value: %#v", dbValue)
    		}
    		if len(bytesValue) > 0 {
    			decoder := gob.NewDecoder(bytes.NewBuffer(bytesValue))
    			err = decoder.Decode(fieldValue.Interface())
    		}
    	}
    	field.ReflectValueOf(ctx, dst).Set(fieldValue.Elem())
    	return
    }
    
    // Value implements serializer interface
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/expiration.go

    // MarshalXML encodes delete marker boolean into an XML form.
    func (b Boolean) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !b.set {
    		return nil
    	}
    	return e.EncodeElement(b.val, startElement)
    }
    
    // UnmarshalXML decodes delete marker boolean from the XML form.
    func (b *Boolean) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    	var exp bool
    	err := d.DecodeElement(&exp, &startElement)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/prefix.go

    }
    
    // UnmarshalXML - decodes XML data.
    func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var s string
    	if err = d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    	*p = Prefix{string: s, set: true}
    	return nil
    }
    
    // MarshalXML - decodes XML data.
    func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !p.set {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 14:45:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  9. internal/s3select/json/reader.go

    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.valueCh
    	if !ok {
    		if err := r.decoder.Err(); err != nil {
    			return nil, errJSONParsingError(err)
    		}
    		return nil, io.EOF
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/transition.go

    func (t Transition) MarshalXML(enc *xml.Encoder, start xml.StartElement) error {
    	if !t.set {
    		return nil
    	}
    	type transitionWrapper Transition
    	return enc.EncodeElement(transitionWrapper(t), start)
    }
    
    // UnmarshalXML decodes transition field from the XML form.
    func (t *Transition) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    	type transitionWrapper Transition
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
Back to top