Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 238 for decoder (0.25 sec)

  1. internal/s3select/json/args.go

    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.7K bytes
    - Viewed (0)
  2. internal/bucket/object/lock/lock.go

    const (
    	// This tested by using `mc lock` command
    	maximumRetentionDays  = 36500
    	maximumRetentionYears = 100
    )
    
    // UnmarshalXML - decodes XML data.
    func (dr *DefaultRetention) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type defaultRetention DefaultRetention
    	retention := defaultRetention{}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 17.1K bytes
    - Viewed (0)
  3. 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 6.6K bytes
    - Viewed (1)
  4. 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
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 24 03:58:53 GMT 2022
    - 3K bytes
    - Viewed (0)
  5. internal/s3select/simdj/reader.go

    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    		decoded:    make(chan simdjson.Object, 1000),
    		input:      make(chan simdjson.Stream, 2),
    		exitReader: make(chan struct{}),
    	}
    	r.onReaderExit = func() {
    		close(r.decoded)
    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    			// Otherwise, we risk the decoder hanging.
    		}
    		r.readerWg.Done()
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  6. internal/s3select/csv/args.go

    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	args.FileHeaderInfo = none
    	args.RecordDelimiter = defaultRecordDelimiter
    	args.FieldDelimiter = defaultFieldDelimiter
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 5.4K bytes
    - Viewed (0)
  7. internal/s3select/parquet/args.go

    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.4K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Dec 14 17:41:44 GMT 2021
    - 5.3K bytes
    - Viewed (1)
  9. docs/sts/README.md

    > - [**AD/LDAP**](https://github.com/minio/minio/blob/master/docs/sts/ldap.md)
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 7.8K bytes
    - Viewed (1)
  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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jan 10 17:07:49 GMT 2022
    - 5.1K bytes
    - Viewed (0)
Back to top