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
- type 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 ConnectionManager
- type ConnectionReuse
- type ConnectionWithError
- type RawConnection
- type RawTCPListener
- type TCPListener
Constants ¶
This section is empty.
Variables ¶
View Source
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 ¶ added in v1.17.1
func DialRaw(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error)
func ListenRawTCP ¶ added in v1.17.1
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) GetConnectionReuse ¶
func (m *Config) GetConnectionReuse() *ConnectionReuse
func (*Config) GetHeaderSettings ¶
func (m *Config) GetHeaderSettings() *v2ray_core_common_serial.TypedMessage
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
type Connection ¶ added in v1.17.1
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶ added in v1.17.1
func NewConnection(id internal.ConnectionId, conn net.Conn, manager ConnectionManager, config *Config) *Connection
func (*Connection) Close ¶ added in v1.17.1
func (v *Connection) Close() error
func (*Connection) LocalAddr ¶ added in v1.17.1
func (v *Connection) LocalAddr() net.Addr
func (*Connection) RemoteAddr ¶ added in v1.17.1
func (v *Connection) RemoteAddr() net.Addr
func (*Connection) Reusable ¶ added in v1.17.1
func (v *Connection) Reusable() bool
func (*Connection) SetDeadline ¶ added in v1.17.1
func (v *Connection) SetDeadline(t time.Time) error
func (*Connection) SetReadDeadline ¶ added in v1.17.1
func (v *Connection) SetReadDeadline(t time.Time) error
func (*Connection) SetReusable ¶ added in v1.17.1
func (v *Connection) SetReusable(reusable bool)
func (*Connection) SetWriteDeadline ¶ added in v1.17.1
func (v *Connection) SetWriteDeadline(t time.Time) error
func (*Connection) SysFd ¶ added in v1.17.1
func (v *Connection) SysFd() (int, error)
type ConnectionManager ¶ added in v1.17.1
type ConnectionManager interface {
Put(internal.ConnectionId, net.Conn)
}
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) IsEnabled ¶
func (v *ConnectionReuse) IsEnabled() bool
func (*ConnectionReuse) ProtoMessage ¶
func (*ConnectionReuse) ProtoMessage()
func (*ConnectionReuse) Reset ¶
func (m *ConnectionReuse) Reset()
func (*ConnectionReuse) String ¶
func (m *ConnectionReuse) String() string
type ConnectionWithError ¶ added in v1.17.1
type ConnectionWithError struct {
// contains filtered or unexported fields
}
type RawConnection ¶ added in v1.17.1
func (*RawConnection) Reusable ¶ added in v1.17.1
func (v *RawConnection) Reusable() bool
func (*RawConnection) SetReusable ¶ added in v1.17.1
func (v *RawConnection) SetReusable(b bool)
func (*RawConnection) SysFd ¶ added in v1.18.1
func (v *RawConnection) SysFd() (int, error)
type RawTCPListener ¶ added in v1.17.1
type RawTCPListener struct {
// contains filtered or unexported fields
}
func (*RawTCPListener) Accept ¶ added in v1.17.1
func (v *RawTCPListener) Accept() (internet.Connection, error)
func (*RawTCPListener) Addr ¶ added in v1.17.1
func (v *RawTCPListener) Addr() net.Addr
func (*RawTCPListener) Close ¶ added in v1.17.1
func (v *RawTCPListener) Close() error
type TCPListener ¶ added in v1.17.1
func (*TCPListener) Accept ¶ added in v1.17.1
func (v *TCPListener) Accept() (internet.Connection, error)
func (*TCPListener) Addr ¶ added in v1.17.1
func (v *TCPListener) Addr() net.Addr
func (*TCPListener) Close ¶ added in v1.17.1
func (v *TCPListener) Close() error
func (*TCPListener) KeepAccepting ¶ added in v1.17.1
func (v *TCPListener) KeepAccepting()
func (*TCPListener) Put ¶
func (v *TCPListener) Put(id internal.ConnectionId, conn net.Conn)
Click to show internal directories.
Click to hide internal directories.