nettool

Documentation

Index

• 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 NewConnectionSet
• type OnceCloseListener
  • func (oc *OnceCloseListener) Close() error

Functions

func ListenConfigWithOSTCPKeepAlive

func ListenConfigWithOSTCPKeepAlive() *net.ListenConfig

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 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