Versions in this module Expand all Collapse all v1 v1.0.2 Apr 30, 2024 Changes in this version + type DebugLogNetConn struct + func NewDebugCustomLogNetConn(conn net.Conn, log DebugLogger) *DebugLogNetConn + func NewDebugLogNetConn(conn net.Conn) *DebugLogNetConn + func (lc *DebugLogNetConn) Close() error + func (lc *DebugLogNetConn) LocalAddr() net.Addr + func (lc *DebugLogNetConn) Read(b []byte) (n int, err error) + func (lc *DebugLogNetConn) RemoteAddr() net.Addr + func (lc *DebugLogNetConn) SetDeadline(t time.Time) error + func (lc *DebugLogNetConn) SetReadDeadline(t time.Time) error + func (lc *DebugLogNetConn) SetWriteDeadline(t time.Time) error + func (lc *DebugLogNetConn) Write(b []byte) (n int, err error) + type DebugLogger interface + Debug func(msg string, args ...any) + type DebugLoggerFunc func(msg string, args ...any) + func (d DebugLoggerFunc) Debug(msg string, args ...any) + type DialFn func(network, addr string) (net.Conn, error) + var DefaultDial DialFn = net.Dial + type GetOption func(*getOptions) + func WithUUID(uuid string) GetOption + type NatsConnProxy struct + func NewNatsConnProxy(nc *nats.Conn, subject string, connPool NetConnManager) *NatsConnProxy + func (ncp NatsConnProxy) Start(ctx context.Context) error + type NatsNetConn struct + func NewNatsNetConn(nc *nats.Conn, subject string, addr *net.TCPAddr) (*NatsNetConn, error) + func (c *NatsNetConn) Close() error + func (c *NatsNetConn) LocalAddr() net.Addr + func (c *NatsNetConn) Read(b []byte) (n int, err error) + func (c *NatsNetConn) RemoteAddr() net.Addr + func (c *NatsNetConn) SetDeadline(t time.Time) error + func (c *NatsNetConn) SetReadDeadline(t time.Time) error + func (c *NatsNetConn) SetWriteDeadline(t time.Time) error + func (c *NatsNetConn) Write(b []byte) (n int, err error) + type NetConnManager interface + Get func(addr *net.TCPAddr, options ...GetOption) (net.Conn, error) + type NetConnPullManager struct + func NewNetConnPullManager(fn DialFn) *NetConnPullManager + func (cp *NetConnPullManager) Close() error + func (cp *NetConnPullManager) Get(addr *net.TCPAddr, options ...GetOption) (net.Conn, error)
Go to main page