Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Addrs (0.02 sec)

  1. internal/http/server_test.go

    		server := NewServer(testCase.addrs).
    			UseHandler(testCase.handler)
    		if testCase.certFn != nil {
    			server = server.UseTLSConfig(&tls.Config{
    				PreferServerCipherSuites: true,
    				GetCertificate:           testCase.certFn,
    			})
    		}
    		if server == nil {
    			t.Fatalf("Case %v: server: expected: <non-nil>, got: <nil>", (i + 1))
    		} else if !reflect.DeepEqual(server.Addrs, testCase.addrs) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. internal/http/listener.go

    		tcpAddr.IP = ip
    	}
    
    	addr = tcpAddr
    	return addr
    }
    
    // Addrs - returns all address information of TCP listeners.
    func (listener *httpListener) Addrs() (addrs []net.Addr) {
    	for i := range listener.listeners {
    		addrs = append(addrs, listener.listeners[i].Addr())
    	}
    
    	return addrs
    }
    
    // TCPOptions specify customizable TCP optimizations on raw socket
    type TCPOptions struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/endpoint.go

    }
    
    func retrieveEndpointAddresses(ep *endpoint.LbEndpoint) []string {
    	addrs := []*core.Address{ep.GetEndpoint().GetAddress()}
    	for _, a := range ep.GetEndpoint().GetAdditionalAddresses() {
    		addrs = append(addrs, a.GetAddress())
    	}
    	result := make([]string, 0, len(addrs))
    	for _, addr := range addrs {
    		if addr := addr.GetSocketAddress(); addr != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 09:57:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. internal/http/server.go

    func (srv *Server) UseTCPOptions(opts TCPOptions) *Server {
    	srv.TCPOptions = opts
    	return srv
    }
    
    // NewServer - creates new HTTP server using given arguments.
    func NewServer(addrs []string) *Server {
    	httpServer := &Server{
    		Addrs: addrs,
    	}
    	// This is not configurable for now.
    	httpServer.MaxHeaderBytes = DefaultMaxHeaderBytes
    	return httpServer
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. internal/http/listener_test.go

    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    		}
    
    		addrs := listener.Addrs()
    		addrSet := set.NewStringSet()
    		for _, addr := range addrs {
    			addrSet.Add(addr.String())
    		}
    
    		if !addrSet.Equals(testCase.expectedAddrs) {
    			t.Fatalf("Test %d: addr: expected = %v, got = %v", i+1, testCase.expectedAddrs, addrs)
    		}
    
    		listener.Close()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. cni/pkg/repair/netns.go

    	if interfaces, err = net.Interfaces(); err != nil {
    		return false, fmt.Errorf("failed to get interfaces")
    	}
    
    	for _, ief := range interfaces {
    		var addrs []net.Addr
    		if addrs, err = ief.Addrs(); err != nil {
    			return
    		}
    		for _, addr := range addrs {
    			switch v := addr.(type) {
    			case *net.IPNet:
    				if v.IP.Equal(targetAddr) {
    					return true, nil
    				}
    			}
    		}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. cmd/net.go

    	ifs, err := net.Interfaces()
    	logger.FatalIf(err, "Unable to get IP addresses of this host")
    
    	for _, interf := range ifs {
    		addrs, err := interf.Addrs()
    		if err != nil {
    			continue
    		}
    		if runtime.GOOS == "windows" && interf.Flags&net.FlagUp == 0 {
    			continue
    		}
    
    		for _, addr := range addrs {
    			var ip net.IP
    			switch v := addr.(type) {
    			case *net.IPNet:
    				ip = v.IP
    			case *net.IPAddr:
    				ip = v.IP
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  8. cmd/server-main.go

    		if err == nil {
    			for _, addr := range haddrs {
    				addrs.Add(net.JoinHostPort(addr, globalMinioPort))
    			}
    		} else {
    			// Unable to lookup host in 2-secs, let it fail later anyways.
    			addrs.Add(globalMinioAddr)
    		}
    	} else {
    		addrs.Add(globalMinioAddr)
    	}
    	return addrs.ToSlice()
    }
    
    var globalLoggerOutput io.WriteCloser
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  9. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    
    	return ""
    }
    
    func retrieveListenerAdditionalAddresses(l *listener.Listener) []string {
    	var addrs []string
    	socketAddresses := l.GetAdditionalAddresses()
    	for _, socketAddr := range socketAddresses {
    		addr := socketAddr.Address
    		addrs = append(addrs, addr.GetSocketAddress().Address)
    	}
    
    	return addrs
    }
    
    func retrieveListenerPort(l *listener.Listener) uint32 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  10. cmd/common-main.go

    			if net.ParseIP(endpoint) == nil {
    				// Checking if the IP is a DNS entry.
    				addrs, err := globalDNSCache.LookupHost(GlobalContext, endpoint)
    				if err != nil {
    					logger.FatalIf(err, "Unable to initialize MinIO server with [%s] invalid entry found in MINIO_PUBLIC_IPS", endpoint)
    				}
    				for _, addr := range addrs {
    					domainIPs.Add(addr)
    				}
    			}
    			domainIPs.Add(endpoint)
    		}
    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