Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for if (0.13 sec)

  1. internal/config/policy/opa/config.go

    	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 == "" {
    			return args, nil
    		}
    	}
    	authToken := env.Get(EnvIamOpaAuthToken, "")
    	if authToken == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  2. internal/logger/config.go

    			if target == legacyEnvLoggerHTTPEndpoint {
    				target = config.Default
    			}
    			loggerTargets = append(loggerTargets, target)
    		}
    
    		// Load HTTP logger from the environment if found
    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  3. istioctl/pkg/config/config.go

    	}
    	return w.Flush()
    }
    
    func configSource(flag string, v env.VariableInfo) string {
    	// Environment variables have high precedence in Viper
    	if v.IsSet() {
    		return "$" + v.GetName()
    	}
    
    	if viper.InConfig(flag) {
    		return root.IstioConfig
    	}
    
    	return "default"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Jul 30 12:16:07 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  4. cmd/config.go

    		if err != nil {
    			if errors.Is(err, errConfigNotFound) {
    				lookupConfigs(srvCfg, objAPI)
    				return srvCfg, nil
    			}
    			return nil, err
    		}
    
    		data, err = decryptData(data, configFile)
    		if err != nil {
    			lookupConfigs(srvCfg, objAPI)
    			return nil, err
    		}
    	}
    
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
  5. internal/config/identity/ldap/config.go

    		if err != nil {
    			return l, err
    		}
    	}
    
    	l.stsExpiryDuration = defaultLDAPExpiry
    
    	// LDAP connection configuration
    	if v := getCfgVal(ServerInsecure); v != "" {
    		l.LDAP.ServerInsecure, err = config.ParseBool(v)
    		if err != nil {
    			return l, err
    		}
    	}
    	if v := getCfgVal(ServerStartTLS); v != "" {
    		l.LDAP.ServerStartTLS, err = config.ParseBool(v)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 7.9K bytes
    - Viewed (2)
  6. internal/config/subnet/config.go

    	c.transport = ncfg.transport
    	c.BaseURL = baseURL
    
    	if isDevEnv {
    		c.BaseURL = os.Getenv("_MINIO_SUBNET_URL")
    		if c.BaseURL == "" {
    			c.BaseURL = baseURLDev
    		}
    	}
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS, transport http.RoundTripper) (cfg Config, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  7. internal/config/identity/tls/config.go

    // GetExpiryDuration - return parsed expiry duration.
    func (l Config) GetExpiryDuration(dsecs string) (time.Duration, error) {
    	if dsecs == "" {
    		return defaultExpiry, nil
    	}
    
    	d, err := strconv.Atoi(dsecs)
    	if err != nil {
    		return 0, auth.ErrInvalidDuration
    	}
    
    	dur := time.Duration(d) * time.Second
    
    	if dur < minExpiry || dur > maxExpiry {
    		return 0, auth.ErrInvalidDuration
    	}
    	return dur, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  8. internal/config/identity/plugin/config.go

    	defer h.Unlock()
    
    	// Update connectivity times
    	if isSuccess {
    		if reqStartTime.After(h.LastCheckSuccess) {
    			h.LastCheckSuccess = reqStartTime
    		}
    	} else {
    		if reqStartTime.After(h.LastCheckFailure) {
    			h.LastCheckFailure = reqStartTime
    		}
    	}
    
    	// Round the request time *down* to whole minute.
    	reqTimeMinute := reqStartTime.Truncate(time.Minute)
    	if reqTimeMinute.After(h.currentMinute.statsTime) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
  9. internal/config/config.go

    	// Check if config param requested is valid.
    	defKVS, ok := DefaultKVS[subSys]
    	if !ok {
    		return
    	}
    
    	defValue, isFound := defKVS.Lookup(cfgParam)
    	// Comments usually are absent from `defKVS`, so we handle it specially.
    	if !isFound && cfgParam == Comment {
    		defValue, isFound = "", true
    	}
    	if !isFound {
    		return
    	}
    
    	if target == "" {
    		target = Default
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  10. internal/config/policy/plugin/config.go

    		// if the config param was found.
    		val, _, _ := s.ResolveConfigParam(config.PolicyPluginSubSys, config.Default, cfgParam, false)
    		return val
    	}
    
    	pluginURL := getCfg(URL)
    	if pluginURL == "" {
    		return args, nil
    	}
    
    	u, err := xnet.ParseHTTPURL(pluginURL)
    	if err != nil {
    		return args, err
    	}
    
    	enableHTTP2 := false
    	if v := getCfg(EnableHTTP2); v != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.8K bytes
    - Viewed (0)
Back to top