internet

package

Go to main page

Versions in this module

v1

v1.5.1

Sep 19, 2021

v1.5.0

Sep 8, 2021

v1.4.9

Sep 5, 2021

v1.4.8

Sep 4, 2021

v1.4.7

Sep 4, 2021

v1.4.6

Sep 4, 2021

v1.4.5

Sep 3, 2021

v1.4.4

Aug 31, 2021

v1.4.3

Aug 31, 2021

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 DomainStrategy_name = map[int32]string

+ var DomainStrategy_value = map[string]int32

+ var File_transport_internet_config_proto protoreflect.FileDescriptor

+ 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 ContextWithLookupDomain(ctx context.Context, domain string) context.Context

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

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

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

+ 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 LookupDomainFromContext(ctx context.Context) string

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

+ func (d *DefaultSystemDialer) Init(dc dns.Client, om outbound.Manager)

+ type Dialer interface

+ Address func() net.Address

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

+ type DomainStrategy int32

+ const DomainStrategy_AS_IS

+ const DomainStrategy_USE_IP

+ const DomainStrategy_USE_IP4

+ const DomainStrategy_USE_IP6

+ func (DomainStrategy) Descriptor() protoreflect.EnumDescriptor

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

+ func (DomainStrategy) Type() protoreflect.EnumType

+ func (x DomainStrategy) Enum() *DomainStrategy

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

+ func (x DomainStrategy) String() string

+ type FileLocker struct

+ func (fl *FileLocker) Acquire() error

+ func (fl *FileLocker) Release()

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

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

+ type MemoryStreamConfig struct

+ ProtocolName string

+ ProtocolSettings interface{}

+ SecuritySettings interface{}

+ SecurityType string

+ SocketSettings *SocketConfig

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

+ type PacketConnWrapper struct

+ func (c *PacketConnWrapper) Close() error

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

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

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

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

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

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

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

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

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

+ type PacketHeader interface

+ Serialize func([]byte)

+ Size func() int32

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

+ type ProxyConfig struct

+ Tag string

+ TransportLayerProxy bool

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

+ func (*ProxyConfig) ProtoMessage()

+ func (c *ProxyConfig) HasTag() bool

+ func (x *ProxyConfig) GetTag() string

+ func (x *ProxyConfig) GetTransportLayerProxy() bool

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

+ func (v *SimpleSystemDialer) Init(_ dns.Client, _ outbound.Manager)

+ type SocketConfig struct

+ AcceptProxyProtocol bool

+ BindAddress []byte

+ BindPort uint32

+ DialerProxy string

+ DomainStrategy DomainStrategy

+ Mark int32

+ ReceiveOriginalDestAddress bool

+ Tfo int32

+ Tproxy SocketConfig_TProxyMode

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

+ func (*SocketConfig) ProtoMessage()

+ func (v *SocketConfig) ParseTFOValue() int

+ func (x *SocketConfig) GetAcceptProxyProtocol() bool

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

+ func (x *SocketConfig) GetBindPort() uint32

+ func (x *SocketConfig) GetDialerProxy() string

+ func (x *SocketConfig) GetDomainStrategy() DomainStrategy

+ func (x *SocketConfig) GetMark() int32

+ func (x *SocketConfig) GetReceiveOriginalDestAddress() bool

+ func (x *SocketConfig) GetTfo() int32

+ func (x *SocketConfig) GetTproxy() SocketConfig_TProxyMode

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

+ func (x *SocketConfig) Reset()

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

+ Init func(dc dns.Client, om outbound.Manager)

+ 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

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