internet

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// For incoming connections.
	TCP_FASTOPEN = 23
	// For out-going connections.
	TCP_FASTOPEN_CONNECT = 30
)

Variables

View Source 
var SendThroughIP net.IP
View Source 
var SocketConfig_TCPFastOpenState_name = map[int32]string{
	0: "AsIs",
	1: "Enable",
	2: "Disable",
}
View Source 
var SocketConfig_TCPFastOpenState_value = map[string]int32{
	"AsIs":    0,
	"Enable":  1,
	"Disable": 2,
}
View Source 
var SocketConfig_TProxyMode_name = map[int32]string{
	0: "Off",
	1: "TProxy",
	2: "Redirect",
}
View Source 
var SocketConfig_TProxyMode_value = map[string]int32{
	"Off":      0,
	"TProxy":   1,
	"Redirect": 2,
}
View Source 
var TransportProtocol_name = map[int32]string{
	0: "TCP",
	1: "UDP",
	2: "MKCP",
	3: "WebSocket",
	4: "HTTP",
	5: "DomainSocket",
}
View Source 
var TransportProtocol_value = map[string]int32{
	"TCP":          0,
	"UDP":          1,
	"MKCP":         2,
	"WebSocket":    3,
	"HTTP":         4,
	"DomainSocket": 5,
}

Functions

func ApplyGlobalTransportSettings 

func ApplyGlobalTransportSettings(settings []*TransportConfig) error

func CreateTransportConfig 

func CreateTransportConfig(name string) (interface{}, error)

func DialSystem 

func DialSystem(ctx context.Context, dest net.Destination, sockopt *SocketConfig) (net.Conn, error)

DialSystem calls system dialer to create a network connection.

func DialUDP 

func DialUDP(ctx context.Context, streamSettings *MemoryStreamConfig) (net.PacketConn, error)

func ListenSystem 

func ListenSystem(ctx context.Context, addr net.Addr, sockopt *SocketConfig) (net.Listener, error)

ListenSystem listens on a local address for incoming TCP connections.

v2ray:api:beta

func ListenSystemPacket 

func ListenSystemPacket(ctx context.Context, addr net.Addr, sockopt *SocketConfig) (net.PacketConn, error)

ListenSystemPacket listens on a local address for incoming UDP connections.

v2ray:api:beta

func RegisterDialerController 

func RegisterDialerController(ctl func(network, address string, fd uintptr) error) error

RegisterDialerController adds a controller to the effective system dialer. The controller can be used to operate on file descriptors before they are put into use. It only works when effective dialer is the default dialer.

v2ray:api:beta

func RegisterListenerController 

func RegisterListenerController(controller func(network, address string, fd uintptr) error) error

RegisterListenerController adds a controller to the effective system listener. The controller can be used to operate on file descriptors before they are put into use.

v2ray:api:beta

func RegisterProtocolConfigCreator 

func RegisterProtocolConfigCreator(name string, creator ConfigCreator) error

func RegisterTransportDialer 

func RegisterTransportDialer(protocol string, dialer dialFunc) error

RegisterTransportDialer registers a Dialer with given name.

func RegisterTransportListener 

func RegisterTransportListener(protocol string, listener ListenFunc) error

func UseAlternativeSystemDialer 

func UseAlternativeSystemDialer(dialer SystemDialer)

UseAlternativeSystemDialer replaces the current system dialer with a given one. Caller must ensure there is no race condition.

v2ray:api:stable

Types

type ConfigCreator 

type ConfigCreator func() interface{}

type ConnHandler 

type ConnHandler func(Connection)

type Connection 

type Connection interface {
	net.Conn
}

func Dial 

func Dial(ctx context.Context, dest net.Destination, streamSettings *MemoryStreamConfig) (Connection, error)

Dial dials a internet connection towards the given destination.

type ConnectionAuthenticator 

type ConnectionAuthenticator interface {
	Client(net.Conn) net.Conn
	Server(net.Conn) net.Conn
}

