Versions in this module Expand all Collapse all v1 v1.4.4 Aug 10, 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
Go to main page