- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Stuart (5.34 sec)
-
cmd/object-handlers.go
} // For providing ranged content start, rangeLen, err := rs.GetOffsetLength(ci.Size) if err != nil { start, rangeLen = 0, ci.Size } // Set content length. w.Header().Set(xhttp.ContentLength, strconv.FormatInt(rangeLen, 10)) if rs != nil { contentRange := fmt.Sprintf("bytes %d-%d/%d", start, start+rangeLen-1, ci.Size)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
updates := make(chan dataUsageCache, 1) defer xioutil.SafeClose(updates) // Start update collector. go func() { defer wg.Done() for info := range updates { mu.Lock() results[i] = info mu.Unlock() } }() // Start scanner. Blocks until done. err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-object.go
} // Reply back invalid range if the input offset and length fall out of range. if startOffset > fi.Size || startOffset+length > fi.Size { return InvalidRange{startOffset, length, fi.Size} } // Get start part index and offset. partIndex, partOffset, err := fi.ObjectToPartOffset(ctx, startOffset) if err != nil { return InvalidRange{startOffset, length, fi.Size} } // Calculate endOffset according to length
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/api-errors.go
Description: "Client token mismatch", HTTPStatusCode: http.StatusBadRequest, }, ErrHealMissingBucket: { Code: "XMinioHealMissingBucket", Description: "A heal start request with a non-empty object-prefix parameter requires a bucket to be specified.", HTTPStatusCode: http.StatusBadRequest, }, ErrHealAlreadyRunning: { Code: "XMinioHealAlreadyRunning",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
cmd/common-main.go
} if _, _, err := net.SplitHostPort(consoleAddr); err != nil { logger.FatalIf(err, "Unable to start listening on console port") } if consoleAddr == addr { logger.FatalIf(errors.New("--console-address cannot be same as --address"), "Unable to start the server") } globalMinioHost, globalMinioPort = mustSplitHostPort(addr) if globalMinioPort == "0" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
docs/distributed/CONFIG.md
### Usage ``` minio server --config config.yaml ``` Lets you start MinIO server with all inputs to start MinIO server provided via this configuration file, once the configuration file is provided all other pre-existing values on disk for configuration are overridden by the new values set in this configuration file.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 4.2K bytes - Viewed (0) -
docs/metrics/v3.md
| `io_write_bytes` | `counter` | Total bytes written by the process to the underlying storage system, /proc/[pid]/io write_bytes | `server` | | `start_time_seconds` | `gauge` | Start time for MinIO process in seconds since Unix epoc | `server` |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
cmd/test-utils_test.go
rawDiskPaths []string } // UnstartedTestServer - Configures a temp FS/Erasure backend, // initializes the endpoints and configures the test server. // The server should be started using the Start() method. func UnstartedTestServer(t TestErrHandler, instanceType string) TestServer { ctx, cancel := context.WithCancel(context.Background()) // create an instance of TestServer. testServer := TestServer{cancel: cancel}
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) -
cmd/metrics-v3-cluster-iam.go
syncFailuresMD = NewCounterMD(syncFailures, "Number of failed IAM data syncs since server start.") syncSuccessesMD = NewCounterMD(syncSuccesses, "Number of successful IAM data syncs since server start.") ) // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics. func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 08:20:42 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/batch-handlers.go
ri.Bucket = bucket for i := range batch { ri.Object = batch[i].Name ri.countItem(batch[i].Size, batch[i].DeleteMarker, true) } } // Start start the batch replication job, resumes if there was a pending job via "job.ID" func (r *BatchJobReplicateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0)