Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Leifer (0.18 sec)

  1. internal/config/identity/plugin/config.go

    	currentMinute    serviceRTTMinuteStats
    }
    
    func (h *metrics) setConnSuccess(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckSuccess = reqStartTime
    }
    
    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
  2. internal/config/policy/opa/config.go

    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    	client := &http.Client{Transport: a.Transport}
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer a.CloseRespFn(resp.Body)
    
    	return nil
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (a *Args) UnmarshalJSON(data []byte) error {
    	// subtype to avoid recursive call to UnmarshalJSON()
    	type subArgs Args
    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)
  3. internal/config/policy/plugin/config.go

    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    	client := &http.Client{Transport: a.Transport}
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer a.CloseRespFn(resp.Body)
    
    	return nil
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (a *Args) UnmarshalJSON(data []byte) error {
    	// subtype to avoid recursive call to UnmarshalJSON()
    	type subArgs Args
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  4. internal/config/config.go

    	}
    
    	if redactSecrets {
    		// If the configuration parameter is a secret, make sure to redact it when
    		// we return.
    		helpKV, _ := HelpSubSysMap[subSys].Lookup(cfgParam)
    		if helpKV.Secret {
    			defer func() {
    				value = ""
    				isRedacted = true
    			}()
    		}
    	}
    
    	envVar := getEnvVarName(subSys, target, cfgParam)
    
    	// Lookup Env var.
    	value = env.Get(envVar, "")
    	if value != "" {
    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)
  5. internal/config/subnet/config.go

    // Registered indicates if cluster is registered or not
    func (c *Config) Registered() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return len(c.APIKey) > 0
    }
    
    // ApplyEnv - applies the current subnet config to Console UI specific environment variables.
    func (c *Config) ApplyEnv() {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.License != "" {
    		os.Setenv("CONSOLE_SUBNET_LICENSE", c.License)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  6. cmd/config.go

    	return &ConfigSys{}
    }
    
    // Initialize and load config from remote etcd or local config directory
    func initConfig(objAPI ObjectLayer) (err error) {
    	bootstrapTraceMsg("load the configuration")
    	defer func() {
    		if err != nil {
    			bootstrapTraceMsg(fmt.Sprintf("loading configuration failed: %v", err))
    		}
    	}()
    
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top