connet

Dec 28, 2025

Changes in this version

+ var ErrClientClosed = errors.New("client closed")

+ var ErrDestinationClosed = fmt.Errorf("destination closed: %w", errEndpointClosed)

+ var ErrSourceClosed = fmt.Errorf("source closed: %w", errEndpointClosed)

+ var ErrSourceConnect = errors.New("cannot connect destination")

+ var ErrSourceConnectDestinations = fmt.Errorf("%w: all peer connections were unreachable", ErrSourceConnect)

+ var ErrSourceNoActiveDestinations = fmt.Errorf("%w: no active peer connections", ErrSourceConnect)

type ClientStatus

+ DirectAddr string

+ Metadata string

+ ServerAddr string

type Option

+ func HandshakeIdleTimeout(d time.Duration) Option

+ func Metadata(metadata string) Option

+ func ServerAddress(address string) Option

+ func ServerCAs(cas *x509.CertPool) Option

+ func ServerCAsFile(certFile string) Option

+ func ServerName(name string) Option

+ type StatusRemotePeer struct

+ Connections []StatusRemotePeerConnection

+ ID string

+ Metadata string

+ type StatusRemotePeerConnection struct

+ Addr string

+ Style string

Dec 13, 2025

Changes in this version

type DestinationConfig

+ DialTimeout time.Duration

+ Endpoint model.Endpoint

+ Proxy model.ProxyVersion

+ RelayEncryptions []model.EncryptionScheme

+ Route model.RouteOption

+ func (cfg DestinationConfig) WithDialTimeout(timeout time.Duration) DestinationConfig

+ func (cfg DestinationConfig) WithProxy(proxy model.ProxyVersion) DestinationConfig

+ func (cfg DestinationConfig) WithRelayEncryptions(schemes ...model.EncryptionScheme) DestinationConfig

+ func (cfg DestinationConfig) WithRoute(route model.RouteOption) DestinationConfig

+ type DestinationStatus struct

+ Status statusc.Status

+ type Option func(cfg *config) error

+ func ControlAddress(address string) Option

+ func ControlCAs(cas *x509.CertPool) Option

+ func ControlCAsFile(certFile string) Option

+ func DirectAddress(address string) Option

+ func DirectStatelessResetKey(key *quic.StatelessResetKey) Option

+ func DirectStatelessResetKeyFile(path string) Option

+ func DirectStatelessResetKeyFromEnv() Option

+ func Logger(logger *slog.Logger) Option

+ func NatPMPConfig(pmp nat.PMPConfig) Option

+ func Token(token string) Option

+ func TokenFromEnv() Option

type SourceConfig

+ DestinationPolicy model.LoadBalancePolicy

+ DestinationRetry model.LoadBalanceRetry

+ DestinationRetryMax int

+ DialTimeout time.Duration

+ Endpoint model.Endpoint

+ RelayEncryptions []model.EncryptionScheme

+ Route model.RouteOption

+ func (cfg SourceConfig) WithDialTimeout(timeout time.Duration) SourceConfig

+ func (cfg SourceConfig) WithLoadBalance(policy model.LoadBalancePolicy, retry model.LoadBalanceRetry, max int) SourceConfig

+ func (cfg SourceConfig) WithRelayEncryptions(schemes ...model.EncryptionScheme) SourceConfig

+ func (cfg SourceConfig) WithRoute(route model.RouteOption) SourceConfig

+ type SourceStatus struct

+ Status statusc.Status

+ type StatusPeer struct

+ Peers []StatusPeerConnection

+ Relays []StatusRelayConnection

+ type StatusPeerConnection struct

+ Addr string

+ ID string

+ Style string

+ type StatusRelayConnection struct

+ Addr string

+ ID string

Jul 12, 2025

Changes in this version

+ func StoreDirFromEnv(prefix string) (string, error)

type ClientOption

+ func ClientDirectStatelessResetKeyFromEnv() ClientOption

+ func ClientTokenFromEnv() ClientOption

type ServerOption

+ func ServerStoreDirFromEnv() ServerOption

Jul 7, 2025

Changes in this version

type ClientOption

+ func ClientNatPMPConfig(pmp nat.PMPConfig) ClientOption

May 2, 2025

Changes in this version

type ServerOption

+ func ServerClientsAuthenticator(clientsAuth control.ClientAuthenticator) ServerOption

+ func ServerClientsIngress(icfg control.Ingress) ServerOption

+ func ServerClientsTokens(tokens ...string) ServerOption

+ func ServerRelayIngress(icfg relay.Ingress) ServerOption

Apr 15, 2025

Changes in this version

+ var ErrNoActiveDestinations = client.ErrNoActiveDestinations

+ var ErrNoDialedDestinations = client.ErrNoDialedDestinations

+ var NewDestinationConfig = client.NewDestinationConfig

+ var NewSourceConfig = client.NewSourceConfig

+ type Binder func(ctx context.Context) (net.Listener, error)

type Client

