internet

Documentation

Index

• Variables
• func DialToDest(src v2net.Address, dest v2net.Destination) (net.Conn, error)
• type Connection
  • func Dial(src v2net.Address, dest v2net.Destination, settings *StreamSettings) (Connection, error)
• type ConnectionHandler
• type Dialer
• type ListenFunc
• type Listener
• type Reusable
• type StreamConnectionType
• type StreamSettings
  • func (this *StreamSettings) IsCapableOf(streamType StreamConnectionType) bool
• type TCPHub
  • func ListenTCP(address v2net.Address, port v2net.Port, callback ConnectionHandler, ...) (*TCPHub, error)
  • func (this *TCPHub) Close()

Variables

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

Functions

func DialToDest

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

Types

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 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 StreamConnectionType

type StreamConnectionType int

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

type StreamSettings

type StreamSettings struct {
	Type StreamConnectionType
}

func (*StreamSettings) IsCapableOf

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

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