- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for into (0.16 sec)
-
cmd/erasure-object.go
} // DeleteObjects deletes objects/versions in bulk, this function will still automatically split objects list // into smaller bulks if some object names are found to be duplicated in the delete list, splitting // into smaller bulks will avoid holding twice the write lock of the duplicated object names.
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) -
internal/bucket/lifecycle/delmarker-expiration.go
XMLName xml.Name `xml:"DelMarkerExpiration"` Days int `xml:"Days,omitempty"` } // Empty returns if a DelMarkerExpiration XML element is empty. // Used to detect if lifecycle.Rule contained a DelMarkerExpiration element. func (de DelMarkerExpiration) Empty() bool { return de.Days == 0 } // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/logger/logrotate.go
// or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary. // Write is non-blocking, if the writer's queue is not full. // Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
} ep.argPatterns = argPatterns return ep, nil } // GetAllSets - parses all ellipses input arguments, expands them into // corresponding list of endpoints chunked evenly in accordance with a // specific set size. // For example: {1...64} is divided into 4 sets each of size 16. // This applies to even distributed setup syntax as well. func GetAllSets(setDriveCount uint64, args ...string) ([][]string, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/signals.go
exit(stopProcess()) case osSignal := <-globalOSSignalCh: logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String())) daemon.SdNotify(false, daemon.SdNotifyStopping) exit(stopProcess()) case signal := <-globalServiceSignalCh: switch signal { case serviceRestart: logger.Info("Restarting on service signal") daemon.SdNotify(false, daemon.SdNotifyReloading)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/logger/console.go
} // Error : func Error(msg string, data ...interface{}) { if DisableErrorLog { return } consoleLog(errorm, msg, data...) } // Info : func Info(msg string, data ...interface{}) { if DisableErrorLog { return } consoleLog(info, msg, data...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
type HealthResult struct { Healthy bool HealthyRead bool HealingDrives int ESHealth []struct { Maintenance bool PoolID, SetID int Healthy bool HealthyRead bool HealthyDrives int HealingDrives int ReadQuorum int WriteQuorum int } WriteQuorum int ReadQuorum int UsingDefaults bool }
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/object-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } wantSize := int64(-1) if size >= 0 { info := ObjectInfo{Size: size} wantSize = info.EncryptedSize() } // do not try to verify encrypted content hashReader, err = hash.NewReader(ctx, etag.Wrap(reader, hashReader), wantSize, "", "", actualSize) if err != nil {
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) -
docs/metrics/v3.md
# Metrics Version 3 In metrics version 3, all metrics are available under the endpoint: ``` /minio/metrics/v3 ``` however, a specific path under this is required. Metrics are organized into groups at paths **relative** to the top-level endpoint above. ## Metrics Request Handling Each endpoint below can be queried at different intervals as needed via a scrape configuration in Prometheus or a compatible metrics collection tool.
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/format-erasure.go
} return nil, err } // Try to decode format json into formatConfigV1 struct. format = &formatErasureV3{} if err = json.Unmarshal(data, format); err != nil { return nil, err } if heal { info, err := disk.DiskInfo(context.Background(), DiskInfoOptions{NoOp: heal}) if err != nil { return nil, err } format.Info = info } // Success. return format, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0)