+ func Connect(ctx context.Context, opts ...ClientOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Destination(ctx context.Context, cfg DestinationConfig) (Destination, error)

+ func (c *Client) DestinationHTTP(ctx context.Context, cfg DestinationConfig, handler http.Handler) error

+ func (c *Client) DestinationHTTPProxy(ctx context.Context, cfg DestinationConfig, dstUrl *url.URL) error

+ func (c *Client) DestinationHTTPSProxy(ctx context.Context, cfg DestinationConfig, dstUrl *url.URL, ...) error

+ func (c *Client) DestinationTCP(ctx context.Context, cfg DestinationConfig, addr string) error

+ func (c *Client) DestinationTLS(ctx context.Context, cfg DestinationConfig, addr string, cas *x509.CertPool) error

+ func (c *Client) Destinations() []string

+ func (c *Client) GetDestination(name string) (Destination, error)

+ func (c *Client) GetSource(name string) (Source, error)

+ func (c *Client) Source(ctx context.Context, cfg SourceConfig) (Source, error)

+ func (c *Client) SourceHTTP(ctx context.Context, cfg SourceConfig, srcURL *url.URL) error

+ func (c *Client) SourceHTTPS(ctx context.Context, cfg SourceConfig, srcURL *url.URL, cert tls.Certificate) error

+ func (c *Client) SourceTCP(ctx context.Context, cfg SourceConfig, addr string) error

+ func (c *Client) SourceTLS(ctx context.Context, cfg SourceConfig, addr string, cert tls.Certificate) error

+ func (c *Client) Sources() []string

+ type Destination interface

+ Accept func() (net.Conn, error)

+ AcceptContext func(ctx context.Context) (net.Conn, error)

+ Addr func() net.Addr

+ Client func() *Client

+ Close func() error

+ Config func() DestinationConfig

+ Context func() context.Context

+ Status func(ctx context.Context) (EndpointStatus, error)

+ type DestinationConfig = client.DestinationConfig

+ type EndpointStatus struct

+ Peer client.PeerStatus

+ Status statusc.Status

+ type HTTPDestination struct

+ func NewHTTPDestination(dst Destination, handler http.Handler) *HTTPDestination

+ func NewHTTPFileDestination(dst Destination, root string) *HTTPDestination

+ func NewHTTPProxyDestination(dst Destination, dstURL *url.URL, cfg *tls.Config) *HTTPDestination

+ func (d *HTTPDestination) Run(ctx context.Context) error

+ type HTTPSource struct

+ func NewHTTPSource(src Source, srcURL *url.URL, cfg *tls.Config) *HTTPSource

+ func (s *HTTPSource) Run(ctx context.Context) error

+ type Source interface

+ Client func() *Client

+ Close func() error

+ Config func() SourceConfig

+ Context func() context.Context

+ Dial func(network, address string) (net.Conn, error)

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ Status func(ctx context.Context) (EndpointStatus, error)

+ type SourceConfig = client.SourceConfig

+ type TCPDestination struct

+ func NewTCPDestination(dst Destination, addr string, logger *slog.Logger) *TCPDestination

+ func NewTLSDestination(dst Destination, addr string, cfg *tls.Config, logger *slog.Logger) *TCPDestination

+ func (d *TCPDestination) Run(ctx context.Context) error

+ type TCPSource struct

+ func NewTCPSource(src Source, addr string, logger *slog.Logger) *TCPSource

+ func NewTLSSource(src Source, addr string, cfg *tls.Config, logger *slog.Logger) *TCPSource

+ func (s *TCPSource) Run(ctx context.Context) error

+ type WSSource struct

+ func NewWSSource(src Source, srcURL *url.URL, cfg *tls.Config, logger *slog.Logger) *WSSource

+ func (s *WSSource) Run(ctx context.Context) error

Apr 2, 2025

Changes in this version

type ClientOption

+ func ClientDestinationServer(name string, addr string) ClientOption

+ func ClientDirectStatelessResetKey(key *quic.StatelessResetKey) ClientOption

+ func ClientDirectStatelessResetKeyFile(path string) ClientOption

+ func ClientSourceServer(name string, addr string) ClientOption

Jan 24, 2025

Changes in this version

type ServerOption

+ func ServerCertificate(certFile, keyFile string) ServerOption

+ func ServerClientAuthenticator(clientsAuth control.ClientAuthenticator) ServerOption

+ func ServerClientsAddress(address string) ServerOption

Jan 11, 2025

Changes in this version

type Client

+ func (c *Client) Status(ctx context.Context) (ClientStatus, error)

type ClientOption

+ func ClientStatusAddress(address string) ClientOption

+ type ClientStatus struct

+ Destinations map[model.Forward]client.PeerStatus

+ Sources map[model.Forward]client.PeerStatus

+ Status statusc.Status

type Server

+ func (s *Server) Status(ctx context.Context) (ServerStatus, error)

type ServerOption

+ func ServerClientRestrictions(allow []string, deny []string) ServerOption

+ func ServerClientTokensRestricted(tokens []string, restr []netc.IPRestriction) ServerOption

+ func ServerStatusAddress(address string) ServerOption

+ type ServerStatus struct

+ Control control.Status

+ Relay relay.Status

Dec 29, 2024

Changes in this version

+ type Client struct

+ func NewClient(opts ...ClientOption) (*Client, error)

+ func (c *Client) Run(ctx context.Context) error

+ type ClientOption func(cfg *clientConfig) error

+ func ClientControlAddress(address string) ClientOption

+ func ClientControlCAs(certFile string) ClientOption

+ func ClientDestination(name, addr string, route model.RouteOption) ClientOption

+ func ClientDirectAddress(address string) ClientOption

+ func ClientLogger(logger *slog.Logger) ClientOption

+ func ClientSource(name, addr string, route model.RouteOption) ClientOption

+ func ClientToken(token string) ClientOption

+ type Server struct

+ func NewServer(opts ...ServerOption) (*Server, error)

+ func (s *Server) Run(ctx context.Context) error

+ type ServerOption func(*serverConfig) error

+ func ServerClientTokens(tokens ...string) ServerOption

+ func ServerControlAddress(address string) ServerOption

+ func ServerControlCertificate(certFile, keyFile string) ServerOption

+ func ServerLogger(logger *slog.Logger) ServerOption

+ func ServerRelayAddress(address string) ServerOption

+ func ServerRelayHostname(hostname string) ServerOption

+ func ServerStoreDir(dir string) ServerOption