internet

package
v3.37.4 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2018 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 ContextWithDialerSource 

func ContextWithDialerSource(ctx context.Context, addr net.Address) context.Context

func ContextWithSecuritySettings 

func ContextWithSecuritySettings(ctx context.Context, securitySettings interface{}) context.Context

func ContextWithStreamSettings 

func ContextWithStreamSettings(ctx context.Context, streamSettings *StreamConfig) context.Context

func ContextWithTransportSettings 

func ContextWithTransportSettings(ctx context.Context, transportSettings interface{}) context.Context

func CreateTransportConfig 

func CreateTransportConfig(protocol TransportProtocol) (interface{}, error)

func CreateTransportConfigByName added in v3.37.1 

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

func DialSystem 

func DialSystem(ctx context.Context, src net.Address, dest net.Destination) (net.Conn, error)

DialSystem calls system dialer to create a network connection.

func DialerSourceFromContext 

func DialerSourceFromContext(ctx context.Context) net.Address

func RegisterProtocolConfigCreator 

func RegisterProtocolConfigCreator(protocol TransportProtocol, creator ConfigCreator) error

func RegisterProtocolConfigCreatorByName added in v3.37.1 

func RegisterProtocolConfigCreatorByName(name string, creator ConfigCreator) error

func RegisterTransportDialer 

func RegisterTransportDialer(protocol string, dialer Dialer) error

func RegisterTransportListener 

func RegisterTransportListener(protocol string, listener ListenFunc) error

func SecuritySettingsFromContext 

func SecuritySettingsFromContext(ctx context.Context) interface{}

func TransportSettingsFromContext 

func TransportSettingsFromContext(ctx context.Context) interface{}

func UseAlternativeSystemDialer 

func UseAlternativeSystemDialer(dialer SystemDialer)

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

Types

type ConfigCreator 

type ConfigCreator func() interface{}

type ConnHandler added in v3.8.1 

type ConnHandler func(Connection)

type Connection 

type Connection interface {
	net.Conn
}

func Dial 

func Dial(ctx context.Context, dest net.Destination) (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 DefaultSystemDialer 

type DefaultSystemDialer struct {
}

func (DefaultSystemDialer) Dial 

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

type Dialer 

type Dialer func(ctx context.Context, dest net.Destination) (Connection, error)

type ListenFunc 

type ListenFunc func(ctx context.Context, address net.Address, port net.Port, 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, handler ConnHandler) (Listener, error)

type PacketHeader 

type PacketHeader interface {
	Size() int32
	Write([]byte) (int, error)
}

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 added in v3.23.1 

func (m *ProxyConfig) XXX_DiscardUnknown()

func (*ProxyConfig) XXX_Marshal added in v3.23.1 

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

func (*ProxyConfig) XXX_Merge added in v3.23.1 

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

func (*ProxyConfig) XXX_Size added in v3.23.1 

func (m *ProxyConfig) XXX_Size() int

func (*ProxyConfig) XXX_Unmarshal added in v3.23.1 

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) (net.Conn, error)

type StatCouterConnection added in v3.17.1 

type StatCouterConnection struct {
	Connection
	Uplink   addInt64
	Downlink addInt64
}

func (*StatCouterConnection) Read added in v3.17.1 

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

func (*StatCouterConnection) Write added in v3.17.1 

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func StreamSettingsFromContext 

func StreamSettingsFromContext(ctx context.Context) *StreamConfig

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 added in v3.37.1 

func (m *StreamConfig) GetProtocolName() string

func (*StreamConfig) GetSecuritySettings 

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

func (*StreamConfig) GetSecurityType 

func (m *StreamConfig) GetSecurityType() string

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 added in v3.23.1 

func (m *StreamConfig) XXX_DiscardUnknown()

func (*StreamConfig) XXX_Marshal added in v3.23.1 

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

func (*StreamConfig) XXX_Merge added in v3.23.1 

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

func (*StreamConfig) XXX_Size added in v3.23.1 

func (m *StreamConfig) XXX_Size() int

func (*StreamConfig) XXX_Unmarshal added in v3.23.1 

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

type SystemDialer 

type SystemDialer interface {
	Dial(ctx context.Context, source net.Address, destination net.Destination) (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 added in v3.37.1 

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 added in v3.37.1 

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 added in v3.23.1 

func (m *TransportConfig) XXX_DiscardUnknown()

func (*TransportConfig) XXX_Marshal added in v3.23.1 

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

func (*TransportConfig) XXX_Merge added in v3.23.1 

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

func (*TransportConfig) XXX_Size added in v3.23.1 

func (m *TransportConfig) XXX_Size() int

func (*TransportConfig) XXX_Unmarshal added in v3.23.1 

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.