Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 66 of 66 for decode (0.14 sec)

  1. internal/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 Jun 01 21:59:40 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader.go

    	input   chan simdjson.Stream
    	decoded chan simdjson.Object
    
    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/filter.go

    				return err
    			}
    		}
    	}
    
    	return e.EncodeToken(xml.EndElement{Name: start.Name})
    }
    
    // UnmarshalXML - decodes XML data.
    func (f *Filter) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	f.set = true
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Feb 27 00:01:20 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. cmd/erasure-coding.go

    	}
    	encoded, err := e.encoder().Split(data)
    	if err != nil {
    		return nil, err
    	}
    	if err = e.encoder().Encode(encoded); err != nil {
    		return nil, err
    	}
    	return encoded, nil
    }
    
    // DecodeDataBlocks decodes the given erasure-coded data.
    // It only decodes the data blocks but does not verify them.
    // It returns an error if the decoding failed.
    func (e *Erasure) DecodeDataBlocks(data [][]byte) error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. internal/bucket/replication/destination.go

    			return err
    		}
    	}
    	return e.EncodeToken(xml.EndElement{Name: start.Name})
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *Destination) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type destination Destination
    	dest := destination{}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. cmd/erasure_test.go

    			t.Errorf("Test %d: test should pass but it failed: %v", i, err)
    		}
    
    		decoded := encoded
    		if !test.shouldFail {
    			if test.reconstructParity {
    				for j := range decoded {
    					if decoded[j] == nil {
    						t.Errorf("Test %d: failed to reconstruct shard %d", i, j)
    					}
    				}
    			} else {
    				for j := range decoded[:test.dataBlocks] {
    					if decoded[j] == nil {
    						t.Errorf("Test %d: failed to reconstruct data shard %d", i, j)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
Back to top