Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 63 for ekvs (0.02 sec)

  1. internal/config/identity/ldap/config.go

    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(ServerAddr) != ""
    }
    
    // Lookup - initializes LDAP config, overrides config, if any ENV values are set.
    func Lookup(s config.Config, rootCAs *x509.CertPool) (l Config, err error) {
    	l = Config{}
    
    	// Purge all removed keys first
    	kvs := s[config.IdentityLDAPSubSys][config.Default]
    	if len(kvs) > 0 {
    		for _, k := range removedKeys {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Sep 18 11:47:48 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  2. internal/config/policy/opa/legacy.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package opa
    
    import (
    	"github.com/minio/minio/internal/config"
    )
    
    // Legacy OPA envs
    const (
    	EnvIamOpaURL       = "MINIO_IAM_OPA_URL"
    	EnvIamOpaAuthToken = "MINIO_IAM_OPA_AUTHTOKEN"
    )
    
    // SetPolicyOPAConfig - One time migration code needed, for migrating from older config to new for PolicyOPAConfig.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  3. internal/config/policy/plugin/config.go

    type AuthZPlugin struct {
    	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)
  4. cmd/config-current.go

    		config.BrowserSubSys:        browser.DefaultKVS,
    	}
    	maps.Copy(kvs, notify.DefaultNotificationKVS)
    	maps.Copy(kvs, lambda.DefaultLambdaKVS)
    	if globalIsErasure {
    		kvs[config.StorageClassSubSys] = storageclass.DefaultKVS
    		kvs[config.HealSubSys] = heal.DefaultKVS
    	}
    	config.RegisterDefaultKVS(kvs)
    
    	// Captures help for each sub-system
    	helpSubSys := config.HelpKVS{
    		config.HelpKV{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  5. cmd/config.go

    	}
    
    	srvCfg, err := readConfigWithoutMigrate(GlobalContext, objAPI)
    	if err != nil {
    		return err
    	}
    
    	bootstrapTraceMsg("lookup the configuration")
    
    	// Override any values from ENVs.
    	lookupConfigs(srvCfg, objAPI)
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	return nil
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  6. internal/config/identity/plugin/config.go

    	shutdownCtx    context.Context
    	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/notify/parse.go

    		},
    	}
    )
    
    // GetNotifyES - returns a map of registered notification 'elasticsearch' targets
    func GetNotifyES(esKVS map[string]config.KVS, transport *http.Transport) (map[string]target.ElasticsearchArgs, error) {
    	esTargets := make(map[string]target.ElasticsearchArgs)
    	for k, kv := range config.Merge(esKVS, target.EnvElasticEnable, DefaultESKVS) {
    		enableEnv := target.EnvElasticEnable
    		if k != config.Default {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  8. internal/config/scanner/scanner.go

    	// has not been changed from its "default" value, if it has been changed honor new settings.
    	if kvs.GetWithDefault(Speed, DefaultKVS) == "default" {
    		if kvs.Get(Delay) != "" && kvs.Get(MaxWait) != "" {
    			if err = lookupDeprecatedScannerConfig(kvs, &cfg); err != nil {
    				return cfg, err
    			}
    		}
    	}
    
    	switch speed := env.Get(EnvSpeed, kvs.GetWithDefault(Speed, DefaultKVS)); speed {
    	case "fastest":
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/s3select/sql/jsonpath.go

    	}
    
    	switch {
    	case p[0].Key != nil:
    		key := p[0].Key.keyString()
    
    		switch kvs := v.(type) {
    		case jstream.KVS:
    			for _, kv := range kvs {
    				if kv.Key == key {
    					return jsonpathEval(p[1:], kv.Value)
    				}
    			}
    			// Key not found - return nil result
    			return Missing{}, false, nil
    		case simdjson.Object:
    			elem := kvs.FindKey(key, nil)
    			if elem == nil {
    				// Key not found - return nil result
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  10. internal/config/etcd/etcd.go

    }
    
    // Enabled returns if etcd is enabled.
    func Enabled(kvs config.KVS) bool {
    	endpoints := kvs.Get(Endpoints)
    	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
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 5.2K bytes
    - Viewed (0)
Back to top