nettool

Documentation

Index

• func IP2Addr(ip net.IP) (netip.Addr, bool)
• func IsEqualMultiURL(a, b MultiURL) bool
• func ListenConfigWithOSTCPKeepAlive() *net.ListenConfig
• func ListenWithOSTCPKeepAlive(network, address string) (net.Listener, error)
• func TLSListenWithOSTCPKeepAlive(network, laddr string, config *tls.Config) (net.Listener, error)
• type ConnectionSet
• type ListenerMetrics
  • func (m *ListenerMetrics) RunGC(ctx context.Context)
  • func (m *ListenerMetrics) Wrap(l net.Listener, name string, ttl time.Duration) (net.Listener, error)
• type LookupIPAddr
• type MultiURL
  • func MultiURLFromURL(ctx context.Context, u *url.URL, resolve LookupIPAddr) (MultiURL, error)
  • func NewMultiURL(scheme string, addresses []netip.Addr, port uint16) MultiURL
  • func ParseMultiURL(addr string) (MultiURL, error)
  • func ParseURL(ctx context.Context, addr string, resolve LookupIPAddr) (MultiURL, error)
  • func (u MultiURL) Addresses() []netip.Addr
  • func (u MultiURL) Port() uint16
  • func (u MultiURL) Scheme() string
  • func (u MultiURL) String() string
• type NewConnectionSet
• type OnceCloseListener
  • func (oc *OnceCloseListener) Close() error

Functions

func IP2Addr

func IP2Addr(ip net.IP) (netip.Addr, bool)

func IsEqualMultiURL

func IsEqualMultiURL(a, b MultiURL) bool

func ListenConfigWithOSTCPKeepAlive

func ListenConfigWithOSTCPKeepAlive() *net.ListenConfig

ListenConfigWithOSTCPKeepAlive return a net.ListeConfig with OS-level KeepAlive settings.

func ListenWithOSTCPKeepAlive

func ListenWithOSTCPKeepAlive(network, address string) (net.Listener, error)

func TLSListenWithOSTCPKeepAlive

func TLSListenWithOSTCPKeepAlive(network, laddr string, config *tls.Config) (net.Listener, error)

Types

type ConnectionSet

type ConnectionSet interface {
	Set(connID int64) error
	Unset(connID int64) error
	GC(context.Context) error
}

type ListenerMetrics

type ListenerMetrics struct {
	Log      *slog.Logger
	NewSet   NewConnectionSet
	GCPeriod time.Duration
	ErrRep   errz.ErrReporter
	// contains filtered or unexported fields
}

func (*ListenerMetrics) RunGC

func (m *ListenerMetrics) RunGC(ctx context.Context)

func (*ListenerMetrics) Wrap

func (m *ListenerMetrics) Wrap(l net.Listener, name string, ttl time.Duration) (net.Listener, error)

Wrap wraps the provided listener. Can be called concurrently.

type LookupIPAddr

type LookupIPAddr func(ctx context.Context, host string) ([]net.IPAddr, error)

type MultiURL

type MultiURL struct {
	// contains filtered or unexported fields
}

MultiURL is an immutable URL that has scheme, port, and one or more IP addresses.

func MultiURLFromURL

func MultiURLFromURL(ctx context.Context, u *url.URL, resolve LookupIPAddr) (MultiURL, error)

MultiURLFromURL turns a URL into a MultiURL. The provided URL must: - not be an opaque. - have a scheme. - host must be an IP address or a domain to be resolved. - have a port. Context is used for DNS resolution when resolve is provided and the host is not an IP address.

func NewMultiURL

func NewMultiURL(scheme string, addresses []netip.Addr, port uint16) MultiURL

func ParseMultiURL

func ParseMultiURL(addr string) (MultiURL, error)

ParseMultiURL parses addr according to the following opaque URL schema: scheme:ip[,ip]|port

func ParseURL

func ParseURL(ctx context.Context, addr string, resolve LookupIPAddr) (MultiURL, error)

ParseURL turns a URL into a MultiURL. See MultiURLFromURL.

func (MultiURL) Addresses

func (u MultiURL) Addresses() []netip.Addr

func (MultiURL) Port

func (u MultiURL) Port() uint16

func (MultiURL) Scheme

func (u MultiURL) Scheme() string

func (MultiURL) String

func (u MultiURL) String() string

type NewConnectionSet

type NewConnectionSet func(name string, ttl time.Duration) (ConnectionSet, error)

type OnceCloseListener

type OnceCloseListener struct {
	net.Listener
	// contains filtered or unexported fields
}

OnceCloseListener wraps a net.Listener, protecting it from multiple Close calls.

func (*OnceCloseListener) Close

func (oc *OnceCloseListener) Close() error