internet

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2022 License: MPL-2.0 Imports: 27 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 (
	TransportProtocol_name = map[int32]string{
		0: "TCP",
		1: "UDP",
		2: "MKCP",
		3: "WebSocket",
		4: "HTTP",
		5: "DomainSocket",
	}
	TransportProtocol_value = map[string]int32{
		"TCP":          0,
		"UDP":          1,
		"MKCP":         2,
		"WebSocket":    3,
		"HTTP":         4,
		"DomainSocket": 5,
	}
)

Enum value maps for TransportProtocol.

View Source
var (
	DomainStrategy_name = map[int32]string{
		0: "AS_IS",
		1: "USE_IP",
		2: "USE_IP4",
		3: "USE_IP6",
	}
	DomainStrategy_value = map[string]int32{
		"AS_IS":   0,
		"USE_IP":  1,
		"USE_IP4": 2,
		"USE_IP6": 3,
	}
)

Enum value maps for DomainStrategy.

View Source
var (
	SocketConfig_TProxyMode_name = map[int32]string{
		0: "Off",
		1: "TProxy",
		2: "Redirect",
	}
	SocketConfig_TProxyMode_value = map[string]int32{
		"Off":      0,
		"TProxy":   1,
		"Redirect": 2,
	}
)

Enum value maps for SocketConfig_TProxyMode.

View Source
var File_transport_internet_config_proto protoreflect.FileDescriptor

Functions

func ApplyGlobalTransportSettings

func ApplyGlobalTransportSettings(settings []*TransportConfig) error

func CreateTransportConfig

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

func Dial

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

Dial dials a internet connection towards the given destination.

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 InitSystemDialer

func InitSystemDialer(dc dns.Client, om outbound.Manager)

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.

xray: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.

xray: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.

xray: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.

xray: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.

xray:api:stable

Types

type ConfigCreator

type ConfigCreator func() interface{}

type ConnHandler

type ConnHandler func(stat.Connection)

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) (l net.Listener, err 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) (stat.Connection, error)

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

Dialer is the interface for dialing outbound connections.

type DomainStrategy

type DomainStrategy int32
const (
	DomainStrategy_AS_IS   DomainStrategy = 0
	DomainStrategy_USE_IP  DomainStrategy = 1
	DomainStrategy_USE_IP4 DomainStrategy = 2
	DomainStrategy_USE_IP6 DomainStrategy = 3
)

func (DomainStrategy) Descriptor

func (DomainStrategy) Enum

func (x DomainStrategy) Enum() *DomainStrategy

func (DomainStrategy) EnumDescriptor deprecated

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

Deprecated: Use DomainStrategy.Descriptor instead.

func (DomainStrategy) Number

func (DomainStrategy) String

func (x DomainStrategy) String() string

func (DomainStrategy) Type

type FileLocker

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

FileLocker is UDS access lock

func (*FileLocker) Acquire

func (fl *FileLocker) Acquire() error

Acquire lock

func (*FileLocker) Release

func (fl *FileLocker) Release()

Release lock

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)

func ListenUnix

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

ListenUnix is the UDS version of ListenTCP

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 PacketConnWrapper

type PacketConnWrapper struct {
	Conn net.PacketConn
	Dest net.Addr
}

func (*PacketConnWrapper) Close

func (c *PacketConnWrapper) Close() error

func (*PacketConnWrapper) LocalAddr

func (c *PacketConnWrapper) LocalAddr() net.Addr

func (*PacketConnWrapper) Read

func (c *PacketConnWrapper) Read(p []byte) (int, error)

func (*PacketConnWrapper) ReadFrom

func (c *PacketConnWrapper) ReadFrom(p []byte) (int, net.Addr, error)

func (*PacketConnWrapper) RemoteAddr

func (c *PacketConnWrapper) RemoteAddr() net.Addr

func (*PacketConnWrapper) SetDeadline

func (c *PacketConnWrapper) SetDeadline(t time.Time) error

func (*PacketConnWrapper) SetReadDeadline

func (c *PacketConnWrapper) SetReadDeadline(t time.Time) error

func (*PacketConnWrapper) SetWriteDeadline

func (c *PacketConnWrapper) SetWriteDeadline(t time.Time) error

func (*PacketConnWrapper) Write

func (c *PacketConnWrapper) Write(p []byte) (int, error)

func (*PacketConnWrapper) WriteTo

func (c *PacketConnWrapper) WriteTo(p []byte, d net.Addr) (int, error)

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"`
	TransportLayerProxy bool   `protobuf:"varint,2,opt,name=transportLayerProxy,proto3" json:"transportLayerProxy,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyConfig) Descriptor deprecated

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

Deprecated: Use ProxyConfig.ProtoReflect.Descriptor instead.

func (*ProxyConfig) GetTag

func (x *ProxyConfig) GetTag() string

func (*ProxyConfig) GetTransportLayerProxy

func (x *ProxyConfig) GetTransportLayerProxy() bool

func (*ProxyConfig) HasTag

func (c *ProxyConfig) HasTag() bool

func (*ProxyConfig) ProtoMessage

func (*ProxyConfig) ProtoMessage()

func (*ProxyConfig) ProtoReflect

func (x *ProxyConfig) ProtoReflect() protoreflect.Message

func (*ProxyConfig) Reset

func (x *ProxyConfig) Reset()

func (*ProxyConfig) String

func (x *ProxyConfig) String() string

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 int32 `protobuf:"varint,2,opt,name=tfo,proto3" json:"tfo,omitempty"`
	// TProxy is for enabling TProxy socket option.
	Tproxy SocketConfig_TProxyMode `protobuf:"varint,3,opt,name=tproxy,proto3,enum=xray.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"`
	AcceptProxyProtocol        bool           `protobuf:"varint,7,opt,name=accept_proxy_protocol,json=acceptProxyProtocol,proto3" json:"accept_proxy_protocol,omitempty"`
	DomainStrategy             DomainStrategy `` /* 148-byte string literal not displayed */
	DialerProxy                string         `protobuf:"bytes,9,opt,name=dialer_proxy,json=dialerProxy,proto3" json:"dialer_proxy,omitempty"`
	TcpKeepAliveInterval       int32          `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

