- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 451 for Decoder (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)