connection

Aug 28, 2023

Changes in this version

+ type ReconnectListenerWrapper struct

+ func NewReconnectListenerWrapper(ctx context.Context, baseConn watermillnet.Connection, ...) *ReconnectListenerWrapper

+ func (rw *ReconnectListenerWrapper) Close() error

+ func (rw *ReconnectListenerWrapper) Connect(addr net.Addr) error

+ func (rw *ReconnectListenerWrapper) LocalAddr() net.Addr

+ func (rw *ReconnectListenerWrapper) Read(b []byte) (n int, err error)

+ func (rw *ReconnectListenerWrapper) RemoteAddr() net.Addr

+ func (rw *ReconnectListenerWrapper) SetDeadline(t time.Time) error

+ func (rw *ReconnectListenerWrapper) SetReadDeadline(t time.Time) error

+ func (rw *ReconnectListenerWrapper) SetWriteDeadline(t time.Time) error

+ func (rw *ReconnectListenerWrapper) Write(b []byte) (n int, err error)

type TCP4Listener

+ func NewTCP4TlsListener(addr string, config *tls.Config) (*TCP4Listener, error)

+ type TCP4TlsConnection struct

+ Closed bool

+ func NewTCPTlsConnection(keepAlive time.Duration, config *tls.Config) *TCP4TlsConnection

+ func (t4tc *TCP4TlsConnection) WithRootCA(rootCAPath string) error

+ func (tc *TCP4TlsConnection) Close() error

+ func (tc *TCP4TlsConnection) Connect(addr net.Addr) error

+ func (tc *TCP4TlsConnection) LocalAddr() net.Addr

+ func (tc *TCP4TlsConnection) Read(b []byte) (n int, err error)

+ func (tc *TCP4TlsConnection) RemoteAddr() net.Addr

+ func (tc *TCP4TlsConnection) SetDeadline(t time.Time) error

+ func (tc *TCP4TlsConnection) SetReadDeadline(t time.Time) error

+ func (tc *TCP4TlsConnection) SetWriteDeadline(t time.Time) error

+ func (tc *TCP4TlsConnection) Write(b []byte) (n int, err error)

+ type TCP4TlsListener struct

+ func (tl *TCP4TlsListener) Accept() (watermillnet.Connection, error)

+ func (tl *TCP4TlsListener) Addr() net.Addr

+ func (tl *TCP4TlsListener) Close() error

Aug 24, 2023

Changes in this version

+ func DefaultErrorFilter(err error) error

+ type Backoff retry.Backoff

+ type ErrorFilter func(err error) error

+ type ReconnectWrapper struct

+ func NewReconnectWrapper(ctx context.Context, baseConn watermillnet.Connection, backoff Backoff, ...) *ReconnectWrapper

+ func (rw *ReconnectWrapper) Close() error

+ func (rw *ReconnectWrapper) Connect(addr net.Addr) error

+ func (rw *ReconnectWrapper) LocalAddr() net.Addr

+ func (rw *ReconnectWrapper) Read(b []byte) (n int, err error)

+ func (rw *ReconnectWrapper) RemoteAddr() net.Addr

+ func (rw *ReconnectWrapper) SetDeadline(t time.Time) error

+ func (rw *ReconnectWrapper) SetReadDeadline(t time.Time) error

+ func (rw *ReconnectWrapper) SetWriteDeadline(t time.Time) error

+ func (rw *ReconnectWrapper) Write(b []byte) (n int, err error)

Aug 22, 2023

Changes in this version

+ var ErrNotConnected = errors.New("not connected")

+ type TCP4Connection struct

+ Closed bool

+ func NewTCPConnection(dialer net.Dialer) *TCP4Connection

+ func (tc *TCP4Connection) Close() error

+ func (tc *TCP4Connection) Connect(addr net.Addr) error

+ func (tc *TCP4Connection) LocalAddr() net.Addr

+ func (tc *TCP4Connection) Read(b []byte) (n int, err error)

+ func (tc *TCP4Connection) RemoteAddr() net.Addr

+ func (tc *TCP4Connection) SetDeadline(t time.Time) error

+ func (tc *TCP4Connection) SetReadDeadline(t time.Time) error

+ func (tc *TCP4Connection) SetWriteDeadline(t time.Time) error

+ func (tc *TCP4Connection) Write(b []byte) (n int, err error)

+ type TCP4Listener struct

+ func NewTCP4Listener(l net.Listener) *TCP4Listener

+ func (tl *TCP4Listener) Accept() (watermillnet.Connection, error)

+ func (tl *TCP4Listener) Addr() net.Addr

+ func (tl *TCP4Listener) Close() error