connector

Documentation

Index

• Variables
• type BindOption
  • func BacklogBindOption(backlog int) BindOption
  • func MuxBindOption(mux bool) BindOption
  • func UDPConnTTLBindOption(ttl time.Duration) BindOption
  • func UDPDataBufferSizeBindOption(size int) BindOption
  • func UDPDataQueueSizeBindOption(size int) BindOption
• type BindOptions
• type ConnectOption
  • func DialerConnectOption(dialer xnet.Dialer) ConnectOption
• type ConnectOptions
• type IBinder
• type IConnector
• type IHandshaker
• type Option
  • func AuthOption(auth *url.Userinfo) Option
  • func LoggerOption(logger logger.ILogger) Option
  • func TLSConfigOption(tlsConfig *tls.Config) Option
• type Options

Variables

var (
	ErrBindUnsupported = errors.New("bind unsupported")
)

Types

type BindOption

type BindOption func(opts *BindOptions)

func BacklogBindOption

func BacklogBindOption(backlog int) BindOption

func MuxBindOption

func MuxBindOption(mux bool) BindOption

func UDPConnTTLBindOption

func UDPConnTTLBindOption(ttl time.Duration) BindOption

func UDPDataBufferSizeBindOption

func UDPDataBufferSizeBindOption(size int) BindOption

func UDPDataQueueSizeBindOption

func UDPDataQueueSizeBindOption(size int) BindOption

type BindOptions

type BindOptions struct {
	Mux               bool
	Backlog           int
	UDPDataQueueSize  int
	UDPDataBufferSize int
	UDPConnTTL        time.Duration
}

type ConnectOption

type ConnectOption func(opts *ConnectOptions)

func DialerConnectOption

func DialerConnectOption(dialer xnet.Dialer) ConnectOption

type ConnectOptions

type ConnectOptions struct {
	Dialer xnet.Dialer
}

type IBinder

type IBinder interface {
	Bind(ctx context.Context, conn net.Conn, network, address string, opts ...BindOption) (net.Listener, error)
}

type IConnector

type IConnector interface {
	Init(metadata.IMetaData) error
	Connect(ctx context.Context, conn net.Conn, network, address string, opts ...ConnectOption) (net.Conn, error)
}

IConnector is responsible for connecting to the destination address.

type IHandshaker

type IHandshaker interface {
	Handshake(ctx context.Context, conn net.Conn) (net.Conn, error)
}

type Option

type Option func(opts *Options)

func AuthOption

func AuthOption(auth *url.Userinfo) Option

func LoggerOption

func LoggerOption(logger logger.ILogger) Option

func TLSConfigOption

func TLSConfigOption(tlsConfig *tls.Config) Option

type Options

type Options struct {
	Auth      *url.Userinfo
	TLSConfig *tls.Config
	Logger    logger.ILogger
}