- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 50 for calling (0.29 sec)
-
internal/disk/stat_windows.go
// which is the total amount of space, the total amount of free space, and the total // amount of free space available to the user that is associated with the calling thread. GetDiskFreeSpaceEx = kernel32.NewProc("GetDiskFreeSpaceExW") // GetDiskFreeSpace - https://msdn.microsoft.com/en-us/library/windows/desktop/aa364935(v=vs.85).aspx
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.1K bytes - Viewed (0) -
cmd/api-router.go
// can be disabled via the corresponding `s3HFlag`. // // CAUTION: for requests involving large req/resp bodies ensure to pass the // `traceHdrsS3HFlag`, otherwise both headers and body will be traced, causing // high memory usage! func s3APIMiddleware(f http.HandlerFunc, flags ...s3HFlag) http.HandlerFunc { // Collect all flags with bitwise-OR and assign operator var handlerFlags s3HFlag for _, flag := range flags {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// by the Content-Type header field. ContentEncoding string // Date and time at which the object is no longer able to be cached Expires time.Time // Cache-Control - Specifies caching behavior along the request/reply chain CacheControl string // Specify object storage class StorageClass string ReplicationStatusInternal string ReplicationStatus replication.StatusType
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/test-utils_test.go
globalObjectAPI = objLayer globalObjLayerMutex.Unlock() // When cache is enabled, Put and Get operations are passed // to underlying cache layer to manage object layer operation and disk caching // operation api := objectAPIHandlers{ ObjectAPI: func() ObjectLayer { return globalObjectAPI }, } // Register ListBuckets handler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
internal/http/response-recorder.go
StartTime: time.Now().UTC(), } } // ErrNotImplemented when a functionality is not implemented var ErrNotImplemented = errors.New("not implemented") // ReadFrom implements support for calling internal io.ReaderFrom implementations // returns an error if the underlying ResponseWriter does not implement io.ReaderFrom func (lrw *ResponseRecorder) ReadFrom(r io.Reader) (int64, error) { if lrw.ReaderFrom != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 00:13:19 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
// Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding // Need to set `Accept-Encoding` header to `gzip` when issuing a GetObject call, to be able // to download the object in compressed state. // Calling ReadCompressed with true accomplishes that. object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true) r, err = object.NewRangeReader(ctx, opts.startOffset, opts.length) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/s3select/sql/aggregation.go
// them if they could be an ancestor of an // aggregation. } return nil } // getAggregate() implementation for each AST node follows. This is // called after calling aggregateRow() on each input row, to calculate // the final aggregate result. func (e *FuncExpr) getAggregate() (*Value, error) { switch e.getFunctionName() { case aggFnCount:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/object-handlers_test.go
type Fault int const ( None Fault = iota MissingContentLength TooBigObject TooBigDecodedLength BadSignature BadMD5 MissingUploadID ) // Wrapper for calling HeadObject API handler tests for both Erasure multiple disks and FS single drive setup. func TestAPIHeadObjectHandler(t *testing.T) { ExecObjectLayerAPITest(t, testAPIHeadObjectHandler, []string{"HeadObject"}) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/bucket-stats.go
} // Clone creates a new BucketReplicationStats copy func (brs BucketReplicationStats) Clone() (c BucketReplicationStats) { // This is called only by replicationStats cache and already holds a // read lock before calling Clone() c = brs // We need to copy the map, so we do not reference the one in `brs`. c.Stats = make(map[string]*BucketReplicationStat, len(brs.Stats)) for arn, st := range brs.Stats { // make a copy of `*st`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/etag/etag.go
// 16 bytes of the encrypted ETag which will be a random // value. // - The object is a SSE-S3 encrypted single-part object. // In this case, the caller has to decrypt the ETag first // before calling Format. // S3 clients expect that the ETag of an SSE-S3 encrypted // single-part object is equal to the object's content MD5. // Formatting the SSE-S3 ETag before decryption will result
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0)