quicreuse

Documentation

Index

• func FromQuicMultiaddr(addr ma.Multiaddr) (*net.UDPAddr, quic.VersionNumber, error)
• func ToQuicMultiaddr(na net.Addr, version quic.VersionNumber) (ma.Multiaddr, error)
• func WithAssociation(ctx context.Context, association any) context.Context
• type ConnManager
  • func NewConnManager(statelessResetKey quic.StatelessResetKey, tokenKey quic.TokenGeneratorKey, ...) (*ConnManager, error)
  • func (c *ConnManager) ClientConfig() *quic.Config
  • func (c *ConnManager) Close() error
  • func (c *ConnManager) DialQUIC(ctx context.Context, raddr ma.Multiaddr, tlsConf *tls.Config, ...) (quic.Connection, error)
  • func (c *ConnManager) ListenQUIC(addr ma.Multiaddr, tlsConf *tls.Config, ...) (Listener, error)
  • func (c *ConnManager) ListenQUICAndAssociate(association any, addr ma.Multiaddr, tlsConf *tls.Config, ...) (Listener, error)
  • func (c *ConnManager) Protocols() []int
  • func (c *ConnManager) SharedNonQUICPacketConn(network string, laddr *net.UDPAddr) (net.PacketConn, error)
  • func (c *ConnManager) TransportForDial(network string, raddr *net.UDPAddr) (refCountedQuicTransport, error)
  • func (c *ConnManager) TransportWithAssociationForDial(association any, network string, raddr *net.UDPAddr) (refCountedQuicTransport, error)
• type Listener
• type Option
  • func DisableReuseport() Option
  • func EnableMetrics(reg prometheus.Registerer) Option

Functions

func FromQuicMultiaddr

func FromQuicMultiaddr(addr ma.Multiaddr) (*net.UDPAddr, quic.VersionNumber, error)

func ToQuicMultiaddr

func ToQuicMultiaddr(na net.Addr, version quic.VersionNumber) (ma.Multiaddr, error)

func WithAssociation

func WithAssociation(ctx context.Context, association any) context.Context

WithAssociation returns a new context with the given association. Used in DialQUIC to prefer a transport that has the given association.

Types

type ConnManager

type ConnManager struct {
	// contains filtered or unexported fields
}

func NewConnManager

func NewConnManager(statelessResetKey quic.StatelessResetKey, tokenKey quic.TokenGeneratorKey, opts ...Option) (*ConnManager, error)

func (*ConnManager) ClientConfig

func (c *ConnManager) ClientConfig() *quic.Config

func (*ConnManager) Close

func (c *ConnManager) Close() error

func (*ConnManager) DialQUIC

func (c *ConnManager) DialQUIC(ctx context.Context, raddr ma.Multiaddr, tlsConf *tls.Config, allowWindowIncrease func(conn quic.Connection, delta uint64) bool) (quic.Connection, error)

func (*ConnManager) ListenQUIC

func (c *ConnManager) ListenQUIC(addr ma.Multiaddr, tlsConf *tls.Config, allowWindowIncrease func(conn quic.Connection, delta uint64) bool) (Listener, error)

func (*ConnManager) ListenQUICAndAssociate

func (c *ConnManager) ListenQUICAndAssociate(association any, addr ma.Multiaddr, tlsConf *tls.Config, allowWindowIncrease func(conn quic.Connection, delta uint64) bool) (Listener, error)

ListenQUICAndAssociate returns a QUIC listener and associates the underlying transport with the given association.

func (*ConnManager) Protocols

func (c *ConnManager) Protocols() []int

func (*ConnManager) SharedNonQUICPacketConn

func (c *ConnManager) SharedNonQUICPacketConn(network string, laddr *net.UDPAddr) (net.PacketConn, error)

func (*ConnManager) TransportForDial

func (c *ConnManager) TransportForDial(network string, raddr *net.UDPAddr) (refCountedQuicTransport, error)

func (*ConnManager) TransportWithAssociationForDial

func (c *ConnManager) TransportWithAssociationForDial(association any, network string, raddr *net.UDPAddr) (refCountedQuicTransport, error)

TransportWithAssociationForDial returns a QUIC transport for dialing, preferring a transport with the given association.

type Listener

type Listener interface {
	Accept(context.Context) (quic.Connection, error)
	Addr() net.Addr
	Multiaddrs() []ma.Multiaddr
	io.Closer
}

type Option

type Option func(*ConnManager) error

func DisableReuseport

func DisableReuseport() Option

func EnableMetrics

func EnableMetrics(reg prometheus.Registerer) Option

EnableMetrics enables Prometheus metrics collection. If reg is nil, prometheus.DefaultRegisterer will be used as the registerer.