func CreateConnectionAuthenticator 

func CreateConnectionAuthenticator(config interface{}) (ConnectionAuthenticator, error)

type DefaultListener 

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

func (*DefaultListener) Listen 

func (dl *DefaultListener) Listen(ctx context.Context, addr net.Addr, sockopt *SocketConfig) (net.Listener, error)

func (*DefaultListener) ListenPacket 

func (dl *DefaultListener) ListenPacket(ctx context.Context, addr net.Addr, sockopt *SocketConfig) (net.PacketConn, error)

type DefaultSystemDialer 

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

func (*DefaultSystemDialer) Dial 

func (d *DefaultSystemDialer) Dial(ctx context.Context, src net.Address, dest net.Destination, sockopt *SocketConfig) (net.Conn, error)

type Dialer 

type Dialer interface {
	// Dial dials a system connection to the given destination.
	Dial(ctx context.Context, destination net.Destination) (Connection, error)

	// Address returns the address used by this Dialer. Maybe nil if not known.
	Address() net.Address

	DialUDP(ctx context.Context) (net.PacketConn, error)
}

Dialer is the interface for dialing outbound connections.

type ListenFunc 

type ListenFunc func(ctx context.Context, address net.Address, port net.Port, settings *MemoryStreamConfig, handler ConnHandler) (Listener, error)

type Listener 

type Listener interface {
	Close() error
	Addr() net.Addr
}

func ListenTCP 

func ListenTCP(ctx context.Context, address net.Address, port net.Port, settings *MemoryStreamConfig, handler ConnHandler) (Listener, error)

type MemoryStreamConfig 

type MemoryStreamConfig struct {
	ProtocolName     string
	ProtocolSettings interface{}
	SecurityType     string
	SecuritySettings interface{}
	SocketSettings   *SocketConfig
}

MemoryStreamConfig is a parsed form of StreamConfig. This is used to reduce number of Protobuf parsing.

func ToMemoryStreamConfig 

func ToMemoryStreamConfig(s *StreamConfig) (*MemoryStreamConfig, error)

ToMemoryStreamConfig converts a StreamConfig to MemoryStreamConfig. It returns a default non-nil MemoryStreamConfig for nil input.

type PacketHeader 

type PacketHeader interface {
	Size() int32
	Serialize([]byte)
}

func CreatePacketHeader 

func CreatePacketHeader(config interface{}) (PacketHeader, error)

type ProxyConfig 

type ProxyConfig struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyConfig) Descriptor 

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

func (*ProxyConfig) GetTag 

func (m *ProxyConfig) GetTag() string

func (*ProxyConfig) HasTag 

func (c *ProxyConfig) HasTag() bool

func (*ProxyConfig) ProtoMessage 

func (*ProxyConfig) ProtoMessage()

func (*ProxyConfig) Reset 

func (m *ProxyConfig) Reset()

func (*ProxyConfig) String 

func (m *ProxyConfig) String() string

func (*ProxyConfig) XXX_DiscardUnknown 

func (m *ProxyConfig) XXX_DiscardUnknown()

func (*ProxyConfig) XXX_Marshal 

func (m *ProxyConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyConfig) XXX_Merge 

func (m *ProxyConfig) XXX_Merge(src proto.Message)

func (*ProxyConfig) XXX_Size 

func (m *ProxyConfig) XXX_Size() int

func (*ProxyConfig) XXX_Unmarshal 

func (m *ProxyConfig) XXX_Unmarshal(b []byte) error

type SimpleSystemDialer 

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

func (*SimpleSystemDialer) Dial 

func (v *SimpleSystemDialer) Dial(ctx context.Context, src net.Address, dest net.Destination, sockopt *SocketConfig) (net.Conn, error)

type SocketConfig 

