hysteria2

Documentation

Index

• Variables
• func QuicLen(s int) int
• type Account
  • func (a *Account) AsAccount() (protocol.Account, error)
  • func (*Account) Descriptor() ([]byte, []int)
  • func (*Account) ProtoMessage()
  • func (x *Account) ProtoReflect() protoreflect.Message
  • func (x *Account) Reset()
  • func (x *Account) String() string
• type Client
  • func NewClient(ctx context.Context, config *ClientConfig) (*Client, error)
  • func (c *Client) Process(ctx context.Context, link *transport.Link, dialer internet.Dialer) error
• type ClientConfig
  • func (*ClientConfig) Descriptor() ([]byte, []int)
  • func (x *ClientConfig) GetServer() []*protocol.ServerEndpoint
  • func (*ClientConfig) ProtoMessage()
  • func (x *ClientConfig) ProtoReflect() protoreflect.Message
  • func (x *ClientConfig) Reset()
  • func (x *ClientConfig) String() string
• type ConnReader
  • func (c *ConnReader) Read(p []byte) (int, error)
  • func (c *ConnReader) ReadMultiBuffer() (buf.MultiBuffer, error)
• type ConnWriter
  • func (c *ConnWriter) Write(p []byte) (n int, err error)
  • func (c *ConnWriter) WriteMultiBuffer(mb buf.MultiBuffer) error
  • func (c *ConnWriter) WriteTCPHeader() error
• type MemoryAccount
  • func (a *MemoryAccount) Equals(another protocol.Account) bool
• type PacketConnectionReader
  • func (r *PacketConnectionReader) ReadFrom(p []byte) (n int, addr net.Addr, err error)
• type PacketPayload
• type PacketReader
  • func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error)
  • func (r *PacketReader) ReadMultiBufferWithMetadata() (*PacketPayload, error)
• type PacketWriter
  • func (w *PacketWriter) WriteMultiBuffer(mb buf.MultiBuffer) error
  • func (w *PacketWriter) WriteMultiBufferWithMetadata(mb buf.MultiBuffer, dest net.Destination) error
  • func (w *PacketWriter) WriteTo(payload []byte, addr net.Addr) (int, error)
• type Server
  • func NewServer(ctx context.Context, config *ServerConfig) (*Server, error)
  • func (s *Server) Network() []net.Network
  • func (s *Server) Process(ctx context.Context, network net.Network, conn internet.Connection, ...) error
• type ServerConfig
  • func (*ServerConfig) Descriptor() ([]byte, []int)
  • func (x *ServerConfig) GetPacketEncoding() packetaddr.PacketAddrType
  • func (*ServerConfig) ProtoMessage()
  • func (x *ServerConfig) ProtoReflect() protoreflect.Message
  • func (x *ServerConfig) Reset()
  • func (x *ServerConfig) String() string

Variables

var File_proxy_hysteria2_config_proto protoreflect.FileDescriptor

Functions

func QuicLen

func QuicLen(s int) int

Types

type Account

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

func (*Account) AsAccount

func (a *Account) AsAccount() (protocol.Account, error)

AsAccount implements protocol.AsAccount.

func (*Account) Descriptor

func (*Account) Descriptor() ([]byte, []int)

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) ProtoMessage

func (*Account) ProtoMessage()

func (*Account) ProtoReflect

func (x *Account) ProtoReflect() protoreflect.Message

func (*Account) Reset

func (x *Account) Reset()

func (*Account) String

func (x *Account) String() string

type Client

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

Client is an inbound handler

func NewClient

func NewClient(ctx context.Context, config *ClientConfig) (*Client, error)

NewClient create a new client.

func (*Client) Process

func (c *Client) Process(ctx context.Context, link *transport.Link, dialer internet.Dialer) error

Process implements OutboundHandler.Process().

type ClientConfig

