netx

type Handler interface {
	Handle(ctx context.Context, conn net.Conn)
}

type HandlerFunc func(context.Context, net.Conn)

type LoggingConn struct {
	net.Conn

	// RW is full conversation log.
	RW bytes.Buffer

	// R is read data.
	R bytes.Buffer

	// W is written data.
	W bytes.Buffer

	// onClose is called when connection is closed.
	// Must be used to get final conversation log.
	OnClose func()
	// contains filtered or unexported fields
}

type LoggingListener struct {
	net.Listener
}

type MaxBytesConn struct {
	net.Conn
	// contains filtered or unexported fields
}

type MaxBytesListener struct {
	net.Listener
	MaxBytes int64
}

type Server struct {
	Addr              string
	TLSConfig         *tls.Config
	NotifyStartedFunc func()
	ListenerWrapper   func(net.Listener) net.Listener // TODO: replace with handler
	Handler
}

type TimeoutConn struct {
	net.Conn
	// contains filtered or unexported fields
}

type TimeoutListener struct {
	net.Listener
	IdleTimeout time.Duration
}