tcp

Documentation

Index

• Constants
• Variables
• func Dial(ctx context.Context, dest v2net.Destination) (internet.Connection, error)
• func GetOriginalDestination(conn internet.Connection) net.Destination
• func ListenTCP(address v2net.Address, port v2net.Port, options internet.ListenOptions) (internet.Listener, error)
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (m *Config) GetConnectionReuse() *ConnectionReuse
  • func (m *Config) GetHeaderSettings() *v2ray_core_common_serial.TypedMessage
  • func (v *Config) IsConnectionReuse() bool
  • func (*Config) ProtoMessage()
  • func (m *Config) Reset()
  • func (m *Config) String() string
• type ConnectionReuse
  • func (*ConnectionReuse) Descriptor() ([]byte, []int)
  • func (m *ConnectionReuse) GetEnable() bool
  • func (*ConnectionReuse) ProtoMessage()
  • func (m *ConnectionReuse) Reset()
  • func (m *ConnectionReuse) String() string
• type ConnectionWithError
• type TCPListener
  • func (v *TCPListener) Accept() (internet.Connection, error)
  • func (v *TCPListener) Addr() net.Addr
  • func (v *TCPListener) Close() error
  • func (v *TCPListener) KeepAccepting()
  • func (v *TCPListener) Put(id internal.ConnectionID, conn net.Conn)

Constants

const SO_ORIGINAL_DST = 80

Variables

var (
	ErrClosedListener = errors.New("Listener is closed.")
)

Functions

func Dial

func Dial(ctx context.Context, dest v2net.Destination) (internet.Connection, error)

func GetOriginalDestination

func GetOriginalDestination(conn internet.Connection) net.Destination

func ListenTCP

func ListenTCP(address v2net.Address, port v2net.Port, options internet.ListenOptions) (internet.Listener, error)

Types

type Config

type Config struct {
	ConnectionReuse *ConnectionReuse                       `protobuf:"bytes,1,opt,name=connection_reuse,json=connectionReuse" json:"connection_reuse,omitempty"`
	HeaderSettings  *v2ray_core_common_serial.TypedMessage `protobuf:"bytes,2,opt,name=header_settings,json=headerSettings" json:"header_settings,omitempty"`
}

func (*Config) Descriptor

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

func (*Config) GetConnectionReuse

func (m *Config) GetConnectionReuse() *ConnectionReuse

func (*Config) GetHeaderSettings

func (m *Config) GetHeaderSettings() *v2ray_core_common_serial.TypedMessage

func (*Config) IsConnectionReuse

func (v *Config) IsConnectionReuse() bool

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) Reset

func (m *Config) Reset()

func (*Config) String

func (m *Config) String() string

type ConnectionReuse

type ConnectionReuse struct {
	Enable bool `protobuf:"varint,1,opt,name=enable" json:"enable,omitempty"`
}

func (*ConnectionReuse) Descriptor

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

func (*ConnectionReuse) GetEnable

func (m *ConnectionReuse) GetEnable() bool

func (*ConnectionReuse) ProtoMessage

func (*ConnectionReuse) ProtoMessage()

func (*ConnectionReuse) Reset

func (m *ConnectionReuse) Reset()

func (*ConnectionReuse) String

func (m *ConnectionReuse) String() string

type ConnectionWithError

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

type TCPListener

type TCPListener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TCPListener) Accept

func (v *TCPListener) Accept() (internet.Connection, error)

func (*TCPListener) Addr

func (v *TCPListener) Addr() net.Addr

func (*TCPListener) Close

func (v *TCPListener) Close() error

func (*TCPListener) KeepAccepting

func (v *TCPListener) KeepAccepting()

func (*TCPListener) Put

func (v *TCPListener) Put(id internal.ConnectionID, conn net.Conn)