rdv

package module

Go to main page

Versions in this module

v0

v0.0.6

May 15, 2024

Changes in this version

+ const ACCEPT

+ const DIAL

+ func AddrPortFrom(addr net.Addr) netip.AddrPort

type AddrSpace

+ const SpaceLoopback4

+ const SpaceLoopback6

+ func AddrSpaceFrom(ip netip.Addr) AddrSpace

+ func (s AddrSpace) IncludesAddr(addr netip.Addr) bool

+ func (s AddrSpace) MatchesAddr(addr netip.Addr) bool

type Client

+ AddrSpaces AddrSpace

+ Logger *slog.Logger

+ Picker Picker

+ Timeout time.Duration

+ func (c *Client) Do(ctx context.Context, method, addr, token string, header http.Header) (*Conn, *http.Response, error)

+ type ErrOther struct

+ Addr netip.AddrPort

+ func (e ErrOther) Error() string

+ type Handler interface

+ Serve func(ctx context.Context, dc, ac *Conn)

type Meta

+ Method string

+ type Picker interface

+ Pick func(candidates chan *Conn, cancel func()) (conns []*Conn)

+ func PickFirst() Picker

+ func WaitConstant(timeout time.Duration) Picker

+ func WaitForP2P(timeout time.Duration) Picker

type Relayer

+ BufferSize int

+ func (r *Relayer) Continue(ctx context.Context, dc, ac *Conn) error

+ func (r *Relayer) Relay(ctx context.Context, w1, w2 io.WriteCloser, r1, r2 io.Reader) (n1 int64, n2 int64, err error)

+ func (r *Relayer) Serve(ctx context.Context, dc, ac *Conn)

type Server

+ Handler Handler

+ LobbyTimeout time.Duration

+ Logger *slog.Logger

+ ObservedAddrFunc func(r *http.Request) (netip.AddrPort, error)

+ func (s *Server) Close() error

+ func (s *Server) Shutdown()

+ func (s *Server) Start()

+ func (s *Server) Upgrade(w http.ResponseWriter, r *http.Request) error

v0.0.5

Mar 17, 2024

Changes in this version

+ func DefaultServeFunc(ctx context.Context, dc, ac *Conn)

type Conn

+ func (c *Conn) Request() *http.Request

v0.0.4

Feb 28, 2024

v0.0.3

Feb 1, 2024

Changes in this version

+ type AddrSpace uint32

+ const AllSpaces

+ const DefaultSpaces

+ const NoSpaces

+ const PublicSpaces

+ const SpaceInvalid

+ const SpaceLink4

+ const SpaceLink6

+ const SpaceLoopback

+ const SpacePrivate4

+ const SpacePrivate6

+ const SpacePublic4

+ const SpacePublic6

+ func FromNetAddr(na net.Addr) (addr netip.AddrPort, space AddrSpace)

+ func GetAddrSpace(ip netip.Addr) AddrSpace

+ func (s AddrSpace) Includes(space AddrSpace) bool

+ func (s AddrSpace) String() string

type Client

+ func NewClient(cfg *ClientConfig) *Client

+ type ClientConfig struct

+ AddrSpaces AddrSpace

+ DialChooser Chooser

+ Logger *slog.Logger

+ SelfAddrFunc func(ctx context.Context, socket *Socket) []netip.AddrPort

+ TlsConfig *tls.Config

type ServerConfig

+ Logger *slog.Logger

v0.0.2

Jan 19, 2023

Changes in this version

+ var DefaultRelayer = &Relayer

+ var DefaultServerConfig = &ServerConfig

+ var ErrBadHandshake = errors.New("bad http handshake")

+ var ErrDontUse = errors.New("bad addr: not helpful for connectivity")

+ var ErrHijackFailed = errors.New("failed hijacking http conn")

+ var ErrIdleTimeout = errors.New("periodic idle timeout exceeded")

+ var ErrInvalidAddr = errors.New("bad addr: invalid addr")

+ var ErrNotChosen = errors.New("no rdv conn chosen")

+ var ErrPrivilegedPort = errors.New("bad addr: expected port >=1024")

+ var ErrProtocol = errors.New("rdv protocol error")

+ var ErrServerClosed = errors.New("rdv server closed")

+ var ErrUpgrade = errors.New("rdv http upgrade error")

+ func AcceptableAddr(addr netip.AddrPort) error

+ func DefaultHandler(ctx context.Context, dc, ac *Conn)

+ func DefaultObservedAddr(r *http.Request) (addr netip.AddrPort, err error)

+ func DefaultSelfAddrs(ctx context.Context, socket *Socket) []netip.AddrPort

+ func GoodObservedAddr(addr netip.AddrPort) error

+ func GoodSelfAddr(addr netip.AddrPort) error

+ type Chooser func(cancel func(), candidates chan *Conn) (chosen *Conn, unchosen []*Conn)

+ func RelayPenalty(penalty time.Duration) Chooser

+ type Client struct

+ DialChooser Chooser

+ Logf func(string, ...interface{})

+ SelfAddrFunc func(ctx context.Context, socket *Socket) []netip.AddrPort

+ TlsConfig *tls.Config

+ func (c *Client) Accept(addr string, token string, reqHeader http.Header) (*Conn, *http.Response, error)

+ func (c *Client) AcceptContext(ctx context.Context, addr string, token string, reqHeader http.Header) (*Conn, *http.Response, error)

+ func (c *Client) Dial(addr string, token string, reqHeader http.Header) (*Conn, *http.Response, error)

+ func (c *Client) DialContext(ctx context.Context, addr string, token string, reqHeader http.Header) (*Conn, *http.Response, error)

+ type Conn struct

+ func (c *Conn) IsRelay() bool

+ func (c *Conn) Meta() *Meta

+ func (c *Conn) Read(p []byte) (int, error)

+ type Meta struct

+ IsDialer bool

+ ObservedAddr *netip.AddrPort

+ PeerAddrs []netip.AddrPort

+ SelfAddrs []netip.AddrPort

+ ServerAddr string

+ Token string

+ type Relayer struct

+ AcceptTap io.Writer

+ DialTap io.Writer

+ IdleTimeout time.Duration

+ func (r *Relayer) Reject(dc, ac *Conn, statusCode int, reason string) error

+ func (r *Relayer) Run(ctx context.Context, dc, ac *Conn) (dn int64, ln int64, err error)

+ type Server struct

+ func NewServer(cfg *ServerConfig) *Server

+ func (l *Server) AddClient(w http.ResponseWriter, req *http.Request) error

+ func (l *Server) Serve() error

+ func (l *Server) ServeContext(ctx context.Context) error

+ func (l *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ServerConfig struct

+ LobbyTimeout time.Duration

+ Logf func(string, ...interface{})

+ ObservedAddrFunc func(req *http.Request) (netip.AddrPort, error)

+ ServeFunc func(ctx context.Context, dc, ac *Conn)

+ type Socket struct

+ D4 *net.Dialer

+ D6 *net.Dialer

+ Port uint16

+ TlsConfig *tls.Config

+ func NewSocket(ctx context.Context, port uint16, tlsConf *tls.Config) (*Socket, error)

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

+ func (s *Socket) DialIPContext(ctx context.Context, addr netip.AddrPort) (net.Conn, error)

+ func (s *Socket) DialURLContext(ctx context.Context, network string, url *urlpkg.URL) (net.Conn, error)

v0.0.1

Jan 19, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL