nethelper

Documentation

Overview

Package nethelper wraps various kind of network support with universal api to dial and listen you need to import according packages to enabled certain network supprot

to support

		tcp/tcp4/tcp6/unix (with or without tls)
		udp/udp4/udp6 (without tls)
		unixpacket/unixgram (with or without tls)
 import _ "arhat.dev/pkg/nethelper/stdnet"

to support

		udp/udp4/udp6 (with tls)
 import _ "arhat.dev/pkg/nethelper/piondtls"

to support

		pipe (with or without tls)
 import _ "arhat.dev/pkg/nethelper/pipenet"

Index

• Variables
• func Dial(ctx context.Context, dialer interface{}, network, addr string, ...) (net.Conn, error)
• func Forward(ctx context.Context, dialer interface{}, network string, addr string, ...) (downstream io.ReadCloser, closeWrite func(), readErrCh <-chan error, err error)
• func Listen(ctx context.Context, config interface{}, network, addr string, ...) (interface{}, error)
• func Register(network string, supportTLS bool, listen ListenFunc, dial DialFunc)
• type DialFunc
• type ListenFunc

Variables

var (
	ErrDialerInvalid       = errors.New("invalid dialer")
	ErrTLSConfigInvalid    = errors.New("invalid tls config")
	ErrListenConfigInvalid = errors.New("invalid listen config")
)

Functions

func Dial

func Dial(ctx context.Context, dialer interface{}, network, addr string, tlsConfig interface{}) (net.Conn, error)

func Forward

func Forward(
	ctx context.Context,
	dialer interface{},
	network string,
	addr string,
	upstream io.Reader,
	packetReadBuf []byte,
) (
	downstream io.ReadCloser,
	closeWrite func(),
	readErrCh <-chan error,
	err error,
)

Forward network traffic the parameters:

ctx is used to cancel dial operation
dialer is optional for custom network dial options
network is the network name, e.g. tcp, udp, tcp4
addr is the endpoint address
upstream is the data channel to the endpoint
packetReadBuf is the buffer used for udp/ip/unix connection

the return values:

downstream is used to read data sent from the forwarded port and close connection
closeWrite is intended to close write in stream oriented connection
readErrCh is used to check read error and whether donwstream reading finished
err if not nil the port forward failed

func Listen

func Listen(
	ctx context.Context,
	config interface{},
	network, addr string,
	tlsConfig interface{},
) (interface{}, error)

func Register

func Register(network string, supportTLS bool, listen ListenFunc, dial DialFunc)

Types

type DialFunc

type DialFunc func(
	ctx context.Context,
	dialer interface{},
	network, addr string,
	tlsConfig interface{},
) (net.Conn, error)

type ListenFunc

type ListenFunc func(
	ctx context.Context,
	config interface{},
	network, addr string,
	tlsConfig interface{},
) (interface{}, error)