Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for laddr (0.24 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener.go

    		if iPort != jPort {
    			return iPort < jPort
    		}
    		iAddr := retrieveListenerAddress(listeners[i])
    		jAddr := retrieveListenerAddress(listeners[j])
    		if iAddr != jAddr {
    			return iAddr < jAddr
    		}
    		iType := retrieveListenerType(listeners[i])
    		jType := retrieveListenerType(listeners[j])
    		return iType < jType
    	})
    
    	fmt.Fprintln(w, "LISTENER\tCHAIN\tMATCH\tDESTINATION")
    	for _, l := range listeners {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  2. internal/http/listener.go

    		listener.listeners[i].Close()
    	}
    
    	return nil
    }
    
    // Addr - net.Listener interface compatible method returns net.Addr.  In case of multiple TCP listeners, it returns '0.0.0.0' as IP address.
    func (listener *httpListener) Addr() (addr net.Addr) {
    	addr = listener.listeners[0].Addr()
    	if len(listener.listeners) == 1 {
    		return addr
    	}
    
    	tcpAddr := addr.(*net.TCPAddr)
    	if ip := net.ParseIP("0.0.0.0"); ip != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/clusters/clusters.go

    	}
    	c.clusters = &cd
    	return nil
    }
    
    func retrieveEndpointAddress(host *admin.HostStatus) string {
    	addr := host.Address.GetSocketAddress()
    	if addr != nil {
    		return addr.Address
    	}
    	if pipe := host.Address.GetPipe(); pipe != nil {
    		return "unix://" + pipe.Path
    	}
    	if internal := host.Address.GetEnvoyInternalAddress(); internal != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  4. cmd/net.go

    	u, err := url.Parse(hostAddr)
    	if err != nil {
    		return "", "", err
    	}
    
    	addr = u.Host
    	scheme = u.Scheme
    
    	// Use the given parameter again if url.Parse()
    	// didn't return any useful result.
    	if addr == "" {
    		addr = hostAddr
    		scheme = "http"
    	}
    
    	// At this point, addr can be one of the following form:
    	//	":9000"
    	//	"localhost:9000"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  5. internal/handlers/proxy.go

    	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.
    func GetSourceIP(r *http.Request) string {
    	addr := GetSourceIPRaw(r)
    	if strings.ContainsRune(addr, ':') {
    		return "[" + addr + "]"
    	}
    	return addr
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  6. internal/grid/debug.go

    			}
    		}
    		addr := l.Addr()
    		hosts = append(hosts, "http://"+addr.String())
    		listeners = append(listeners, l)
    	}
    	return
    }
    
    func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) {
    	server = httptest.NewUnstartedServer(handler)
    	server.Config.Addr = listener.Addr().String()
    	server.Listener = listener
    	server.Start()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. src/cmd/addr2line/addr2line_test.go

    	if err := scanner.Err(); err != nil {
    		t.Fatalf("error reading symbols: %v", err)
    	}
    	return syms
    }
    
    func runAddr2Line(t *testing.T, dbgExePath, addr string) (funcname, path, lineno string) {
    	cmd := testenv.Command(t, addr2linePath(t), dbgExePath)
    	cmd.Stdin = strings.NewReader(addr)
    	out, err := cmd.CombinedOutput()
    	if err != nil {
    		t.Fatalf("go tool addr2line %v: %v\n%s", os.Args[0], err, string(out))
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Feb 21 22:16:54 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  8. internal/http/dial_dnscache.go

    		}).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)
    		}
    
    		ips, err := lookupHost(ctx, host)
    		if err != nil {
    			return nil, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  9. callbacks/associations.go

    						if _, zero := rel.Field.ValueOf(db.Statement.Context, obj); !zero { // check belongs to relation value
    							rv := rel.Field.ReflectValueOf(db.Statement.Context, obj) // relation reflect value
    							if !isPtr {
    								rv = rv.Addr()
    							}
    							objs = append(objs, obj)
    							elems = reflect.Append(elems, rv)
    
    							relPrimaryValues := make([]interface{}, 0, len(rel.FieldSchema.PrimaryFields))
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Apr 11 03:06:13 GMT 2023
    - 14.3K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/server_test.go

    			Namespace: "test",
    			UID:       types.UID("test"),
    		},
    	}
    
    	fakeCtx := context.Background()
    	fakeClientSet := fake.NewSimpleClientset(pod)
    
    	podIP := netip.MustParseAddr("99.9.9.1")
    	podIPs := []netip.Addr{podIP}
    
    	server := &fakeServer{}
    	server.On("AddPodToMesh",
    		fakeCtx,
    		pod,
    		podIPs,
    		"",
    	).Return(nil)
    
    	server.Start(fakeCtx)
    	m := meshDataplane{
    		kubeClient: fakeClientSet,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
Back to top