Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Content (0.29 sec)

  1. internal/logger/config.go

    	if key != config.Default {
    		envName = envName + config.Default + key
    	}
    	return env.Get(envName, defaultValue)
    }
    
    func lookupLegacyConfigForSubSys(ctx context.Context, subSys string) Config {
    	cfg := NewConfig()
    	switch subSys {
    	case config.LoggerWebhookSubSys:
    		var loggerTargets []string
    		envs := env.List(legacyEnvLoggerHTTPEndpoint)
    		for _, k := range envs {
    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)
  2. internal/config/policy/opa/config.go

    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	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
    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)
  3. internal/config/identity/plugin/config.go

    		o.args.RoleARN: o.args.RolePolicy,
    	}
    }
    
    // checkConnectivity returns true if we are able to connect to the plugin
    // service.
    func (o *AuthNPlugin) checkConnectivity(ctx context.Context) bool {
    	ctx, cancel := context.WithTimeout(ctx, healthCheckTimeout)
    	defer cancel()
    	u := url.URL(*o.args.URL)
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodHead, u.String(), nil)
    	if err != nil {
    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)
  4. internal/config/policy/plugin/config.go

    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	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
    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)
  5. cmd/config.go

    	return err
    }
    
    func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) {
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix)
    	data, err := readConfig(ctx, objAPI, historyFile)
    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
  6. internal/config/config.go

    		if err != nil {
    			return nil, err
    		}
    		ids[tgt] = true
    	}
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    	return
    }
    
    // ReadConfig - read content from input and write into c.
    // Returns whether all parameters were dynamic.
    func (c Config) ReadConfig(r io.Reader) (dynOnly bool, err error) {
    	var n int
    	scanner := bufio.NewScanner(r)
    	dynOnly = true
    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)
Back to top