Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for SplitHostPort (0.12 sec)

  1. cmd/net.go

    	// IPv6 addresses of localhost.
    	localIP6 = mustGetLocalIP6()
    
    	// List of all local loopback addresses.
    	localLoopbacks = mustGetLocalLoopbacks()
    )
    
    // mustSplitHostPort is a wrapper to net.SplitHostPort() where error is assumed to be a fatal.
    func mustSplitHostPort(hostPort string) (host, port string) {
    	xh, err := xnet.ParseHost(hostPort)
    	if err != nil {
    		logger.FatalIf(err, "Unable to split host port %s", hostPort)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  2. cmd/endpoint.go

    			u.User == nil && u.Opaque == "" && !u.ForceQuery && u.RawQuery == "" && u.Fragment == "") {
    			return ep, fmt.Errorf("invalid URL endpoint format")
    		}
    
    		var port string
    		host, port, err = net.SplitHostPort(u.Host)
    		if err != nil {
    			if !strings.Contains(err.Error(), "missing port in address") {
    				return ep, fmt.Errorf("invalid URL endpoint format: %w", err)
    			}
    
    			host = u.Host
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			ip = "None"
    		}
    		workloadNames[ip] = s.Name + "." + s.Namespace
    	}
    	lookupIP := func(addr string) string {
    		if filter.Raw {
    			return addr
    		}
    		ip, port, _ := net.SplitHostPort(addr)
    		if s, f := serviceNames[ip]; f {
    			return net.JoinHostPort(s, port)
    		}
    		if w, f := workloadNames[ip]; f {
    			return net.JoinHostPort(w, port)
    		}
    		return addr
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 21:45:11 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. internal/http/dial_linux.go

    			if opts.UserTimeout > 0 {
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout)
    			}
    
    			if opts.Interface != "" {
    				if h, _, err := net.SplitHostPort(address); err == nil {
    					address = h
    				}
    				// Create socket on specific vrf device.
    				// To catch all kinds of special cases this filters specifically for loopback networks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/http-tracer.go

    			inputBytes += len(k) + len(v)
    		}
    
    		// Calculate node name
    		nodeName := r.Host
    		if globalIsDistErasure {
    			nodeName = globalLocalNodeName
    		}
    		if host, port, err := net.SplitHostPort(nodeName); err == nil {
    			if port == "443" || port == "80" {
    				nodeName = host
    			}
    		}
    
    		// Calculate reqPath
    		reqPath := r.URL.RawPath
    		if reqPath == "" {
    			reqPath = r.URL.Path
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/server-startup-msg.go

    	// Prints documentation message.
    	printObjectAPIMsg()
    	if globalIsDistErasure {
    		logger.Startup(color.Bold(banner))
    	}
    }
    
    // Returns true if input is IPv6
    func isIPv6(host string) bool {
    	h, _, err := net.SplitHostPort(host)
    	if err != nil {
    		h = host
    	}
    	ip := net.ParseIP(h)
    	return ip.To16() != nil && ip.To4() == nil
    }
    
    // strip api endpoints list with standard ports such as
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  7. internal/event/target/webhook.go

    		store:      queueStore,
    		cancel:     cancel,
    		cancelCh:   ctx.Done(),
    	}
    
    	// Calculate the webhook addr with the port number format
    	target.addr = args.Endpoint.Host
    	if _, _, err := net.SplitHostPort(args.Endpoint.Host); err != nil && strings.Contains(err.Error(), "missing port in address") {
    		switch strings.ToLower(args.Endpoint.Scheme) {
    		case "http":
    			target.addr += ":80"
    		case "https":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. internal/config/dns/etcd_dns.go

    		return nil, errors.New("invalid argument")
    	}
    
    	// strip ports off of domainIPs
    	domainIPsWithoutPorts := args.domainIPs.ApplyFunc(func(ip string) string {
    		host, _, err := net.SplitHostPort(ip)
    		if err != nil {
    			if strings.Contains(err.Error(), "missing port in address") {
    				host = ip
    			}
    		}
    		return host
    	})
    	args.domainIPs = domainIPsWithoutPorts
    
    	return args, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. cmd/sftp-server.go

    		if len(tokens) != 2 {
    			logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s", arg), "unable to start SFTP server")
    		}
    		switch tokens[0] {
    		case "address":
    			host, portStr, err := net.SplitHostPort(tokens[1])
    			if err != nil {
    				logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s (%v)", arg, err), "unable to start SFTP server")
    			}
    			port, err = strconv.Atoi(portStr)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
  10. cmd/api-router.go

    	for _, domainName := range globalDomainNames {
    		if IsKubernetes() {
    			routers = append(routers, apiRouter.MatcherFunc(func(r *http.Request, match *mux.RouteMatch) bool {
    				host, _, err := net.SplitHostPort(getHost(r))
    				if err != nil {
    					host = r.Host
    				}
    				// Make sure to skip matching minio.<domain>` this is
    				// specifically meant for operator/k8s deployment
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
Back to top