Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  2. 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
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  4. 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
    	d := kvs.GetWithDefault(MaxTimeout, DefaultKVS)
    	if d == "" {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  5. 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 == "" {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  6. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.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
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  8. internal/config/lambda/parse.go

    		subSysTarget := subSys
    		if tname != config.Default {
    			subSysTarget = subSys + config.SubSystemSeparator + tname
    		}
    		if v, ok := kv.Lookup(config.Enable); ok && v == config.EnableOn {
    			if err := config.CheckValidKeys(subSysTarget, kv, validKVS); err != nil {
    				return err
    			}
    		}
    	}
    	return nil
    }
    
    // GetLambdaWebhook - returns a map of registered notification 'webhook' targets
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  9. 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)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  10. 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
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
Back to top