Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for CheckValidKeys (0.08 sec)

  1. internal/logger/config.go

    			continue
    		}
    		subSysTarget := config.LoggerWebhookSubSys
    		if k != config.Default {
    			subSysTarget = config.LoggerWebhookSubSys + config.SubSystemSeparator + k
    		}
    		if err := config.CheckValidKeys(subSysTarget, kv, DefaultLoggerWebhookKVS); err != nil {
    			return cfg, err
    		}
    		enableCfgVal := getCfgVal(EnvLoggerWebhookEnable, k, kv.Get(config.Enable))
    		enable, err := config.ParseBool(enableCfgVal)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. internal/config/policy/opa/config.go

    }
    
    // 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{}
    
    	if err := config.CheckValidKeys(config.PolicyOPASubSys, kv, DefaultKVS); err != nil {
    		return args, err
    	}
    
    	opaURL := env.Get(EnvIamOpaURL, "")
    	if opaURL == "" {
    		opaURL = env.Get(EnvPolicyOpaURL, kv.Get(URL))
    		if opaURL == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. internal/config/ilm/ilm.go

    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	cfg = Config{
    		TransitionWorkers: 100,
    		ExpirationWorkers: 100,
    	}
    
    	if err = config.CheckValidKeys(config.ILMSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	tw, err := strconv.Atoi(env.Get(EnvILMTransitionWorkers, kvs.GetWithDefault(transitionWorkers, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. internal/config/batch/batch.go

    	},
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.BatchSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	cfg.ReplicationWorkersWait = 0
    	cfg.KeyRotationWorkersWait = 0
    	cfg.ExpirationWorkersWait = 0
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. internal/config/callhome/callhome.go

    	c.Enable = ncfg.Enable
    	c.Frequency = ncfg.Frequency
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.CallhomeSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	cfg.Enable = env.Get(config.EnvMinIOCallhomeEnable,
    		kvs.GetWithDefault(Enable, DefaultKVS)) == config.EnableOn
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. internal/config/drive/drive.go

    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	cfg = Config{
    		MaxTimeout: 30 * time.Second,
    	}
    	if err = config.CheckValidKeys(config.DriveSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	// if not set. Get default value from environment
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. internal/config/etcd/etcd.go

    	return endpoints != ""
    }
    
    // LookupConfig - Initialize new etcd config.
    func LookupConfig(kvs config.KVS, rootCAs *x509.CertPool) (Config, error) {
    	cfg := Config{}
    	if err := config.CheckValidKeys(config.EtcdSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	endpoints := env.Get(EnvEtcdEndpoints, kvs.Get(Endpoints))
    	if endpoints == "" {
    		return cfg, nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. internal/config/browser/browser.go

    		HSTSSeconds:           0,
    		HSTSIncludeSubdomains: true,
    		HSTSPreload:           true,
    		ReferrerPolicy:        "strict-origin-when-cross-origin",
    	}
    
    	if err = config.CheckValidKeys(config.BrowserSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  9. internal/config/config.go

    				name)
    			return
    		}
    		s.name = name
    	}
    	return
    }
    
    // CheckValidKeys - checks if inputs KVS has the necessary keys,
    // returns error if it find extra or superfluous keys.
    func CheckValidKeys(subSys string, kv KVS, validKVS KVS, deprecatedKeys ...string) error {
    	nkv := KVS{}
    	for _, kv := range kv {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  10. internal/config/scanner/scanner.go

    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	cfg = Config{
    		ExcessVersions: 100,
    		ExcessFolders:  50000,
    		IdleMode:       0, // Default is on
    	}
    
    	if err = config.CheckValidKeys(config.ScannerSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	excessVersions, err := strconv.ParseInt(env.Get(EnvExcessVersions, kvs.GetWithDefault(ExcessVersions, DefaultKVS)), 10, 64)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top