direct

Mar 19, 2020

Changes in this version

+ func NewOutboundConnSession(conn io.ReadWriteCloser, req *protocol.Request) (protocol.ConnSession, error)

+ func NewOutboundPacketSession() (protocol.PacketSession, error)

+ type DirectOutboundConnSession struct

+ func (o *DirectOutboundConnSession) Close() error

+ func (o *DirectOutboundConnSession) Read(p []byte) (int, error)

+ func (o *DirectOutboundConnSession) Write(p []byte) (int, error)

+ type DirectOutboundPacketSession struct

+ func (o *DirectOutboundPacketSession) Close() error

+ func (o *DirectOutboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)

+ func (o *DirectOutboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)