Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for rowEnd (0.23 sec)

  1. docs/sts/web-identity.md

    `MINIO_BROWSER_REDIRECT_URL=https://console.minio.example.org`. This will ensure that the redirect URL is set to `https://console.minio.example.org/oauth_callback` and the login process should work correctly.
    
    For deployments employing DNS round-robin on a single domain to all the MinIO servers, it is possible that after redirection the browser may land on a different MinIO server. For example, the domain `console.minio.example.org` may resolve to `console-X.minio.example.org`, where `X` is...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  2. cmd/xl-storage-disk-id-check.go

    			select {
    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    			}
    		}()
    
    		func() {
    			defer dcancel()
    
    			err := p.storage.WriteAll(ctx, minioMetaTmpBucket, fn, toWrite)
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  3. internal/grid/muxclient.go

    func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) {
    	if debugPrint {
    		start := time.Now()
    		defer func() {
    			fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond))
    		}()
    	}
    	defer func() {
    		// addErrorNonBlockingClose will close the response channel
    		// - maybe async, so we shouldn't do it here.
    		if m.respErr.Load() == nil {
    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)
  4. cmd/metrics-resource.go

    					cpuUserVal := math.Round(ts.User/tot*100*100) / 100
    					updateResourceMetrics(cpuSubsystem, cpuUser, cpuUserVal, labels, false)
    					cpuSystemVal := math.Round(ts.System/tot*100*100) / 100
    					updateResourceMetrics(cpuSubsystem, cpuSystem, cpuSystemVal, labels, false)
    					cpuIdleVal := math.Round(ts.Idle/tot*100*100) / 100
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  5. docs/metrics/v3.md

    | `minio_cluster_iam_plugin_authn_service_succ_avg_rtt_ms_minute` | `counter` | When plugin authentication is configured, returns average round-trip-time of successful requests in the last full minute |        |
    | `minio_cluster_iam_plugin_authn_service_succ_max_rtt_ms_minute` | `counter` | When plugin authentication is configured, returns maximum round-trip-time of successful requests in the last full minute |        |
    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)
  6. internal/grid/connection.go

    			}
    			sleep := defaultDialTimeout + time.Duration(rng.Int63n(int64(defaultDialTimeout)))
    			next := dialStarted.Add(sleep / 2)
    			sleep = time.Until(next).Round(time.Millisecond)
    			if sleep < 0 {
    				sleep = 0
    			}
    			gotState := c.State()
    			if gotState == StateShutdown {
    				return
    			}
    			if gotState != StateConnecting {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    				cancel()
    				exit = true
    				meta.status = scanStateError
    				meta.error = fmt.Sprintf("listing canceled since time since last handout was %v ago", time.Since(meta.lastHandout).Round(time.Second))
    				o.debugln(color.Green("saveMetaCacheStream: ") + meta.error)
    				meta, err = o.updateMetacacheListing(meta, rpc)
    			}
    			if err == nil {
    				*mc.meta = meta
    				if meta.status == scanStateError {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  8. internal/config/identity/plugin/config.go

    		if reqStartTime.After(h.LastCheckSuccess) {
    			h.LastCheckSuccess = reqStartTime
    		}
    	} else {
    		if reqStartTime.After(h.LastCheckFailure) {
    			h.LastCheckFailure = reqStartTime
    		}
    	}
    
    	// Round the request time *down* to whole minute.
    	reqTimeMinute := reqStartTime.Truncate(time.Minute)
    	if reqTimeMinute.After(h.currentMinute.statsTime) {
    		// Drop the last full minute now, since we got a request for a time we
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
  9. cmd/prepare-storage.go

    	// All times are rounded to avoid showing milli, micro and nano seconds
    	formatStartTime := time.Now().Round(time.Second)
    	getElapsedTime := func() string {
    		return time.Now().Round(time.Second).Sub(formatStartTime).String()
    	}
    
    	var (
    		tries   int
    		verbose bool
    	)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  10. cmd/server-main.go

    	if serverDebugLog {
    		fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg)
    	}
    
    	noSubs := globalTrace.NumSubscribers(madmin.TraceBootstrap) == 0
    	if noSubs {
    		return
    	}
    
    	globalTrace.Publish(info)
    }
    
    func bootstrapTrace(msg string, worker func()) {
    	if serverDebugLog {
    		fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
Back to top