- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for SplitHostPort (0.19 sec)
-
internal/handlers/forwarder.go
func ipv6fix(clientIP string) string { return strings.Split(clientIP, "%")[0] } func (rw *headerRewriter) Rewrite(req *http.Request) { if clientIP, _, err := net.SplitHostPort(req.RemoteAddr); err == nil { clientIP = ipv6fix(clientIP) if req.Header.Get(xRealIP) == "" { req.Header.Set(xRealIP, clientIP) } } xfProto := req.Header.Get(xForwardedProto)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
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) -
internal/http/dial_dnscache.go
Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }).DialContext } return func(ctx context.Context, network, addr string) (conn net.Conn, err error) { host, port, err := net.SplitHostPort(addr) if err != nil { return nil, err } if net.ParseIP(host) != nil { // For IP only setups there is no need for DNS lookups. return baseDialCtx(ctx, "tcp", addr) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 03 19:30:51 UTC 2023 - 2.6K bytes - Viewed (0) -
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) -
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) -
internal/handlers/proxy.go
func GetSourceIPRaw(r *http.Request) string { addr := GetSourceIPFromHeaders(r) if addr == "" { addr = r.RemoteAddr } // Default to remote address if headers not set. raddr, _, _ := net.SplitHostPort(addr) if raddr == "" { return addr } return raddr } // GetSourceIP retrieves the IP from the request headers // and falls back to r.RemoteAddr when necessary.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:55 UTC 2023 - 5.1K bytes - Viewed (0) -
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) -
cmd/ftp-server.go
if len(tokens) != 2 { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s", arg), "unable to start FTP server") } switch tokens[0] { case "address": host, portStr, err := net.SplitHostPort(tokens[1]) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server") } port, err = strconv.Atoi(portStr) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Mar 09 03:07:08 UTC 2024 - 4.8K bytes - Viewed (0) -
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) -
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)