trojan

Documentation

Index

• func NewInboundConnSession(ctx context.Context, conn net.Conn, config *conf.GlobalConfig, ...) (protocol.ConnSession, *protocol.Request, error)
• func NewInboundObfReadWriteCloser(key []byte, conn net.Conn) (*obfReadWriteCloser, error)
• func NewInboundWebsocket(ctx context.Context, conn net.Conn, config *conf.GlobalConfig, ...) (io.ReadWriteCloser, error)
• func NewOutboundConnSession(req *protocol.Request, rwc io.ReadWriteCloser, config *conf.GlobalConfig, ...) (protocol.ConnSession, error)
• func NewOutboundObfReadWriteCloser(key []byte, conn net.Conn) *obfReadWriteCloser
• func NewOutboundWebosocket(conn net.Conn, config *conf.GlobalConfig) (io.ReadWriteCloser, error)
• func NewPacketSession(conn io.ReadWriteCloser) (protocol.PacketSession, error)
• type TrojanInboundConnSession
  • func (i *TrojanInboundConnSession) Close() error
  • func (i *TrojanInboundConnSession) Read(p []byte) (int, error)
  • func (i *TrojanInboundConnSession) SetMeter(meter stat.TrafficMeter)
  • func (i *TrojanInboundConnSession) Write(p []byte) (int, error)
• type TrojanOutboundConnSession
  • func (o *TrojanOutboundConnSession) Close() error
  • func (o *TrojanOutboundConnSession) Read(p []byte) (int, error)
  • func (o *TrojanOutboundConnSession) SetMeter(meter stat.TrafficMeter)
  • func (o *TrojanOutboundConnSession) Write(p []byte) (int, error)
• type TrojanPacketSession
  • func (i *TrojanPacketSession) Close() error
  • func (i *TrojanPacketSession) ReadPacket() (*protocol.Request, []byte, error)
  • func (i *TrojanPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)

Functions

func NewInboundConnSession

func NewInboundConnSession(ctx context.Context, conn net.Conn, config *conf.GlobalConfig, auth stat.Authenticator, shadowMan *shadow.ShadowManager) (protocol.ConnSession, *protocol.Request, error)

func NewInboundObfReadWriteCloser

func NewInboundObfReadWriteCloser(key []byte, conn net.Conn) (*obfReadWriteCloser, error)

func NewInboundWebsocket

func NewInboundWebsocket(ctx context.Context, conn net.Conn, config *conf.GlobalConfig, shadowMan *shadow.ShadowManager) (io.ReadWriteCloser, error)

func NewOutboundConnSession

func NewOutboundConnSession(req *protocol.Request, rwc io.ReadWriteCloser, config *conf.GlobalConfig, auth stat.Authenticator) (protocol.ConnSession, error)

func NewOutboundObfReadWriteCloser

func NewOutboundObfReadWriteCloser(key []byte, conn net.Conn) *obfReadWriteCloser

func NewOutboundWebosocket

func NewOutboundWebosocket(conn net.Conn, config *conf.GlobalConfig) (io.ReadWriteCloser, error)

func NewPacketSession

func NewPacketSession(conn io.ReadWriteCloser) (protocol.PacketSession, error)

Types

type TrojanInboundConnSession

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

func (*TrojanInboundConnSession) Close

func (i *TrojanInboundConnSession) Close() error

func (*TrojanInboundConnSession) Read

func (i *TrojanInboundConnSession) Read(p []byte) (int, error)

func (*TrojanInboundConnSession) SetMeter

func (i *TrojanInboundConnSession) SetMeter(meter stat.TrafficMeter)

func (*TrojanInboundConnSession) Write

func (i *TrojanInboundConnSession) Write(p []byte) (int, error)

type TrojanOutboundConnSession

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

func (*TrojanOutboundConnSession) Close

func (o *TrojanOutboundConnSession) Close() error

func (*TrojanOutboundConnSession) Read

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

func (*TrojanOutboundConnSession) SetMeter

func (o *TrojanOutboundConnSession) SetMeter(meter stat.TrafficMeter)

func (*TrojanOutboundConnSession) Write

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

type TrojanPacketSession

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

func (*TrojanPacketSession) Close

func (i *TrojanPacketSession) Close() error

func (*TrojanPacketSession) ReadPacket

func (i *TrojanPacketSession) ReadPacket() (*protocol.Request, []byte, error)

func (*TrojanPacketSession) WritePacket

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