internet

Documentation

Index

• Variables
• 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
• func UseAlternativeSystemDialer(dialer SystemDialer)
• type Authenticator
  • func CreateAuthenticator(name string, config AuthenticatorConfig) (Authenticator, error)
  • func NewAuthenticatorChain(auths ...Authenticator) Authenticator
• type AuthenticatorChain
  • func (this *AuthenticatorChain) Open(payload *alloc.Buffer) bool
  • func (this *AuthenticatorChain) Overhead() int
  • func (this *AuthenticatorChain) Seal(payload *alloc.Buffer)
• type AuthenticatorConfig
  • func CreateAuthenticatorConfig(rawConfig []byte) (string, AuthenticatorConfig, error)
• type AuthenticatorFactory
• type Connection
  • func Dial(src v2net.Address, dest v2net.Destination, settings *StreamSettings) (Connection, error)
• type ConnectionHandler
• type DefaultSystemDialer
  • func (this *DefaultSystemDialer) Dial(src v2net.Address, dest v2net.Destination) (net.Conn, error)
• type Dialer
• type ListenFunc
• type Listener
• type Reusable
• type SimpleSystemDialer
  • func (this *SimpleSystemDialer) Dial(src v2net.Address, dest v2net.Destination) (net.Conn, error)
• type StreamConnectionType
• type StreamSecurityType
• type StreamSettings
  • func (this *StreamSettings) IsCapableOf(streamType StreamConnectionType) bool
• type SysFd
• type SystemDialer
  • func WithAdapter(dialer SystemDialerAdapter) SystemDialer
• type SystemDialerAdapter
• type TCPHub
  • func ListenTCP(address v2net.Address, port v2net.Port, callback ConnectionHandler, ...) (*TCPHub, error)
  • func (this *TCPHub) Close()
• type TLSSettings
  • func (this *TLSSettings) GetTLSConfig() *tls.Config

Variables

var (
	ErrDuplicatedAuthenticator = errors.New("Authenticator already registered.")
	ErrAuthenticatorNotFound   = errors.New("Authenticator not found.")
)

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

Functions

func DialToDest

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

func RegisterAuthenticator

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

func SubstituteDialer

func SubstituteDialer(dialer SystemDialerAdapter) error

SubstituteDialer replaces the current system dialer with a given one. Caller must ensure there is no race condition. @Deprecated: Use UseAlternativeSimpleSystemDialer.

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 Authenticator

type Authenticator interface {
	Seal(*alloc.Buffer)
	Open(*alloc.Buffer) bool
	Overhead() int
}

func CreateAuthenticator

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

func NewAuthenticatorChain

func NewAuthenticatorChain(auths ...Authenticator) Authenticator

type AuthenticatorChain

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

func (*AuthenticatorChain) Open

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

func (*AuthenticatorChain) Overhead

func (this *AuthenticatorChain) Overhead() int

func (*AuthenticatorChain) Seal

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

type AuthenticatorConfig

type AuthenticatorConfig interface {
}

func CreateAuthenticatorConfig

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

type AuthenticatorFactory

type AuthenticatorFactory interface {
	Create(AuthenticatorConfig) Authenticator
}

type Connection

type Connection interface {
	net.Conn
	Reusable
}

func Dial

func Dial(src v2net.Address, dest v2net.Destination, settings *StreamSettings) (Connection, error)

type ConnectionHandler

type ConnectionHandler func(Connection)

type DefaultSystemDialer

type DefaultSystemDialer struct {
}

func (*DefaultSystemDialer) Dial

func (this *DefaultSystemDialer) Dial(src v2net.Address, dest v2net.Destination) (net.Conn, error)

type Dialer

type Dialer func(src v2net.Address, dest v2net.Destination) (Connection, error)

var (
	TCPDialer    Dialer
	KCPDialer    Dialer
	RawTCPDialer Dialer
	UDPDialer    Dialer
)

type ListenFunc

type ListenFunc func(address v2net.Address, port v2net.Port) (Listener, error)

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

	KCPListenFunc    ListenFunc
	TCPListenFunc    ListenFunc
	RawTCPListenFunc ListenFunc
)

type Listener

type Listener interface {
	Accept() (Connection, error)
	Close() error
	Addr() net.Addr
}

type Reusable

type Reusable interface {
	Reusable() bool
	SetReusable(reuse bool)
}

type SimpleSystemDialer

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

func (*SimpleSystemDialer) Dial

func (this *SimpleSystemDialer) Dial(src v2net.Address, dest v2net.Destination) (net.Conn, error)

type StreamConnectionType

type StreamConnectionType int

const (
	StreamConnectionTypeRawTCP StreamConnectionType = 1
	StreamConnectionTypeTCP    StreamConnectionType = 2
	StreamConnectionTypeKCP    StreamConnectionType = 4
)

type StreamSecurityType

type StreamSecurityType int

const (
	StreamSecurityTypeNone StreamSecurityType = 0
	StreamSecurityTypeTLS  StreamSecurityType = 1
)

type StreamSettings

type StreamSettings struct {
	Type        StreamConnectionType
	Security    StreamSecurityType
	TLSSettings *TLSSettings
}

func (*StreamSettings) IsCapableOf

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

type SysFd

type SysFd interface {
	SysFd() (int, error)
}

type SystemDialer

type SystemDialer interface {
	Dial(source v2net.Address, destination v2net.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 TCPHub

type TCPHub struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func ListenTCP

func ListenTCP(address v2net.Address, port v2net.Port, callback ConnectionHandler, settings *StreamSettings) (*TCPHub, error)

func (*TCPHub) Close

func (this *TCPHub) Close()

type TLSSettings

type TLSSettings struct {
	AllowInsecure bool
	Certs         []tls.Certificate
}

func (*TLSSettings) GetTLSConfig

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