type SocketConfig struct {
	// Mark of the connection. If non-zero, the value will be set to SO_MARK.
	Mark int32 `protobuf:"varint,1,opt,name=mark,proto3" json:"mark,omitempty"`
	// TFO is the state of TFO settings.
	Tfo SocketConfig_TCPFastOpenState `protobuf:"varint,2,opt,name=tfo,proto3,enum=v2ray.core.transport.internet.SocketConfig_TCPFastOpenState" json:"tfo,omitempty"`
	// TProxy is for enabling TProxy socket option.
	Tproxy SocketConfig_TProxyMode `protobuf:"varint,3,opt,name=tproxy,proto3,enum=v2ray.core.transport.internet.SocketConfig_TProxyMode" json:"tproxy,omitempty"`
	// ReceiveOriginalDestAddress is for enabling IP_RECVORIGDSTADDR socket option.
	// This option is for UDP only.
	ReceiveOriginalDestAddress bool     `` /* 144-byte string literal not displayed */
	BindAddress                []byte   `protobuf:"bytes,5,opt,name=bind_address,json=bindAddress,proto3" json:"bind_address,omitempty"`
	BindPort                   uint32   `protobuf:"varint,6,opt,name=bind_port,json=bindPort,proto3" json:"bind_port,omitempty"`
	Tos                        int32    `protobuf:"varint,7,opt,name=tos,proto3" json:"tos,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

SocketConfig is options to be applied on network sockets.

func (*SocketConfig) Descriptor 

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

func (*SocketConfig) GetBindAddress 

func (m *SocketConfig) GetBindAddress() []byte

func (*SocketConfig) GetBindPort 

func (m *SocketConfig) GetBindPort() uint32

func (*SocketConfig) GetMark 

func (m *SocketConfig) GetMark() int32

func (*SocketConfig) GetReceiveOriginalDestAddress 

func (m *SocketConfig) GetReceiveOriginalDestAddress() bool

func (*SocketConfig) GetTfo 

func (m *SocketConfig) GetTfo() SocketConfig_TCPFastOpenState

func (*SocketConfig) GetTos 

func (m *SocketConfig) GetTos() int32

func (*SocketConfig) GetTproxy 

func (m *SocketConfig) GetTproxy() SocketConfig_TProxyMode

func (*SocketConfig) ProtoMessage 

func (*SocketConfig) ProtoMessage()

func (*SocketConfig) Reset 

func (m *SocketConfig) Reset()

func (*SocketConfig) String 

func (m *SocketConfig) String() string

func (*SocketConfig) XXX_DiscardUnknown 

func (m *SocketConfig) XXX_DiscardUnknown()

func (*SocketConfig) XXX_Marshal 

func (m *SocketConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketConfig) XXX_Merge 

func (m *SocketConfig) XXX_Merge(src proto.Message)

func (*SocketConfig) XXX_Size 

func (m *SocketConfig) XXX_Size() int

func (*SocketConfig) XXX_Unmarshal 

func (m *SocketConfig) XXX_Unmarshal(b []byte) error

type SocketConfig_TCPFastOpenState 

type SocketConfig_TCPFastOpenState int32
const (
	// AsIs is to leave the current TFO state as is, unmodified.
	SocketConfig_AsIs SocketConfig_TCPFastOpenState = 0
	// Enable is for enabling TFO explictly.
	SocketConfig_Enable SocketConfig_TCPFastOpenState = 1
	// Disable is for disabling TFO explictly.
	SocketConfig_Disable SocketConfig_TCPFastOpenState = 2
)

func (SocketConfig_TCPFastOpenState) EnumDescriptor 

func (SocketConfig_TCPFastOpenState) EnumDescriptor() ([]byte, []int)

func (SocketConfig_TCPFastOpenState) String 

func (x SocketConfig_TCPFastOpenState) String() string

type SocketConfig_TProxyMode 

type SocketConfig_TProxyMode int32
const (
	// TProxy is off.
	SocketConfig_Off SocketConfig_TProxyMode = 0
	// TProxy mode.
	SocketConfig_TProxy SocketConfig_TProxyMode = 1
	// Redirect mode.
	SocketConfig_Redirect SocketConfig_TProxyMode = 2
)

func (SocketConfig_TProxyMode) EnumDescriptor 

func (SocketConfig_TProxyMode) EnumDescriptor() ([]byte, []int)

func (SocketConfig_TProxyMode) IsEnabled 

func (m SocketConfig_TProxyMode) IsEnabled() bool

func (SocketConfig_TProxyMode) String 

func (x SocketConfig_TProxyMode) String() string

type StatCouterConnection 

type StatCouterConnection struct {
	Connection
	Uplink   stats.Counter
	Downlink stats.Counter
}

func (*StatCouterConnection) Read 

func (c *StatCouterConnection) Read(b []byte) (int, error)

func (*StatCouterConnection) Write 

func (c *StatCouterConnection) Write(b []byte) (int, error)

type StreamConfig 

type StreamConfig struct {
	// Effective network. Deprecated. Use the string form below.
	Protocol TransportProtocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=v2ray.core.transport.internet.TransportProtocol" json:"protocol,omitempty"` // Deprecated: Do not use.
	// Effective network.
	ProtocolName      string             `protobuf:"bytes,5,opt,name=protocol_name,json=protocolName,proto3" json:"protocol_name,omitempty"`
	TransportSettings []*TransportConfig `protobuf:"bytes,2,rep,name=transport_settings,json=transportSettings,proto3" json:"transport_settings,omitempty"`
	// Type of security. Must be a message name of the settings proto.
	SecurityType string `protobuf:"bytes,3,opt,name=security_type,json=securityType,proto3" json:"security_type,omitempty"`
	// Settings for transport security. For now the only choice is TLS.
	SecuritySettings     []*serial.TypedMessage `protobuf:"bytes,4,rep,name=security_settings,json=securitySettings,proto3" json:"security_settings,omitempty"`
	SocketSettings       *SocketConfig          `protobuf:"bytes,6,opt,name=socket_settings,json=socketSettings,proto3" json:"socket_settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StreamConfig) Descriptor 

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

func (*StreamConfig) GetEffectiveProtocol 

func (c *StreamConfig) GetEffectiveProtocol() string

func (*StreamConfig) GetEffectiveSecuritySettings 

func (c *StreamConfig) GetEffectiveSecuritySettings() (interface{}, error)

func (*StreamConfig) GetEffectiveTransportSettings 

func (c *StreamConfig) GetEffectiveTransportSettings() (interface{}, error)

func (*StreamConfig) GetProtocol deprecated 

func (m *StreamConfig) GetProtocol() TransportProtocol

Deprecated: Do not use.

func (*StreamConfig) GetProtocolName 

func (m *StreamConfig) GetProtocolName() string

func (*StreamConfig) GetSecuritySettings 

func (m *StreamConfig) GetSecuritySettings() []*serial.TypedMessage

func (*StreamConfig) GetSecurityType 

func (m *StreamConfig) GetSecurityType() string

func (*StreamConfig) GetSocketSettings 

func (m *StreamConfig) GetSocketSettings() *SocketConfig

func (*StreamConfig) GetTransportSettings 

func (m *StreamConfig) GetTransportSettings() []*TransportConfig

func (*StreamConfig) GetTransportSettingsFor 

func (c *StreamConfig) GetTransportSettingsFor(protocol string) (interface{}, error)

func (*StreamConfig) HasSecuritySettings 

func (c *StreamConfig) HasSecuritySettings() bool

func (*StreamConfig) ProtoMessage 

func (*StreamConfig) ProtoMessage()

func (*StreamConfig) Reset 

func (m *StreamConfig) Reset()

func (*StreamConfig) String 

func (m *StreamConfig) String() string

func (*StreamConfig) XXX_DiscardUnknown 

func (m *StreamConfig) XXX_DiscardUnknown()

func (*StreamConfig) XXX_Marshal 

func (m *StreamConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamConfig) XXX_Merge 

func (m *StreamConfig) XXX_Merge(src proto.Message)

func (*StreamConfig) XXX_Size 

func (m *StreamConfig) XXX_Size() int

func (*StreamConfig) XXX_Unmarshal 

func (m *StreamConfig) XXX_Unmarshal(b []byte) error

type SystemDialer 

type SystemDialer interface {
	Dial(ctx context.Context, source net.Address, destination net.Destination, sockopt *SocketConfig) (net.Conn, error)
}

func WithAdapter 

func WithAdapter(dialer SystemDialerAdapter) SystemDialer

type SystemDialerAdapter 

type SystemDialerAdapter interface {
	Dial(network string, address string) (net.Conn, error)
}

type TransportConfig 

type TransportConfig struct {
	// Type of network that this settings supports.
	// Deprecated. Use the string form below.
	Protocol TransportProtocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=v2ray.core.transport.internet.TransportProtocol" json:"protocol,omitempty"`
	// Type of network that this settings supports.
	ProtocolName string `protobuf:"bytes,3,opt,name=protocol_name,json=protocolName,proto3" json:"protocol_name,omitempty"`
	// Specific settings. Must be of the transports.
	Settings             *serial.TypedMessage `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TransportConfig) Descriptor 

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

func (*TransportConfig) GetProtocol 

func (m *TransportConfig) GetProtocol() TransportProtocol

func (*TransportConfig) GetProtocolName 

func (m *TransportConfig) GetProtocolName() string

func (*TransportConfig) GetSettings 

func (m *TransportConfig) GetSettings() *serial.TypedMessage

func (*TransportConfig) GetTypedSettings 

func (c *TransportConfig) GetTypedSettings() (interface{}, error)

func (*TransportConfig) GetUnifiedProtocolName 

func (c *TransportConfig) GetUnifiedProtocolName() string

func (*TransportConfig) ProtoMessage 

func (*TransportConfig) ProtoMessage()

func (*TransportConfig) Reset 

func (m *TransportConfig) Reset()

func (*TransportConfig) String 

func (m *TransportConfig) String() string

func (*TransportConfig) XXX_DiscardUnknown 

func (m *TransportConfig) XXX_DiscardUnknown()

func (*TransportConfig) XXX_Marshal 

func (m *TransportConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransportConfig) XXX_Merge 

func (m *TransportConfig) XXX_Merge(src proto.Message)

func (*TransportConfig) XXX_Size 

func (m *TransportConfig) XXX_Size() int

func (*TransportConfig) XXX_Unmarshal 

func (m *TransportConfig) XXX_Unmarshal(b []byte) error

type TransportProtocol 

type TransportProtocol int32
const (
	TransportProtocol_TCP          TransportProtocol = 0
	TransportProtocol_UDP          TransportProtocol = 1
	TransportProtocol_MKCP         TransportProtocol = 2
	TransportProtocol_WebSocket    TransportProtocol = 3
	TransportProtocol_HTTP         TransportProtocol = 4
	TransportProtocol_DomainSocket TransportProtocol = 5
)

func (TransportProtocol) EnumDescriptor 

func (TransportProtocol) EnumDescriptor() ([]byte, []int)

func (TransportProtocol) String 

func (x TransportProtocol) String() string

Source Files

View all Source files

Directories

Path Synopsis
headers
http
noop
srtp
tls
utp
wechat
wireguard
Package kcp - A Fast and Reliable ARQ Protocol Acknowledgement: skywind3000@github for inventing the KCP protocol xtaci@github for translating to Golang
 Package kcp - A Fast and Reliable ARQ Protocol Acknowledgement: skywind3000@github for inventing the KCP protocol xtaci@github for translating to Golang
Package websocket implements Websocket transport Websocket transport implements an HTTP(S) compliable, surveillance proof transport method with plausible deniability.
 Package websocket implements Websocket transport Websocket transport implements an HTTP(S) compliable, surveillance proof transport method with plausible deniability.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.