tcp

package
v2.10.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2016 License: MIT Imports: 15 Imported by: 0

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

Constants

This section is empty.

Variables

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

Functions

func Dial

func DialRaw

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_loader.TypedSettings `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_loader.TypedSettings

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 {
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(id internal.ConnectionId, conn net.Conn, manager ConnectionManager, 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 ConnectionManager

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

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 added in v1.18.1

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL