Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 100 for Reed (0.15 sec)

  1. cmd/signals.go

    		for _, p := range globalProfiler {
    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    	stopProcess := func() bool {
    		// send signal to various go-routines that they need to quit.
    		cancelGlobalContext()
    
    		if httpServer := newHTTPServerFn(); httpServer != nil {
    			if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) {
    				shutdownLogIf(context.Background(), err)
    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)
  2. cmd/mrf.go

    	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'
    			if u.bucket == minioMetaBucket {
    				// No MRF needed for temporary objects
    				if wildcard.Match("buckets/*/.metacache/*", u.object) {
    					continue
    				}
    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)
  3. cmd/xl-storage-disk-id-check.go

    			for i := range p.apiCalls {
    				diskMetric.APICalls[storageMetric(i).String()] = atomic.LoadUint64(&p.apiCalls[i])
    			}
    			return diskMetric, nil
    		},
    	)
    
    	diskMetric, _ := p.metricsCache.Get()
    	// Do not need this value to be cached.
    	diskMetric.TotalErrorsTimeout = p.totalErrsTimeout.Load()
    	diskMetric.TotalErrorsAvailability = p.totalErrsAvailability.Load()
    
    	return diskMetric
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    		//   however writing the response doesn't need to serialize
    		//   concurrent writers
    		unlockOnDefer = true
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    	}
    
    	fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, bucket, object, opts, true)
    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)
  5. internal/logger/console.go

    const ConsoleLoggerTgt = "console+http"
    
    // ExitFunc is called by Fatal() class functions, by default it calls os.Exit()
    var ExitFunc = os.Exit
    
    // Logger interface describes the methods that need to be implemented to satisfy the interface requirements.
    type Logger interface {
    	json(msg string, args ...interface{})
    	quiet(msg string, args ...interface{})
    	pretty(msg string, args ...interface{})
    }
    
    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)
  6. cmd/bootstrap-peer-server.go

    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  7. cmd/iam.go

    	statusDisabled = "disabled"
    )
    
    const (
    	embeddedPolicyType  = "embedded-policy"
    	inheritedPolicyType = "inherited-policy"
    )
    
    // IAMSys - config system.
    type IAMSys struct {
    	// Need to keep them here to keep alignment - ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	// metrics
    	LastRefreshTimeUnixNano         uint64
    	LastRefreshDurationMilliseconds uint64
    	TotalRefreshSuccesses           uint64
    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)
  8. cmd/object-multipart-handlers.go

    			if err = setEncryptionMetadata(r, bucket, object, encMetadata); err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    		}
    		// Set this for multipart only operations, we need to differentiate during
    		// decryption if the file was actually multipart or not.
    		encMetadata[ReservedMetadataPrefix+"Encrypted-Multipart"] = ""
    	}
    
    	// Extract metadata that needs to be saved.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  9. docs/metrics/prometheus/README.md

    export MINIO_PROMETHEUS_AUTH_TYPE="public"
    minio server ~/test
    ```
    
    ### 3. Configuring Prometheus
    
    #### 3.1 Authenticated Prometheus config
    
    > If MinIO is configured to expose metrics without authentication, you don't need to use `mc` to generate prometheus config. You can skip reading further and move to 3.2 section.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. cmd/object-handlers.go

    	// if encryption is enabled we do not need explicit "REPLACE" metadata to
    	// be enabled as well - this is to allow for key-rotation.
    	if !isDirectiveReplace(r.Header.Get(xhttp.AmzMetadataDirective)) && !isDirectiveReplace(r.Header.Get(xhttp.AmzTagDirective)) &&
    		srcInfo.metadataOnly && srcOpts.VersionID == "" && !objectEncryption {
    		// If x-amz-metadata-directive is not set to REPLACE then we need
    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)
Back to top