tcp

Documentation

Overview

Package tcp is a generated protocol buffer package.

It is generated from these files:

v2ray.com/core/transport/internet/tcp/config.proto

It has these top-level messages:

ConnectionReuse
Config

Index

• Variables
• func Dial(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error)
• func DialRaw(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error)
• func ListenRawTCP(address v2net.Address, port v2net.Port, options internet.ListenOptions) (internet.Listener, error)
• 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 Connection
  • func NewConnection(id internal.ConnectionID, conn net.Conn, manager internal.ConnectionRecyler, ...) *Connection
  • func (v *Connection) Close() error
  • func (v *Connection) LocalAddr() net.Addr
  • func (v *Connection) Read(b []byte) (int, error)
  • func (v *Connection) RemoteAddr() net.Addr
  • func (v *Connection) Reusable() bool
  • func (v *Connection) SetDeadline(t time.Time) error
  • func (v *Connection) SetReadDeadline(t time.Time) error
  • func (v *Connection) SetReusable(reusable bool)
  • func (v *Connection) SetWriteDeadline(t time.Time) error
  • func (v *Connection) SysFd() (int, error)
  • func (v *Connection) Write(b []byte) (int, error)
• 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 RawConnection
  • func (v *RawConnection) Reusable() bool
  • func (v *RawConnection) SetReusable(b bool)
  • func (v *RawConnection) SysFd() (int, error)
• type RawTCPListener
  • func (v *RawTCPListener) Accept() (internet.Connection, error)
  • func (v *RawTCPListener) Addr() net.Addr
  • func (v *RawTCPListener) Close() error
• 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)

Variables

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

Functions

func Dial

func Dial(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error)

func DialRaw

func DialRaw(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error)

func ListenRawTCP

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

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 Connection

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(id internal.ConnectionID, conn net.Conn, manager internal.ConnectionRecyler, config *Config) *Connection

func (*Connection) Close

func (v *Connection) Close() error

func (*Connection) LocalAddr

func (v *Connection) LocalAddr() net.Addr

func (*Connection) Read

func (v *Connection) Read(b []byte) (int, error)

func (*Connection) RemoteAddr

func (v *Connection) RemoteAddr() net.Addr

func (*Connection) Reusable

func (v *Connection) Reusable() bool

func (*Connection) SetDeadline

func (v *Connection) SetDeadline(t time.Time) error

func (*Connection) SetReadDeadline

func (v *Connection) SetReadDeadline(t time.Time) error

func (*Connection) SetReusable

func (v *Connection) SetReusable(reusable bool)

func (*Connection) SetWriteDeadline

func (v *Connection) SetWriteDeadline(t time.Time) error

func (*Connection) SysFd

func (v *Connection) SysFd() (int, error)

func (*Connection) Write

func (v *Connection) Write(b []byte) (int, error)

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 RawConnection

type RawConnection struct {
	net.TCPConn
}

func (*RawConnection) Reusable

func (v *RawConnection) Reusable() bool

func (*RawConnection) SetReusable

func (v *RawConnection) SetReusable(b bool)

func (*RawConnection) SysFd

func (v *RawConnection) SysFd() (int, error)

type RawTCPListener

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

func (*RawTCPListener) Accept

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

func (*RawTCPListener) Addr

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

func (*RawTCPListener) Close

func (v *RawTCPListener) Close() error

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)