connector

type BindOption func(opts *BindOptions)

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

type ConnectOption func(opts *ConnectOptions)

type ConnectOptions struct {
	NetDialer *dialer.NetDialer
}

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

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

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

type NewConnector func(opts ...Option) IConnector

type Option func(opts *Options)

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