Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for LookupConfig (0.04 sec)

  1. cmd/config-current.go

    			if _, err := storageclass.LookupConfig(s[config.StorageClassSubSys][config.Default], setDriveCount); err != nil {
    				return err
    			}
    		}
    	case config.CompressionSubSys:
    		if _, err := compress.LookupConfig(s[config.CompressionSubSys][config.Default]); err != nil {
    			return err
    		}
    	case config.HealSubSys:
    		if _, err := heal.LookupConfig(s[config.HealSubSys][config.Default]); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  2. internal/config/policy/opa/config.go

    type Opa struct {
    	args   Args
    	client *http.Client
    }
    
    // Enabled returns if opa is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(URL) != ""
    }
    
    // LookupConfig lookup Opa from config, override with any ENVs.
    func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser)) (Args, error) {
    	args := Args{}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. internal/config/compress/compress.go

    		}
    		if e == "/" {
    			return nil, config.ErrInvalidCompressionIncludesValue(nil).Msg("extension/mime-type cannot be '/'")
    		}
    	}
    	return includes, nil
    }
    
    // LookupConfig - lookup compression config.
    func LookupConfig(kvs config.KVS) (Config, error) {
    	var err error
    	cfg := Config{}
    	if err = config.CheckValidKeys(config.CompressionSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Sep 06 17:37:10 UTC 2025
    - 5K bytes
    - Viewed (0)
  4. internal/config/policy/plugin/config.go

    	args   Args
    	client *http.Client
    }
    
    // Enabled returns if AuthZPlugin is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(URL) != ""
    }
    
    // LookupConfig lookup AuthZPlugin from config, override with any ENVs.
    func LookupConfig(s config.Config, httpSettings xhttp.ConnSettings, closeRespFn func(io.ReadCloser)) (Args, error) {
    	args := Args{}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  5. internal/config/api/api.go

    	type Alias Config
    	aux := &struct {
    		*Alias
    	}{
    		Alias: (*Alias)(sCfg),
    	}
    	return json.Unmarshal(data, &aux)
    }
    
    // LookupConfig - lookup api config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	deprecatedKeys := []string{
    		apiReadyDeadline,
    		apiRequestsDeadline,
    		"extend_list_cache_life",
    		apiReplicationWorkers,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.5K bytes
    - Viewed (1)
  6. internal/config/identity/plugin/config.go

    	serviceMetrics *metrics
    }
    
    // Enabled returns if AuthNPlugin is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(URL) != ""
    }
    
    // LookupConfig lookup AuthNPlugin from config, override with any ENVs.
    func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser), serverRegion string) (Args, error) {
    	args := Args{}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  7. internal/config/identity/openid/openid.go

    	maps.Copy(cfg.arnProviderCfgsMap, r.arnProviderCfgsMap)
    	maps.Copy(cfg.ProviderCfgs, r.ProviderCfgs)
    	maps.Copy(cfg.roleArnPolicyMap, r.roleArnPolicyMap)
    	return cfg
    }
    
    // LookupConfig lookup jwks from config, override with any ENVs.
    func LookupConfig(s config.Config, transport http.RoundTripper, closeRespFn func(io.ReadCloser), serverRegion string) (c Config, err error) {
    	openIDClientTransport := http.DefaultTransport
    	if transport != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  8. internal/config/storageclass/storage-class.go

    	case 1:
    		return 0
    	case 3, 2:
    		return 1
    	case 4, 5:
    		return 2
    	case 6, 7:
    		return 3
    	default:
    		return 4
    	}
    }
    
    // LookupConfig - lookup storage class config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS, setDriveCount int) (cfg Config, err error) {
    	cfg = Config{}
    
    	deprecatedKeys := []string{
    		"dma",
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  9. cmd/iam.go

    			}
    		}
    
    		if !authZInit {
    			authZPluginCfg, err := polplugin.LookupConfig(s, GetDefaultConnSettings(), xhttp.DrainBody)
    			if err != nil {
    				iamLogIf(ctx, fmt.Errorf("Unable to initialize AuthZPlugin: %w", err), logger.WarningKind)
    			} else {
    				authZInit = true
    			}
    			if authZPluginCfg.URL == nil {
    				opaCfg, err := opa.LookupConfig(s[config.PolicyOPASubSys][config.Default],
    					NewHTTPTransport(), xhttp.DrainBody)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 76.5K bytes
    - Viewed (0)
  10. cmd/format-erasure.go

    // It will attempt to read it from env variable and fall back to drives/2.
    func ecDrivesNoConfig(setDriveCount int) (int, error) {
    	sc, err := storageclass.LookupConfig(config.KVS{}, setDriveCount)
    	if err != nil {
    		return 0, err
    	}
    	return sc.GetParityForSC(storageclass.STANDARD), nil
    }
    
    // Initialize a new set of set formats which will be written to all disks.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
Back to top