- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 69 for decode (0.31 sec)
-
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) -
docs/select/README.md
}, 'CompressionType': 'GZIP', }, OutputSerialization={'CSV': {}}, ) for event in r['Payload']: if 'Records' in event: records = event['Records']['Payload'].decode('utf-8') print(records) elif 'Stats' in event: statsDetails = event['Stats']['Details'] print("Stats details bytesScanned: ") print(statsDetails['BytesScanned'])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 6.5K bytes - Viewed (0) -
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) -
docs/lambda/README.md
request_token = object_context["outputToken"] # Get the original S3 object using the presigned URL r = requests.get(s3_url) original_object = r.content.decode('utf-8') # Transform all text in the original object to uppercase # You can replace it with your custom code based on your use case transformed_object = original_object.upper() # Write object back to S3 Object Lambda # response sends the transformed data
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Apr 04 19:15:28 UTC 2023 - 7.6K bytes - Viewed (0) -
docs/sts/README.md
> - [**AD/LDAP**](https://github.com/minio/minio/blob/master/docs/sts/ldap.md)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 7.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)