direct

Documentation

Index

• func NewOutboundConnSession(conn io.ReadWriteCloser, req *protocol.Request) (protocol.ConnSession, error)
• func NewOutboundPacketSession() (protocol.PacketSession, error)
• type DirectOutboundConnSession
  • func (o *DirectOutboundConnSession) Close() error
  • func (o *DirectOutboundConnSession) Read(p []byte) (int, error)
  • func (o *DirectOutboundConnSession) Write(p []byte) (int, error)
• type DirectOutboundPacketSession
  • func (o *DirectOutboundPacketSession) Close() error
  • func (o *DirectOutboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)
  • func (o *DirectOutboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)

Functions

func NewOutboundConnSession

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

func NewOutboundPacketSession

func NewOutboundPacketSession() (protocol.PacketSession, error)

Types

type DirectOutboundConnSession

type DirectOutboundConnSession struct {
	protocol.ConnSession
	// contains filtered or unexported fields
}

func (*DirectOutboundConnSession) Close

func (o *DirectOutboundConnSession) Close() error

func (*DirectOutboundConnSession) Read

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

func (*DirectOutboundConnSession) Write

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

type DirectOutboundPacketSession

type DirectOutboundPacketSession struct {
	protocol.PacketSession
	// contains filtered or unexported fields
}

func (*DirectOutboundPacketSession) Close

func (o *DirectOutboundPacketSession) Close() error

func (*DirectOutboundPacketSession) ReadPacket

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

func (*DirectOutboundPacketSession) WritePacket

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