- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 139 for dine (0.17 sec)
-
internal/logger/console.go
// message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit. break } for { // Save the attributes of the current cursor helps // us save the text color of the passed error message
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) -
.github/workflows/mint.yml
done docker-compose -f ${GITHUB_WORKSPACE}/.github/workflows/multipart/docker-compose-site1.yaml rm -s -f || true docker-compose -f ${GITHUB_WORKSPACE}/.github/workflows/multipart/docker-compose-site2.yaml rm -s -f || true for volume in $(docker volume ls -q | grep minio); do docker volume rm ${volume} || true done
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 23:44:49 GMT 2024 - 2.6K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
} add_alias() { for i in $(seq 1 4); do echo "... attempting to add alias $i" until (mc alias set minio http://127.0.0.1:9000 minioadmin minioadmin); do echo "...waiting... for 5secs" && sleep 5 done done echo "Sleeping for nginx" sleep 20 } __init__() { sudo apt install curl -y export GOPATH=/tmp/gopath export PATH=${PATH}:${GOPATH}/bin go install github.com/minio/mc@latest
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 11:39:55 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/erasure-common.go
disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return } di, err := disks[i].DiskInfo(context.Background(), DiskInfoOptions{}) if err != nil || di.Healing { // - Do not consume disks which are not reachable
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-dashboard.json
"axisCenteredZero": false, "axisColorMode": "text", "axisLabel": "", "axisPlacement": "auto", "barAlignment": 0, "drawStyle": "line", "fillOpacity": 10, "gradientMode": "none", "hideFrom": { "legend": false, "tooltip": false, "viz": false },
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 10:03:01 GMT 2024 - 93K bytes - Viewed (2) -
cmd/erasure-server-pool.go
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 { scannerLogIf(ctx, err)
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/iam.go
return sys.store.GetBucketUsers(bucket) case <-ctx.Done(): return nil, ctx.Err() } } // ListUsers - list all users. func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) { if !sys.Initialized() { return nil, errServerNotInitialized } select { case <-sys.configLoaded: return sys.store.GetUsers(), nil case <-ctx.Done(): return nil, ctx.Err() } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/grid/README.md
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/mrf.go
// issues healing requests for queued objects belonging to the // corresponding erasure set func (m *mrfState) healRoutine(z *erasureServerPools) { for { select { case <-GlobalContext.Done(): return case u, ok := <-m.opCh: if !ok { return } // We might land at .metacache, .trash, .multipart // no need to heal them skip, only when bucket // is '.minio.sys'
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/license-update.go
ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() licenseUpdateTimer := time.NewTimer(licUpdateCycle) defer licenseUpdateTimer.Stop() for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C: if globalSubnetConfig.Registered() { performLicenseUpdate(ctx, objAPI) } // Reset the timer for next cycle. licenseUpdateTimer.Reset(licUpdateCycle)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0)