- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 238 for decoder (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)