Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for CheckValidKeys (0.1 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/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)
  4. 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)
  5. 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)
  6. internal/config/api/api.go

    		for _, cors := range corsAllowOrigin {
    			if cors == "" {
    				return cfg, errors.New("invalid cors value")
    			}
    		}
    	}
    	cfg.CorsAllowOrigin = corsAllowOrigin
    
    	if err = config.CheckValidKeys(config.APISubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil {
    		return cfg, err
    	}
    
    	// Check environment variables parameters
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. internal/config/identity/ldap/config.go

    	kvs := s[config.IdentityLDAPSubSys][config.Default]
    	if len(kvs) > 0 {
    		for _, k := range removedKeys {
    			kvs.Delete(k)
    		}
    		s[config.IdentityLDAPSubSys][config.Default] = kvs
    	}
    
    	if err := s.CheckValidKeys(config.IdentityLDAPSubSys, removedKeys); err != nil {
    		return l, err
    	}
    
    	getCfgVal := func(cfgParam string) string {
    		// As parameters are already validated, we skip checking
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/config/identity/openid/openid.go

    		for _, dk := range deprecatedKeys {
    			kvs := s[config.IdentityOpenIDSubSys][k]
    			kvs.Delete(dk)
    			s[config.IdentityOpenIDSubSys][k] = kvs
    		}
    	}
    
    	if err := s.CheckValidKeys(config.IdentityOpenIDSubSys, deprecatedKeys); err != nil {
    		return c, err
    	}
    
    	openIDTargets, err := s.GetAvailableTargets(config.IdentityOpenIDSubSys)
    	if err != nil {
    		return c, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  9. internal/config/storageclass/storage-class.go

    func LookupConfig(kvs config.KVS, setDriveCount int) (cfg Config, err error) {
    	cfg = Config{}
    
    	deprecatedKeys := []string{
    		"dma",
    	}
    
    	if err = config.CheckValidKeys(config.StorageClassSubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil {
    		return Config{}, err
    	}
    
    	ssc := env.Get(StandardEnv, kvs.Get(ClassStandard))
    	rrsc := env.Get(RRSEnv, kvs.Get(ClassRRS))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  10. internal/config/notify/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
    }
    
    // DefaultKafkaKVS - default KV for kafka target
    var (
    	DefaultKafkaKVS = config.KVS{
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
Back to top