Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for ParseHTTPURL (0.14 sec)

  1. internal/logger/config.go

    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    				continue
    			}
    			url, err := xnet.ParseHTTPURL(endpoint)
    			if err != nil {
    				LogOnceIf(ctx, "logging", err, "logger-webhook-"+endpoint)
    				continue
    			}
    			cfg.HTTP[target] = http.Config{
    				Enabled:  true,
    				Endpoint: url,
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. internal/config/identity/openid/jwt_test.go

    		},
    	}
    
    	token, err := jwt.SignedString([]byte("WNGvKVyyNmXq0TraSvjaDN9CtpFgx35IXtGEffMCPR0"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	fmt.Println(token)
    
    	u1, err := xnet.ParseHTTPURL(server.URL)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	pubKeys := publicKeys{
    		RWMutex: &sync.RWMutex{},
    		pkMap:   map[string]interface{}{},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. internal/config/etcd/etcd.go

    func parseEndpoints(endpoints string) ([]string, bool, error) {
    	etcdEndpoints := strings.Split(endpoints, config.ValueSeparator)
    
    	var etcdSecure bool
    	for _, endpoint := range etcdEndpoints {
    		u, err := xnet.ParseHTTPURL(endpoint)
    		if err != nil {
    			return nil, false, err
    		}
    		if etcdSecure && u.Scheme == "http" {
    			return nil, false, config.Errorf("all endpoints should be https or http: %s", endpoint)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. internal/config/policy/plugin/config.go

    		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 != "" {
    		enableHTTP2, err = config.ParseBool(v)
    		if err != nil {
    			return args, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. internal/config/subnet/config.go

    		return cfg, err
    	}
    
    	var proxyURL *xnet.URL
    	proxy := env.Get(config.EnvMinIOSubnetProxy, kvs.Get(config.Proxy))
    	if len(proxy) > 0 {
    		proxyURL, err = xnet.ParseHTTPURL(proxy)
    		if err != nil {
    			return cfg, err
    		}
    
    	}
    
    	cfg.License = strings.TrimSpace(env.Get(config.EnvMinIOSubnetLicense, kvs.Get(config.License)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. internal/config/policy/opa/config.go

    		if opaURL == "" {
    			return args, nil
    		}
    	}
    	authToken := env.Get(EnvIamOpaAuthToken, "")
    	if authToken == "" {
    		authToken = env.Get(EnvPolicyOpaAuthToken, kv.Get(AuthToken))
    	}
    
    	u, err := xnet.ParseHTTPURL(opaURL)
    	if err != nil {
    		return args, err
    	}
    	args = Args{
    		URL:         u,
    		AuthToken:   authToken,
    		Transport:   transport,
    		CloseRespFn: closeRespFn,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. internal/config/identity/openid/openid.go

    		if seenClientIDs.Contains(p.ClientID) {
    			return c, config.Errorf("Client ID %s is present with multiple OpenID configurations", p.ClientID)
    		}
    		seenClientIDs.Add(p.ClientID)
    
    		p.URL, err = xnet.ParseHTTPURL(configURL)
    		if err != nil {
    			return c, err
    		}
    		configURLDomain := p.URL.Hostname()
    		p.DiscoveryDoc, err = parseDiscoveryDoc(p.URL, transport, closeRespFn)
    		if err != nil {
    			return c, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. cmd/server-startup-msg.go

    		return apiEndpoints
    	}
    	newAPIEndpoints = make([]string, len(apiEndpoints))
    	// Check all API endpoints for standard ports and strip them.
    	for i, apiEndpoint := range apiEndpoints {
    		_, err := xnet.ParseHTTPURL(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		u, err := url.Parse(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		if host == "" && isIPv6(u.Hostname()) {
    			// Skip all IPv6 endpoints
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. internal/config/lambda/parse.go

    			return nil, err
    		}
    		if !enabled {
    			continue
    		}
    		urlEnv := target.EnvWebhookEndpoint
    		if k != config.Default {
    			urlEnv = urlEnv + config.Default + k
    		}
    		url, err := xnet.ParseHTTPURL(env.Get(urlEnv, kv.Get(target.WebhookEndpoint)))
    		if err != nil {
    			return nil, err
    		}
    		authEnv := target.EnvWebhookAuthToken
    		if k != config.Default {
    			authEnv = authEnv + config.Default + k
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. cmd/common-main.go

    	}
    }
    
    func serverHandleEnvVars() {
    	var err error
    	if globalBrowserEnabled {
    		if redirectURL := env.Get(config.EnvBrowserRedirectURL, ""); redirectURL != "" {
    			u, err := xnet.ParseHTTPURL(redirectURL)
    			if err != nil {
    				logger.Fatal(err, "Invalid MINIO_BROWSER_REDIRECT_URL value in environment variable")
    			}
    			// Look for if URL has invalid values and return error.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
Back to top