Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 57 for decode (0.11 sec)

  1. internal/bucket/lifecycle/prefix.go

    	set    bool
    	Unused struct{} // Needed for GOB compatibility
    }
    
    // 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 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Aug 15 14:45:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  2. cmd/streaming-v4-unsigned.go

    	buffer []byte
    	offset int
    	err    error
    	debug  bool
    }
    
    func (cr *s3UnsignedChunkedReader) Close() (err error) {
    	return cr.err
    }
    
    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    	// First, if there is any unread data, copy it to the client
    	// provided buffer.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/noncurrentversion.go

    	}
    	type noncurrentVersionExpirationWrapper NoncurrentVersionExpiration
    	return e.EncodeElement(noncurrentVersionExpirationWrapper(n), start)
    }
    
    // UnmarshalXML decodes NoncurrentVersionExpiration
    func (n *NoncurrentVersionExpiration) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    	// To handle xml with MaxNoncurrentVersions from older MinIO releases.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/tag.go

    	errDuplicatedXMLTag = Errorf("duplicated XML Tag")
    	errUnknownXMLTag    = Errorf("unknown XML Tag")
    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  5. internal/bucket/replication/rule.go

    		return errDeleteReplicationMissing
    	}
    	if d.Status != Disabled && d.Status != Enabled {
    		return errInvalidDeleteReplicationStatus
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type deleteReplication DeleteReplication
    	drep := deleteReplication{}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jan 24 23:22:20 UTC 2022
    - 8.3K 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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/expiration.go

    	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)
    	if err != nil {
    		return err
    	}
    	b.val = exp
    	b.set = true
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. cmd/erasure-encode.go

    	return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers))
    }
    
    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/transition.go

    	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
    	var trw transitionWrapper
    	err := d.DecodeElement(&trw, &startElement)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  10. internal/config/lambda/event/targetid.go

    	return ARN{TargetID: tid, region: region}
    }
    
    // MarshalJSON - encodes to JSON data.
    func (tid TargetID) MarshalJSON() ([]byte, error) {
    	return json.Marshal(tid.String())
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (tid *TargetID) UnmarshalJSON(data []byte) error {
    	var s string
    	if err := json.Unmarshal(data, &s); err != nil {
    		return err
    	}
    
    	targetID, err := parseTargetID(s)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top