client

Aug 14, 2024

Changes in this version

type Dialer

+ Token string

Jul 4, 2024

Changes in this version

+ var ErrClosed = errors.New("closed")

+ type Dialer struct

+ TLSConfig *tls.Config

+ URL *url.URL

+ func (d *Dialer) Dial(ctx context.Context, endpointID string) (net.Conn, error)

+ type Forwarder struct

+ func (f *Forwarder) Close() error

+ func (f *Forwarder) Wait() error

+ type Listener interface

+ EndpointID func() string

+ type Logger interface

+ Debug func(msg string, fields ...zap.Field)

+ Error func(msg string, fields ...zap.Field)

+ Info func(msg string, fields ...zap.Field)

+ Sync func() error

+ Warn func(msg string, fields ...zap.Field)

+ type Upstream struct

+ Logger Logger

+ MaxReconnectBackoff time.Duration

+ MinReconnectBackoff time.Duration

+ TLSConfig *tls.Config

+ Token string

+ URL *url.URL

+ func (u *Upstream) Listen(ctx context.Context, endpointID string) (Listener, error)

+ func (u *Upstream) ListenAndForward(ctx context.Context, endpointID string, addr string) (*Forwarder, error)