- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for CheckValidKeys (0.07 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 18.7K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/config/subnet/config.go
} } } // LookupConfig - lookup config and override with valid environment settings if any. func LookupConfig(kvs config.KVS, transport http.RoundTripper) (cfg Config, err error) { if err = config.CheckValidKeys(config.SubnetSubSys, kvs, DefaultKVS); err != nil { return cfg, err } var proxyURL *xnet.URL proxy := env.Get(config.EnvMinIOSubnetProxy, kvs.Get(config.Proxy)) if len(proxy) > 0 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 3.9K bytes - Viewed (0) -
internal/config/config.go
name) return s, err } s.name = name } return s, err } // 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K bytes - Viewed (0) -
internal/config/api/api.go
corsAllowOrigin = strings.Split(corsList, ",") if slices.Contains(corsAllowOrigin, "") { 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.5K bytes - Viewed (1) -
internal/config/compress/compress.go
} } 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 } compress := env.Get(EnvCompressState, "") if compress == "" { compress = env.Get(EnvCompressEnableLegacy, "")
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Sep 06 17:37:10 UTC 2025 - 5K bytes - Viewed (0) -
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' targetsRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
// 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{} if err := s.CheckValidKeys(config.PolicyPluginSubSys, nil); err != nil { return args, err } getCfg := func(cfgParam string) string { // As parameters are already validated, we skip checking // if the config param was found.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.8K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Sep 18 11:47:48 UTC 2025 - 8.6K bytes - Viewed (0)