internet

package

Go to main page

Versions in this module

v1

v1.24.4

Aug 19, 2016

Changes in this version

+ var ErrUnsupportedStreamType = errors.New("Unsupported stream type.")

+ func DialToDest(src v2net.Address, dest v2net.Destination) (net.Conn, error)

+ func RegisterAuthenticator(name string, factory AuthenticatorFactory, configCreator loader.ConfigCreator) error

+ func SubstituteDialer(dialer SystemDialerAdapter) error

+ type Authenticator interface

+ Open func(*alloc.Buffer) bool

+ Overhead func() int

+ Seal func(*alloc.Buffer)

+ func CreateAuthenticator(name string, config AuthenticatorConfig) (Authenticator, error)

+ func NewAuthenticatorChain(auths ...Authenticator) Authenticator

+ type AuthenticatorChain struct

+ func (this *AuthenticatorChain) Open(payload *alloc.Buffer) bool

+ func (this *AuthenticatorChain) Overhead() int

+ func (this *AuthenticatorChain) Seal(payload *alloc.Buffer)

+ type AuthenticatorConfig interface

+ func CreateAuthenticatorConfig(rawConfig []byte) (string, AuthenticatorConfig, error)

+ type AuthenticatorFactory interface

+ Create func(AuthenticatorConfig) Authenticator

+ type ConnectionHandler func(Connection)

type Dialer

+ var KCPDialer Dialer

+ var RawTCPDialer Dialer

+ var TCPDialer Dialer

+ var UDPDialer Dialer

+ var WSDialer Dialer

type ListenFunc

+ var ErrClosedConnection = errors.New("Connection already closed.")

+ var KCPListenFunc ListenFunc

+ var RawTCPListenFunc ListenFunc

+ var TCPListenFunc ListenFunc

+ var WSListenFunc ListenFunc

type Listener

+ Accept func() (Connection, error)

+ type Reusable interface

+ Reusable func() bool

+ SetReusable func(reuse bool)

+ type StreamConnectionType int

+ const StreamConnectionTypeKCP

+ const StreamConnectionTypeRawTCP

+ const StreamConnectionTypeTCP

+ const StreamConnectionTypeWebSocket

+ type StreamSecurityType int

+ const StreamSecurityTypeNone

+ const StreamSecurityTypeTLS

+ type StreamSettings struct

+ Security StreamSecurityType

+ TLSSettings *TLSSettings

+ Type StreamConnectionType

+ func (this *StreamSettings) IsCapableOf(streamType StreamConnectionType) bool

+ type SysFd interface

+ SysFd func() (int, error)

+ type TCPHub struct

+ func (this *TCPHub) Close()

+ type TLSSettings struct

+ AllowInsecure bool

+ Certs []tls.Certificate

+ func (this *TLSSettings) GetTLSConfig() *tls.Config

v1.10.0

Aug 28, 2020

Changes in this version

+ const TCP_FASTOPEN — darwin/amd64, linux/amd64, windows/amd64

+ const TCP_FASTOPEN_CLIENT — darwin/amd64

+ const TCP_FASTOPEN_CONNECT — linux/amd64

+ const TCP_FASTOPEN_SERVER — darwin/amd64

+ var File_v2ray_com_core_transport_internet_config_proto protoreflect.FileDescriptor

+ var SocketConfig_TCPFastOpenState_name = map[int32]string

+ var SocketConfig_TCPFastOpenState_value = map[string]int32

+ var SocketConfig_TProxyMode_name = map[int32]string

+ var SocketConfig_TProxyMode_value = map[string]int32

+ var TransportProtocol_name = map[int32]string

+ var TransportProtocol_value = map[string]int32

+ func ApplyGlobalTransportSettings(settings []*TransportConfig) error

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

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

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

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

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

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

+ func RegisterProtocolConfigCreator(name string, creator ConfigCreator) error

+ func RegisterTransportDialer(protocol string, dialer dialFunc) error

+ func RegisterTransportListener(protocol string, listener ListenFunc) error

+ func UseAlternativeSystemDialer(dialer SystemDialer)

+ type ConfigCreator func() interface

+ type ConnHandler func(Connection)

+ type Connection interface

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

+ type ConnectionAuthenticator interface

+ Client func(net.Conn) net.Conn

+ Server func(net.Conn) net.Conn

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

+ type DefaultListener struct

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

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

+ type DefaultSystemDialer struct

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

+ type Dialer interface

+ Address func() net.Address

+ Dial func(ctx context.Context, destination net.Destination) (Connection, error)

+ type ListenFunc func(ctx context.Context, address net.Address, port net.Port, ...) (Listener, error)

+ type Listener interface

+ Addr func() net.Addr

+ Close func() error

+ func ListenTCP(ctx context.Context, address net.Address, port net.Port, ...) (Listener, error)

+ type MemoryStreamConfig struct

+ ProtocolName string

+ ProtocolSettings interface{}

+ SecuritySettings interface{}

+ SecurityType string

+ SocketSettings *SocketConfig

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

