reverse

Documentation

Index

• Constants
• Variables
• type Dialer
  • func NewDialer(l net.Listener, opt ...DialerOption) *Dialer
  • func (d *Dialer) Close() (e error)
  • func (d *Dialer) Dial(network, addr string) (c net.Conn, e error)
  • func (d *Dialer) DialContext(ctx context.Context, network, addr string) (c net.Conn, e error)
  • func (d *Dialer) Serve() error
• type DialerOption
  • func WithDialerHeart(heart time.Duration) DialerOption
  • func WithDialerHeartTimeout(timeout time.Duration) DialerOption
  • func WithDialerSynAck(synAck bool) DialerOption
  • func WithDialerTimeout(timeout time.Duration) DialerOption
• type Listener
  • func Listen(addr net.Addr, opt ...ListenerOption) *Listener
  • func (l *Listener) Accept() (c net.Conn, e error)
  • func (l *Listener) Addr() net.Addr
  • func (l *Listener) Close() (e error)
• type ListenerOption
  • func WithListenerDial(f func(network, address string) (net.Conn, error)) ListenerOption
  • func WithListenerDialContext(f func(ctx context.Context, network, address string) (net.Conn, error)) ListenerOption
  • func WithListenerHeartTimeout(d time.Duration) ListenerOption
  • func WithListenerSynAck(synAck bool) ListenerOption
  • func WithListenerSynAckTimeout(d time.Duration) ListenerOption

Constants

const (
	DatagramHeart = uint8(1) + iota
	DatagramSyn
	DatagramSynAck
	DatagramAck
)

const DatagramFlag = uint16(3553)

const DatagramLen = 2 + 1 + 1

const DatagramVersion = uint8(1)

Variables

var ErrProtocol = errors.New(`protocol error`)

Types

type Dialer

type Dialer struct {
	// contains filtered or unexported fields
}

func NewDialer

func NewDialer(l net.Listener, opt ...DialerOption) *Dialer

func (*Dialer) Close

func (d *Dialer) Close() (e error)

func (*Dialer) Dial

func (d *Dialer) Dial(network, addr string) (c net.Conn, e error)

func (*Dialer) DialContext

func (d *Dialer) DialContext(ctx context.Context, network, addr string) (c net.Conn, e error)

func (*Dialer) Serve

func (d *Dialer) Serve() error

type DialerOption

type DialerOption interface {
	// contains filtered or unexported methods
}

func WithDialerHeart

func WithDialerHeart(heart time.Duration) DialerOption

func WithDialerHeartTimeout

func WithDialerHeartTimeout(timeout time.Duration) DialerOption

func WithDialerSynAck

func WithDialerSynAck(synAck bool) DialerOption

func WithDialerTimeout

func WithDialerTimeout(timeout time.Duration) DialerOption

type Listener

type Listener struct {
	// contains filtered or unexported fields
}

func Listen

func Listen(addr net.Addr, opt ...ListenerOption) *Listener

func (*Listener) Accept

func (l *Listener) Accept() (c net.Conn, e error)

Accept waits for and returns the next connection to the listener.

func (*Listener) Addr

func (l *Listener) Addr() net.Addr

Addr returns the listener's network address.

func (*Listener) Close

func (l *Listener) Close() (e error)

Close closes the listener. Any blocked Accept operations will be unblocked and return errors.

type ListenerOption

type ListenerOption interface {
	// contains filtered or unexported methods
}

func WithListenerDial

func WithListenerDial(f func(network, address string) (net.Conn, error)) ListenerOption

func WithListenerDialContext

func WithListenerDialContext(f func(ctx context.Context, network, address string) (net.Conn, error)) ListenerOption

func WithListenerHeartTimeout

func WithListenerHeartTimeout(d time.Duration) ListenerOption

func WithListenerSynAck

func WithListenerSynAck(synAck bool) ListenerOption

func WithListenerSynAckTimeout

func WithListenerSynAckTimeout(d time.Duration) ListenerOption