Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 243 for Reed (0.12 sec)

  1. 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)
  2. 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)
  3. internal/s3select/parquet/reader.go

    	if se == nil {
    		return v, nil
    	}
    
    	var value interface{}
    	switch val := v.(type) {
    	case []byte:
    		// TODO: only strings are supported in s3select output (not
    		// binary arrays) - perhaps we need to check the annotation to
    		// ensure it's UTF8 encoded.
    		value = string(val)
    	case [12]byte:
    		// TODO: This is returned for the parquet INT96 type. We just
    		// treat it same as []byte (but AWS S3 treats it as a large int)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  4. internal/mountinfo/mountinfo_linux.go

    	for _, mount := range mts {
    		// Add a separator to indicate that this is a proper mount-point.
    		// This is to avoid a situation where prefix is '/tmp/fsmount'
    		// and mount path is /tmp/fs. In such a scenario we need to check for
    		// `/tmp/fs/` to be a common prefix amount other mounts.
    		mpath := strings.TrimSuffix(mount.Path, "/") + "/"
    		ppath := strings.TrimSuffix(path, "/") + "/"
    		if strings.HasPrefix(mpath, ppath) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  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. internal/config/identity/openid/openid.go

    			isExplicitlyEnabled = cfgEnableVal != ""
    		)
    
    		var enabled bool
    		if isExplicitlyEnabled {
    			enabled, err = config.ParseBool(cfgEnableVal)
    			if err != nil {
    				return c, err
    			}
    			// No need to continue loading if the config is not enabled.
    			if !enabled {
    				continue
    			}
    		}
    
    		p := newProviderCfgFromConfig(getCfgVal)
    		configURL := getCfgVal(ConfigURL)
    
    		if !isExplicitlyEnabled {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top