Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 66 for decode (0.1 sec)

  1. internal/kms/conn.go

    	}
    	return json.Marshal(JSON{
    		KeyID:      d.KeyID,
    		Version:    uint32(d.Version),
    		Ciphertext: d.Ciphertext,
    	})
    }
    
    // UnmarshalText tries to decode text as JSON representation
    // of a DEK and sets DEK's key ID and ciphertext to the
    // decoded values.
    //
    // It sets DEK's plaintext to nil.
    func (d *DEK) UnmarshalText(text []byte) error {
    	type JSON struct {
    		KeyID      string `json:"keyid"`
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  2. internal/s3select/json/preader.go

    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte             // raw input sent to the worker
    	dst   chan []jstream.KVS // result of block decode
    	err   error              // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  3. docs/sts/web-identity.go

    	}
    	defer resp.Body.Close()
    	if resp.StatusCode != http.StatusOK {
    		return d, fmt.Errorf("unexpected error returned by %s : status(%s)", ustr, resp.Status)
    	}
    	dec := json.NewDecoder(resp.Body)
    	if err = dec.Decode(&d); err != nil {
    		return d, err
    	}
    	return d, nil
    }
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    	flag.StringVar(&configEndpoint, "config-ep",
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  4. internal/s3select/csv/reader.go

    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte          // raw input sent to the worker
    	dst   chan [][]string // result of block decode
    	err   error           // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. 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)
  6. 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{}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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{}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  10. 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)
Back to top