+ type PacketHeader interface

+ Serialize func([]byte)

+ Size func() int32

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

+ type ProxyConfig struct

+ Tag string

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

+ func (*ProxyConfig) ProtoMessage()

+ func (c *ProxyConfig) HasTag() bool

+ func (x *ProxyConfig) GetTag() string

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

+ func (x *ProxyConfig) Reset()

+ func (x *ProxyConfig) String() string

+ type SimpleSystemDialer struct

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

+ type SocketConfig struct

+ BindAddress []byte

+ BindPort uint32

+ Mark int32

+ ReceiveOriginalDestAddress bool

+ Tfo SocketConfig_TCPFastOpenState

+ Tproxy SocketConfig_TProxyMode

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

+ func (*SocketConfig) ProtoMessage()

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

+ func (x *SocketConfig) GetBindPort() uint32

+ func (x *SocketConfig) GetMark() int32

+ func (x *SocketConfig) GetReceiveOriginalDestAddress() bool

+ func (x *SocketConfig) GetTfo() SocketConfig_TCPFastOpenState

+ func (x *SocketConfig) GetTproxy() SocketConfig_TProxyMode

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

+ func (x *SocketConfig) Reset()

+ func (x *SocketConfig) String() string

+ type SocketConfig_TCPFastOpenState int32

+ const SocketConfig_AsIs

+ const SocketConfig_Disable

+ const SocketConfig_Enable

+ func (SocketConfig_TCPFastOpenState) Descriptor() protoreflect.EnumDescriptor

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

+ func (SocketConfig_TCPFastOpenState) Type() protoreflect.EnumType

+ func (x SocketConfig_TCPFastOpenState) Enum() *SocketConfig_TCPFastOpenState

+ func (x SocketConfig_TCPFastOpenState) Number() protoreflect.EnumNumber

+ func (x SocketConfig_TCPFastOpenState) String() string

+ type SocketConfig_TProxyMode int32

+ const SocketConfig_Off

+ const SocketConfig_Redirect

+ const SocketConfig_TProxy

+ func (SocketConfig_TProxyMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (SocketConfig_TProxyMode) Type() protoreflect.EnumType

+ func (m SocketConfig_TProxyMode) IsEnabled() bool

+ func (x SocketConfig_TProxyMode) Enum() *SocketConfig_TProxyMode

+ func (x SocketConfig_TProxyMode) Number() protoreflect.EnumNumber

+ func (x SocketConfig_TProxyMode) String() string

+ type StatCouterConnection struct

+ ReadCounter stats.Counter

+ WriteCounter stats.Counter

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

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

+ type StreamConfig struct

+ Protocol TransportProtocol

+ ProtocolName string

+ SecuritySettings []*serial.TypedMessage

+ SecurityType string

+ SocketSettings *SocketConfig

+ TransportSettings []*TransportConfig

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

+ func (*StreamConfig) ProtoMessage()

+ func (c *StreamConfig) GetEffectiveProtocol() string

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

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

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

+ func (c *StreamConfig) HasSecuritySettings() bool

+ func (x *StreamConfig) GetProtocol() TransportProtocol

+ func (x *StreamConfig) GetProtocolName() string

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

+ func (x *StreamConfig) GetSecurityType() string

+ func (x *StreamConfig) GetSocketSettings() *SocketConfig

+ func (x *StreamConfig) GetTransportSettings() []*TransportConfig

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

+ func (x *StreamConfig) Reset()

+ func (x *StreamConfig) String() string

+ type SystemDialer interface

+ Dial func(ctx context.Context, source net.Address, destination net.Destination, ...) (net.Conn, error)

+ func WithAdapter(dialer SystemDialerAdapter) SystemDialer

+ type SystemDialerAdapter interface

+ Dial func(network string, address string) (net.Conn, error)

+ type TransportConfig struct

+ Protocol TransportProtocol

+ ProtocolName string

+ Settings *serial.TypedMessage

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

+ func (*TransportConfig) ProtoMessage()

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

+ func (c *TransportConfig) GetUnifiedProtocolName() string

+ func (x *TransportConfig) GetProtocol() TransportProtocol

+ func (x *TransportConfig) GetProtocolName() string

+ func (x *TransportConfig) GetSettings() *serial.TypedMessage

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

+ func (x *TransportConfig) Reset()

+ func (x *TransportConfig) String() string

+ type TransportProtocol int32

+ const TransportProtocol_DomainSocket

+ const TransportProtocol_HTTP

+ const TransportProtocol_MKCP

+ const TransportProtocol_TCP

+ const TransportProtocol_UDP

+ const TransportProtocol_WebSocket

+ func (TransportProtocol) Descriptor() protoreflect.EnumDescriptor

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

+ func (TransportProtocol) Type() protoreflect.EnumType

+ func (x TransportProtocol) Enum() *TransportProtocol

+ func (x TransportProtocol) Number() protoreflect.EnumNumber

+ func (x TransportProtocol) String() string

Incompatible versions in this module

v3.50.2+incompatible

Oct 29, 2018

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