internet

package
v1.18.1 Latest Latest
Warning

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

Go to latest
Published: Jul 4, 2016 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 SysFd added in v1.18.1

type SysFd interface {
	SysFd() (int, 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()

Directories

Path Synopsis
Package kcp - A Fast and Reliable ARQ Protocol
Package kcp - A Fast and Reliable ARQ Protocol

Jump to

Keyboard shortcuts

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