connector

Dec 23, 2024

Changes in this version

type ConnectOption

+ func DialerConnectOption(dialer xnet.Dialer) ConnectOption

type ConnectOptions

+ Dialer xnet.Dialer

Dec 21, 2023

Changes in this version

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

+ type BindOption func(opts *BindOptions)

+ 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 struct

+ Backlog int

+ Mux bool

+ UDPConnTTL time.Duration

+ UDPDataBufferSize int

+ UDPDataQueueSize int

+ type ConnectOption func(opts *ConnectOptions)

+ func NetDialerConnectOption(netd *dialer.NetDialer) ConnectOption

+ type ConnectOptions struct

+ NetDialer *dialer.NetDialer

+ type IBinder interface

+ Bind func(ctx context.Context, conn net.Conn, network, address string, ...) (net.Listener, error)

+ type IConnector interface

+ Connect func(ctx context.Context, conn net.Conn, network, address string, ...) (net.Conn, error)

+ Init func(metadata.IMetaData) error

+ type IHandshaker interface

+ Handshake func(ctx context.Context, conn net.Conn) (net.Conn, error)

+ type NewConnector func(opts ...Option) IConnector

+ type Option func(opts *Options)

+ func AuthOption(auth *url.Userinfo) Option

+ func LoggerOption(logger logger.ILogger) Option

+ func TLSConfigOption(tlsConfig *tls.Config) Option

+ type Options struct

+ Auth *url.Userinfo

+ Logger logger.ILogger

+ TLSConfig *tls.Config