type ClientConfig struct {
	Server []*protocol.ServerEndpoint `protobuf:"bytes,1,rep,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientConfig) Descriptor

func (*ClientConfig) Descriptor() ([]byte, []int)

Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

func (*ClientConfig) GetServer

func (x *ClientConfig) GetServer() []*protocol.ServerEndpoint

func (*ClientConfig) ProtoMessage

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) ProtoReflect

func (x *ClientConfig) ProtoReflect() protoreflect.Message

func (*ClientConfig) Reset

func (x *ClientConfig) Reset()

func (*ClientConfig) String

func (x *ClientConfig) String() string

type ConnReader

type ConnReader struct {
	io.Reader
	Target net.Destination
}

ConnReader is TCP Connection Reader Wrapper

func (*ConnReader) Read

func (c *ConnReader) Read(p []byte) (int, error)

Read implements io.Reader

func (*ConnReader) ReadMultiBuffer

func (c *ConnReader) ReadMultiBuffer() (buf.MultiBuffer, error)

ReadMultiBuffer implements buf.Reader

type ConnWriter

type ConnWriter struct {
	io.Writer
	Target        net.Destination
	TCPHeaderSent bool
}

ConnWriter is TCP Connection Writer Wrapper

func (*ConnWriter) Write

func (c *ConnWriter) Write(p []byte) (n int, err error)

Write implements io.Writer

func (*ConnWriter) WriteMultiBuffer

func (c *ConnWriter) WriteMultiBuffer(mb buf.MultiBuffer) error

WriteMultiBuffer implements buf.Writer

func (*ConnWriter) WriteTCPHeader

func (c *ConnWriter) WriteTCPHeader() error

type MemoryAccount

type MemoryAccount struct{}

MemoryAccount is an account type converted from Account.

func (*MemoryAccount) Equals

func (a *MemoryAccount) Equals(another protocol.Account) bool

Equals implements protocol.Account.Equals().

type PacketConnectionReader

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

func (*PacketConnectionReader) ReadFrom

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

type PacketPayload

type PacketPayload struct {
	Target net.Destination
	Buffer buf.MultiBuffer
}

PacketPayload combines udp payload and destination

type PacketReader

type PacketReader struct {
	io.Reader
	HyConn *hyTransport.HyConn
}

PacketReader is UDP Connection Reader Wrapper

func (*PacketReader) ReadMultiBuffer

func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error)

ReadMultiBuffer implements buf.Reader

func (*PacketReader) ReadMultiBufferWithMetadata

func (r *PacketReader) ReadMultiBufferWithMetadata() (*PacketPayload, error)

ReadMultiBufferWithMetadata reads udp packet with destination

type PacketWriter

type PacketWriter struct {
	io.Writer
	HyConn *hyTransport.HyConn
	Target net.Destination
}

PacketWriter UDP Connection Writer Wrapper

func (*PacketWriter) WriteMultiBuffer

func (w *PacketWriter) WriteMultiBuffer(mb buf.MultiBuffer) error

WriteMultiBuffer implements buf.Writer

func (*PacketWriter) WriteMultiBufferWithMetadata

func (w *PacketWriter) WriteMultiBufferWithMetadata(mb buf.MultiBuffer, dest net.Destination) error

WriteMultiBufferWithMetadata writes udp packet with destination specified

func (*PacketWriter) WriteTo

func (w *PacketWriter) WriteTo(payload []byte, addr net.Addr) (int, error)

type Server

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

Server is an inbound connection handler that handles messages in protocol.

func NewServer

func NewServer(ctx context.Context, config *ServerConfig) (*Server, error)

NewServer creates a new inbound handler.

func (*Server) Network

func (s *Server) Network() []net.Network

Network implements proxy.Inbound.Network().

func (*Server) Process

func (s *Server) Process(ctx context.Context, network net.Network, conn internet.Connection, dispatcher routing.Dispatcher) error

Process implements proxy.Inbound.Process().

type ServerConfig

type ServerConfig struct {
	PacketEncoding packetaddr.PacketAddrType `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServerConfig) Descriptor

func (*ServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

func (*ServerConfig) GetPacketEncoding

func (x *ServerConfig) GetPacketEncoding() packetaddr.PacketAddrType

func (*ServerConfig) ProtoMessage

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) ProtoReflect

func (x *ServerConfig) ProtoReflect() protoreflect.Message

func (*ServerConfig) Reset

func (x *ServerConfig) Reset()

func (*ServerConfig) String

func (x *ServerConfig) String() string