- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for scwang (0.24 sec)
-
cmd/metacache-walk.go
// WalkDirOptions provides options for WalkDir operations. type WalkDirOptions struct { // Bucket to scanner Bucket string // Directory inside the bucket. BaseDir string // Do a full recursive scan. Recursive bool // ReportNotFound will return errFileNotFound if all disks reports the BaseDir cannot be found. ReportNotFound bool // FilterPrefix will only return results with given prefix within folder.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/metacache.go
"fmt" "path" "strings" "time" ) type scanStatus uint8 const ( scanStateNone scanStatus = iota scanStateStarted scanStateSuccess scanStateError // Time in which the initiator of a scan must have reported back. metacacheMaxRunningAge = time.Minute // Max time between client calls before dropping an async cache listing. metacacheMaxClientWait = 3 * time.Minute
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
internal/config/config.go
type Config map[string]map[string]KVS // DelFrom - deletes all keys in the input reader. func (c Config) DelFrom(r io.Reader) error { scanner := bufio.NewScanner(r) for scanner.Scan() { // Skip any empty lines, or comment like characters text := scanner.Text() if text == "" || strings.HasPrefix(text, KvComment) { continue } if err := c.DelKVS(text); err != nil { return err
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/metacache-set.go
// This will be used to persist the list. ID string // Bucket of the listing. Bucket string // Directory inside the bucket. // When unset listPath will set this based on Prefix BaseDir string // Scan/return only content with prefix. Prefix string // FilterPrefix will return only results with this prefix when scanning. // Should never contain a slash. // Prefix should still be set. FilterPrefix string
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 04:42:11 GMT 2024 - 30.4K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-bucket.json
"interval": "1m", "legendFormat": "{{server}}", "refId": "A" } ], "thresholds": [], "timeRegions": [], "title": "Time Elapsed Since Last Scan (nanos)", "tooltip": { "shared": true, "sort": 0, "value_type": "individual" }, "type": "graph", "xaxis": { "mode": "time",
Json - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Tue Feb 20 09:45:00 GMT 2024 - 71.4K bytes - Viewed (1) -
docs/metrics/prometheus/grafana/bucket/minio-bucket.json
"interval": "1m", "legendFormat": "{{server}}", "refId": "A" } ], "title": "Time Elapsed Since Last Scan (nanos)", "type": "timeseries" }, { "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "fieldConfig": { "defaults": {
Json - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 10:03:01 GMT 2024 - 102K bytes - Viewed (0) -
cmd/global-heal.go
"github.com/minio/pkg/v2/wildcard" "github.com/minio/pkg/v2/workers" ) const ( bgHealingUUID = "0000-0000-0000-0000" ) // NewBgHealSequence creates a background healing sequence // operation which scans all objects and heal them. func newBgHealSequence() *healSequence { reqInfo := &logger.ReqInfo{API: "BackgroundHeal"} ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo)) hs := madmin.HealOpts{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 09:22:13 GMT 2024 - 14.2K bytes - Viewed (1) -
.mailmap
# Generate CONTRIBUTORS.md: contributors.sh # Tip for finding duplicates (besides scanning the output of CONTRIBUTORS.md for name # duplicates that aren't also email duplicates): scan the output of: # git log --format='%aE - %aN' | sort -uf # # For explanation on this file format: man git-shortlog Anand Babu (AB) Periasamy <******@****.***> Anand Babu (AB) Periasamy <******@****.***> Anand Babu (AB) Periasamy <******@****.***> <******@****.***>
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 09 18:39:42 GMT 2019 - 835 bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
wantTrailers := make(map[string]struct{}, len(cr.trailers)) for k := range cr.trailers { wantTrailers[strings.ToLower(k)] = struct{}{} } input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes())) for input.Scan() { line := strings.TrimSpace(input.Text()) if line == "" { continue } // Find first separator. idx := strings.IndexByte(line, trailerKVSeparator[0]) if idx <= 0 || idx >= len(line) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat May 06 02:53:12 GMT 2023 - 6.1K bytes - Viewed (1) -
cmd/local-locker_test.go
Quorum: 0, }) if !ok || err != nil { t.Fatal("failed:", err, ok) } } } start := time.Now() l.expireOldLocks(time.Hour) t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap)) if len(l.lockMap) != locks { t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap)) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0)