Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for ParseHTTPURL (0.21 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,
    			}
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K 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{}{},
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  3. 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)))
    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)
  4. 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,
    	}
    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)
  5. 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
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. 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)
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  7. 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
    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)
  8. 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
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  9. 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
    			continue
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  10. cmd/storage-rest_test.go

    	prevHost, prevPort := globalMinioHost, globalMinioPort
    	defer func() {
    		globalMinioHost, globalMinioPort = prevHost, prevPort
    	}()
    	// tg[0] = local, tg[1] = remote
    
    	// Remote URL
    	url, err := xnet.ParseHTTPURL(tg.Servers[1].URL)
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	url.Path = t.TempDir()
    
    	globalMinioHost, globalMinioPort = mustSplitHostPort(url.Host)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.4K bytes
    - Viewed (0)
Back to top