SocketConfig is options to be applied on network sockets.

func (*SocketConfig) Descriptor deprecated

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

Deprecated: Use SocketConfig.ProtoReflect.Descriptor instead.

func (*SocketConfig) GetAcceptProxyProtocol

func (x *SocketConfig) GetAcceptProxyProtocol() bool

func (*SocketConfig) GetBindAddress

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

func (*SocketConfig) GetBindPort

func (x *SocketConfig) GetBindPort() uint32

func (*SocketConfig) GetDialerProxy

func (x *SocketConfig) GetDialerProxy() string

func (*SocketConfig) GetDomainStrategy

func (x *SocketConfig) GetDomainStrategy() DomainStrategy

func (*SocketConfig) GetMark

func (x *SocketConfig) GetMark() int32

func (*SocketConfig) GetReceiveOriginalDestAddress

func (x *SocketConfig) GetReceiveOriginalDestAddress() bool

func (*SocketConfig) GetTcpKeepAliveInterval

func (x *SocketConfig) GetTcpKeepAliveInterval() int32

func (*SocketConfig) GetTfo

func (x *SocketConfig) GetTfo() int32

func (*SocketConfig) GetTproxy

func (x *SocketConfig) GetTproxy() SocketConfig_TProxyMode

func (*SocketConfig) ParseTFOValue

func (v *SocketConfig) ParseTFOValue() int

func (*SocketConfig) ProtoMessage

func (*SocketConfig) ProtoMessage()

func (*SocketConfig) ProtoReflect

func (x *SocketConfig) ProtoReflect() protoreflect.Message

func (*SocketConfig) Reset

func (x *SocketConfig) Reset()

func (*SocketConfig) String

func (x *SocketConfig) 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) Descriptor

func (SocketConfig_TProxyMode) Enum

func (SocketConfig_TProxyMode) EnumDescriptor deprecated

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

Deprecated: Use SocketConfig_TProxyMode.Descriptor instead.

func (SocketConfig_TProxyMode) IsEnabled

func (m SocketConfig_TProxyMode) IsEnabled() bool

func (SocketConfig_TProxyMode) Number

func (SocketConfig_TProxyMode) String

func (x SocketConfig_TProxyMode) String() string

func (SocketConfig_TProxyMode) Type

type StreamConfig

type StreamConfig struct {

	// Effective network. Deprecated. Use the string form below.
	//
	// Deprecated: Do not use.
	Protocol TransportProtocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=xray.transport.internet.TransportProtocol" json:"protocol,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

func (*StreamConfig) Descriptor deprecated

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

Deprecated: Use StreamConfig.ProtoReflect.Descriptor instead.

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 (x *StreamConfig) GetProtocol() TransportProtocol

Deprecated: Do not use.

func (*StreamConfig) GetProtocolName

func (x *StreamConfig) GetProtocolName() string

func (*StreamConfig) GetSecuritySettings

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

func (*StreamConfig) GetSecurityType

func (x *StreamConfig) GetSecurityType() string

func (*StreamConfig) GetSocketSettings

func (x *StreamConfig) GetSocketSettings() *SocketConfig

func (*StreamConfig) GetTransportSettings

func (x *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) ProtoReflect

func (x *StreamConfig) ProtoReflect() protoreflect.Message

func (*StreamConfig) Reset

func (x *StreamConfig) Reset()

func (*StreamConfig) String

func (x *StreamConfig) String() string

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.
	//
	// Deprecated: Do not use.
	Protocol TransportProtocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=xray.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"`
	// contains filtered or unexported fields
}

func (*TransportConfig) Descriptor deprecated

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

Deprecated: Use TransportConfig.ProtoReflect.Descriptor instead.

func (*TransportConfig) GetProtocol deprecated

func (x *TransportConfig) GetProtocol() TransportProtocol

Deprecated: Do not use.

func (*TransportConfig) GetProtocolName

func (x *TransportConfig) GetProtocolName() string

func (*TransportConfig) GetSettings

func (x *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) ProtoReflect

func (x *TransportConfig) ProtoReflect() protoreflect.Message

func (*TransportConfig) Reset

func (x *TransportConfig) Reset()

func (*TransportConfig) String

func (x *TransportConfig) String() string

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) Descriptor

func (TransportProtocol) Enum

func (TransportProtocol) EnumDescriptor deprecated

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

Deprecated: Use TransportProtocol.Descriptor instead.

func (TransportProtocol) Number

func (TransportProtocol) String

func (x TransportProtocol) String() string

func (TransportProtocol) Type

Directories

Path Synopsis
headers
tls
utp
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