- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for stacking (0.14 sec)
-
cmd/globals.go
globalTierConfigMgr *TierConfigMgr globalConsoleSrv *consoleapi.Server // handles service freeze or un-freeze S3 API calls. globalServiceFreeze atomic.Value // Only needed for tracking globalServiceFreezeCnt int32 globalServiceFreezeMu sync.Mutex // Updates. // List of local drives to this node, this is only set during server startup,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/s3select/select.go
return &limitedReadCloser{ LimitedReader: io.LimitedReader{R: r, N: n}, Closer: r, } } // ObjectSegmentReaderFn is a function that returns a reader for a contiguous // suffix segment of an object starting at the given (non-negative) offset. type ObjectSegmentReaderFn func(offset int64) (io.ReadCloser, error) // ObjectReadSeekCloser implements ReadSeekCloser interface for reading objects.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// - missing format.json (unformatted drive) // - format.json is valid but invalid 'uuid' if err = p.checkDiskStale(); err != nil { return ctx, done, err } // Disallow recursive tracking to avoid deadlocks. if ctx.Value(healthDiskCtxKey{}) != nil { done = p.updateStorageMetrics(s, paths...) return ctx, done, nil } if contextCanceled(ctx) { return ctx, done, ctx.Err() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-object.go
tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier) if err != nil { return err } // Acquire write lock before starting to transition the object. lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetLock(ctx, globalDeleteOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lk.Unlock(lkctx)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/server_test.go
t.Run(fmt.Sprintf("Test: %d, ServerType: %s", i+1, testCase.serverType), func(t *testing.T) { runAllTests(testCase, &check{t, testCase.serverType}) }) } } // Setting up the test suite. // Starting the Test server with temporary backend. func (s *TestSuiteCommon) SetUpSuite(c *check) { if s.secure { cert, key, err := generateTLSCertKey("127.0.0.1") c.Assert(err, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/batch-rotate.go
// tags: // - key: "name" // value: "pick*" # match objects with tag 'name', with all values starting with 'pick' // metadata: // - key: "content-type" // value: "image/*" # match objects with 'content-type', with all values starting with 'image/' // kmskey: "key-id" # match objects with KMS key-id (applicable only for sse-kms) // notify:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/http/listener.go
Interface string // This is a VRF device passed via `--interface` flag Trace func(msg string) // Trace when starting. } // newHTTPListener - creates new httpListener object which is interface compatible to net.Listener. // httpListener is capable to // * listen to multiple addresses
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/batch-expire.go
// tags: // - key: name // value: pick* # match objects with tag 'name', all values starting with 'pick' // metadata: // - key: content-type // value: image/* # match objects with 'content-type', all values starting with 'image/' // size: // lessThan: "10MiB" # match objects with size less than this value (e.g. 10MiB)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/object-api-datatypes.go
// by max uploads. IsTruncated bool // List of all pending uploads. Uploads []MultipartInfo // When a prefix is provided in the request, The result contains only keys // starting with the specified prefix. Prefix string // A character used to truncate the object prefixes. // NOTE: only supported delimiter is '/'. Delimiter string
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/object-api-utils.go
inputReader = ioutil.NewSkipReader(inputReader, decryptSkip) } oi.Size = decLength } // Decompression reader. var dopts []s2.ReaderOption if off > 0 || decOff > 0 { // We are not starting at the beginning, so ignore stream identifiers. dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier()) } s2Reader := s2.NewReader(inputReader, dopts...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1)