hysteria2

Documentation

Index

• Constants
• func NewSalamanderConn(conn net.PacketConn, password []byte) net.PacketConn
• type Client
  • func NewClient(options ClientOptions) (*Client, error)
  • func (c *Client) CloseWithError(err error) error
  • func (c *Client) DialConn(ctx context.Context, destination M.Socksaddr) (net.Conn, error)
  • func (c *Client) ListenPacket(ctx context.Context) (net.PacketConn, error)
• type ClientOptions
• type HopPacketConn
  • func NewHopPacketConn(dialFunc func(M.Socksaddr) (net.PacketConn, error), destination M.Socksaddr, ...) (*HopPacketConn, error)
  • func (c *HopPacketConn) Close() error
  • func (c *HopPacketConn) LocalAddr() net.Addr
  • func (c *HopPacketConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)
  • func (c *HopPacketConn) SetDeadline(t time.Time) error
  • func (c *HopPacketConn) SetReadBuffer(bytes int) error
  • func (c *HopPacketConn) SetReadDeadline(t time.Time) error
  • func (c *HopPacketConn) SetWriteBuffer(bytes int) error
  • func (c *HopPacketConn) SetWriteDeadline(t time.Time) error
  • func (c *HopPacketConn) SyscallConn() (syscall.RawConn, error)
  • func (c *HopPacketConn) WriteTo(b []byte, _ net.Addr) (n int, err error)
• type SalamanderPacketConn
  • func (s *SalamanderPacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (s *SalamanderPacketConn) Upstream() any
  • func (s *SalamanderPacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)
• type ServerHandler
• type Service
  • func NewService[U comparable](options ServiceOptions) (*Service[U], error)
  • func (s *Service[U]) Close() error
  • func (s *Service[U]) Start(conn net.PacketConn) error
  • func (s *Service[U]) UpdateUsers(userList []U, passwordList []string)
• type ServiceOptions
• type VectorisedSalamanderPacketConn
  • func (s *VectorisedSalamanderPacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)
  • func (s *VectorisedSalamanderPacketConn) WriteVectorisedPacket(buffers []*buf.Buffer, destination M.Socksaddr) error

Constants

const ObfsTypeSalamander = "salamander"

Functions

func NewSalamanderConn

func NewSalamanderConn(conn net.PacketConn, password []byte) net.PacketConn

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(options ClientOptions) (*Client, error)

func (*Client) CloseWithError

func (c *Client) CloseWithError(err error) error

func (*Client) DialConn

func (c *Client) DialConn(ctx context.Context, destination M.Socksaddr) (net.Conn, error)

func (*Client) ListenPacket

func (c *Client) ListenPacket(ctx context.Context) (net.PacketConn, error)

type ClientOptions

type ClientOptions struct {
	Context            context.Context
	Dialer             N.Dialer
	Logger             logger.Logger
	BrutalDebug        bool
	ServerAddress      M.Socksaddr
	ServerPorts        []string
	HopInterval        time.Duration
	SendBPS            uint64
	ReceiveBPS         uint64
	SalamanderPassword string
	Password           string
	TLSConfig          aTLS.Config
	UDPDisabled        bool
}

type HopPacketConn

type HopPacketConn struct {
	// contains filtered or unexported fields
}

func NewHopPacketConn

func NewHopPacketConn(
	dialFunc func(M.Socksaddr) (net.PacketConn, error),
	destination M.Socksaddr,
	ports []uint16,
	interval time.Duration,
) (*HopPacketConn, error)

func (*HopPacketConn) Close

func (c *HopPacketConn) Close() error

func (*HopPacketConn) LocalAddr

func (c *HopPacketConn) LocalAddr() net.Addr

func (*HopPacketConn) ReadFrom

func (c *HopPacketConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)

func (*HopPacketConn) SetDeadline

func (c *HopPacketConn) SetDeadline(t time.Time) error

func (*HopPacketConn) SetReadBuffer

func (c *HopPacketConn) SetReadBuffer(bytes int) error

func (*HopPacketConn) SetReadDeadline

func (c *HopPacketConn) SetReadDeadline(t time.Time) error

func (*HopPacketConn) SetWriteBuffer

func (c *HopPacketConn) SetWriteBuffer(bytes int) error

func (*HopPacketConn) SetWriteDeadline

func (c *HopPacketConn) SetWriteDeadline(t time.Time) error

func (*HopPacketConn) SyscallConn

func (c *HopPacketConn) SyscallConn() (syscall.RawConn, error)

func (*HopPacketConn) WriteTo

func (c *HopPacketConn) WriteTo(b []byte, _ net.Addr) (n int, err error)

type SalamanderPacketConn

type SalamanderPacketConn struct {
	net.PacketConn
	// contains filtered or unexported fields
}

func (*SalamanderPacketConn) ReadFrom

func (s *SalamanderPacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

func (*SalamanderPacketConn) Upstream

func (s *SalamanderPacketConn) Upstream() any

func (*SalamanderPacketConn) WriteTo

func (s *SalamanderPacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

type ServerHandler

type ServerHandler interface {
	N.TCPConnectionHandlerEx
	N.UDPConnectionHandlerEx
}

type Service

type Service[U comparable] struct {
	// contains filtered or unexported fields
}

func NewService

func NewService[U comparable](options ServiceOptions) (*Service[U], error)

func (*Service[U]) Close

func (s *Service[U]) Close() error

func (*Service[U]) Start

func (s *Service[U]) Start(conn net.PacketConn) error

func (*Service[U]) UpdateUsers

func (s *Service[U]) UpdateUsers(userList []U, passwordList []string)

type ServiceOptions

type ServiceOptions struct {
	Context               context.Context
	Logger                logger.Logger
	BrutalDebug           bool
	SendBPS               uint64
	ReceiveBPS            uint64
	IgnoreClientBandwidth bool
	SalamanderPassword    string
	TLSConfig             aTLS.ServerConfig
	UDPDisabled           bool
	UDPTimeout            time.Duration
	Handler               ServerHandler
	MasqueradeHandler     http.Handler
}

type VectorisedSalamanderPacketConn

type VectorisedSalamanderPacketConn struct {
	SalamanderPacketConn
	// contains filtered or unexported fields
}

func (*VectorisedSalamanderPacketConn) WriteTo

func (s *VectorisedSalamanderPacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

func (*VectorisedSalamanderPacketConn) WriteVectorisedPacket

func (s *VectorisedSalamanderPacketConn) WriteVectorisedPacket(buffers []*buf.Buffer, destination M.Socksaddr) error