Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 243 for Seed (0.21 sec)

  1. internal/config/identity/ldap/legacy.go

    }
    
    // SetIdentityLDAP - One time migration code needed, for migrating from older config to new for LDAPConfig.
    func SetIdentityLDAP(s config.Config, ldapArgs LegacyConfig) {
    	if !ldapArgs.Enabled {
    		// ldap not enabled no need to preserve it in new settings.
    		return
    	}
    	s[config.IdentityLDAPSubSys][config.Default] = config.KVS{
    		config.KV{
    			Key:   ServerAddr,
    			Value: ldapArgs.ServerAddr,
    		},
    		config.KV{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 08 05:12:36 GMT 2022
    - 2.2K bytes
    - Viewed (0)
  2. 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)
  3. docs/throttle/README.md

    This will reduce the pileup of waiting requests when clients are not configured with timeouts. Default wait time is *10 seconds* if *MINIO_API_REQUESTS_MAX* is enabled. This may need to be tuned to your application needs.
    
    Example: Limit a MinIO cluster to accept at max 1600 simultaneous S3 API requests across 8 servers, and set the wait deadline of *2 minutes* per API operation.
    
    ```sh
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  4. 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)
  5. docs/tls/kubernetes/README.md

    For a [distributed MinIO setup](https://min.io/docs/minio/kubernetes/upstream/operations/installation.html#procedure), where there are multiple pods with different domain names expected to run, you will either need wildcard certificates valid for all the domains or have specific certificates for each domain. If you are going to use specific certificates, make sure to create Kubernetes secrets accordingly.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 3K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top