pool

package
v1.5.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2026 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrPoolClosed    = errors.New("connection pool is closed")
	ErrNoConnections = errors.New("no available connections")
)

Functions

This section is empty.

Types

type Conn 

type Conn struct {
	Host       string
	RemoteAddr net.Addr
	TLSConn    *utls.UConn
	HTTP2Conn  *http2.ClientConn
	CreatedAt  time.Time
	LastUsedAt time.Time
	UseCount   int64
	// contains filtered or unexported fields
}

Conn represents a persistent connection

func (*Conn) Age 

func (c *Conn) Age() time.Duration

Age returns how long the connection has been open

func (*Conn) Close 

func (c *Conn) Close() error

Close closes the connection

func (*Conn) IdleTime 

func (c *Conn) IdleTime() time.Duration

IdleTime returns how long since the connection was last used

func (*Conn) IsHealthy 

func (c *Conn) IsHealthy() bool

IsHealthy checks if the connection is still usable

func (*Conn) MarkUsed 

func (c *Conn) MarkUsed()

MarkUsed updates the last used timestamp

type HostPool 

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

HostPool manages connections to a single host

func NewHostPool 

func NewHostPool(host, port string, preset *fingerprint.Preset, dnsCache *dns.Cache) *HostPool

NewHostPool creates a new pool for a specific host Note: This generates its own shuffled specs. For consistent session fingerprinting, use Manager.GetPool() instead which shares cached specs across all hosts.

func NewHostPoolWithConfig 

func NewHostPoolWithConfig(host, port string, preset *fingerprint.Preset, dnsCache *dns.Cache, insecureSkipVerify bool, proxyURL string, cachedSpec, cachedPSKSpec *utls.ClientHelloSpec, shuffleSeed int64, sessionCache utls.ClientSessionCache) *HostPool

NewHostPoolWithConfig creates a pool with TLS and proxy configuration

func (*HostPool) Close 

func (p *HostPool) Close()

Close closes all connections in the pool

func (*HostPool) CloseIdle 

func (p *HostPool) CloseIdle()

CloseIdle closes connections that have been idle too long

func (*HostPool) GetConn 

func (p *HostPool) GetConn(ctx context.Context) (*Conn, error)

GetConn returns an available connection or creates a new one

func (*HostPool) SetECHConfig added in v1.5.3 

func (p *HostPool) SetECHConfig(echConfig []byte)

SetECHConfig sets a custom ECH configuration for this pool

func (*HostPool) SetECHConfigDomain added in v1.5.3 

func (p *HostPool) SetECHConfigDomain(domain string)

SetECHConfigDomain sets a domain to fetch ECH config from

func (*HostPool) SetMaxConns 

func (p *HostPool) SetMaxConns(max int)

SetMaxConns sets the maximum connections for this pool (0 = unlimited)

func (*HostPool) Stats 

func (p *HostPool) Stats() (total int, healthy int, totalRequests int64)

Stats returns pool statistics

type Manager 

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

Manager manages connection pools for multiple hosts

func NewManager 

func NewManager(preset *fingerprint.Preset) *Manager

NewManager creates a new connection pool manager

func NewManagerWithProxy 

func NewManagerWithProxy(preset *fingerprint.Preset, proxyURL string, insecureSkipVerify bool) *Manager

NewManagerWithProxy creates a manager with proxy support

func NewManagerWithTLSConfig 

func NewManagerWithTLSConfig(preset *fingerprint.Preset, insecureSkipVerify bool) *Manager

NewManagerWithTLSConfig creates a manager with TLS configuration

func (*Manager) Close 

func (m *Manager) Close()

Close shuts down the manager and all pools

func (*Manager) CloseAllPools added in v1.5.8 

func (m *Manager) CloseAllPools()

CloseAllPools closes all connection pools and clears session cache This is used when switching proxies - old connections are invalid for new proxy route

func (*Manager) GetConn 

func (m *Manager) GetConn(ctx context.Context, host, port string) (*Conn, error)

GetConn gets a connection to the specified host

func (*Manager) GetDNSCache 

func (m *Manager) GetDNSCache() *dns.Cache

GetDNSCache returns the DNS cache

func (*Manager) GetPool 

func (m *Manager) GetPool(host, port string) (*HostPool, error)

GetPool returns a pool for the given host, creating one if needed

func (*Manager) GetProxy added in v1.5.8 

func (m *Manager) GetProxy() string

GetProxy returns the current proxy URL

func (*Manager) GetSessionCache added in v1.5.10 

func (m *Manager) GetSessionCache() utls.ClientSessionCache

GetSessionCache returns the shared TLS session cache

func (*Manager) SetConnectTo added in v1.5.2 

func (m *Manager) SetConnectTo(requestHost, connectHost string)

SetConnectTo sets a host mapping for domain fronting

func (*Manager) SetECHConfig added in v1.5.2 

func (m *Manager) SetECHConfig(echConfig []byte)

SetECHConfig sets a custom ECH configuration

func (*Manager) SetECHConfigDomain added in v1.5.2 

func (m *Manager) SetECHConfigDomain(domain string)

SetECHConfigDomain sets a domain to fetch ECH config from

func (*Manager) SetMaxConnsPerHost 

func (m *Manager) SetMaxConnsPerHost(max int)

SetMaxConnsPerHost sets the max connections per host for new pools (0 = unlimited)

func (*Manager) SetPreset 

func (m *Manager) SetPreset(preset *fingerprint.Preset)

SetPreset changes the fingerprint preset for new connections

func (*Manager) SetProxy added in v1.5.8 

func (m *Manager) SetProxy(proxyURL string)

SetProxy changes the proxy URL and closes all existing connections TLS sessions from old proxy route are invalid, so we clear everything

func (*Manager) SetSessionCache added in v1.5.10 

func (m *Manager) SetSessionCache(cache utls.ClientSessionCache)

SetSessionCache sets the shared TLS session cache for all pools This allows session persistence to work across Save/Load

func (*Manager) Stats 

func (m *Manager) Stats() map[string]struct {
	Total    int
	Healthy  int
	Requests int64
}

Stats returns overall manager statistics

type QUICConn 

type QUICConn struct {
	Host       string
	RemoteAddr net.Addr
	QUICConn   *quic.Conn
	HTTP3RT    *http3.Transport
	CreatedAt  time.Time
	LastUsedAt time.Time
	UseCount   int64
	// contains filtered or unexported fields
}

QUICConn represents a persistent QUIC connection

func (*QUICConn) Age 

func (c *QUICConn) Age() time.Duration

Age returns how long the connection has been open

func (*QUICConn) Close 

func (c *QUICConn) Close() error

Close closes the QUIC connection

func (*QUICConn) IdleTime 

func (c *QUICConn) IdleTime() time.Duration

IdleTime returns how long since the connection was last used

func (*QUICConn) IsHealthy 

func (c *QUICConn) IsHealthy() bool

IsHealthy checks if the QUIC connection is still usable

func (*QUICConn) MarkUsed 

func (c *QUICConn) MarkUsed()

MarkUsed updates the last used timestamp

type QUICHostPool 

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

QUICHostPool manages QUIC connections to a single host

func NewQUICHostPool 

func NewQUICHostPool(host, port string, preset *fingerprint.Preset, dnsCache *dns.Cache) *QUICHostPool

NewQUICHostPool creates a new QUIC pool for a specific host

func NewQUICHostPoolWithCachedSpec added in v1.1.4 

func NewQUICHostPoolWithCachedSpec(host, port string, preset *fingerprint.Preset, dnsCache *dns.Cache, cachedSpec *utls.ClientHelloSpec, cachedPSKSpec *utls.ClientHelloSpec, shuffleSeed int64) *QUICHostPool

NewQUICHostPoolWithCachedSpec creates a QUIC pool with a pre-cached ClientHelloSpec and shuffle seed This ensures consistent TLS extension order and transport parameter order across all hosts in a session cachedSpec is used for initial connections, cachedPSKSpec is used when resuming sessions

func (*QUICHostPool) Close 

func (p *QUICHostPool) Close()

Close closes all connections in the pool

func (*QUICHostPool) CloseConnections added in v1.5.7 

func (p *QUICHostPool) CloseConnections()

CloseConnections closes all connections but keeps the pool usable This allows testing session resumption by forcing new connections

func (*QUICHostPool) CloseIdle 

func (p *QUICHostPool) CloseIdle()

CloseIdle closes connections that have been idle too long

func (*QUICHostPool) GetConn 

func (p *QUICHostPool) GetConn(ctx context.Context) (*QUICConn, error)

GetConn returns an available QUIC connection or creates a new one

func (*QUICHostPool) SetMaxConns 

func (p *QUICHostPool) SetMaxConns(max int)

SetMaxConns sets the maximum connections for this pool (0 = unlimited)

func (*QUICHostPool) Stats 

func (p *QUICHostPool) Stats() (total int, healthy int, totalRequests int64)

Stats returns pool statistics

type QUICManager 

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

QUICManager manages QUIC connection pools for multiple hosts

func NewQUICManager 

func NewQUICManager(preset *fingerprint.Preset, dnsCache *dns.Cache) *QUICManager

NewQUICManager creates a new QUIC connection pool manager

func (*QUICManager) Close 

func (m *QUICManager) Close()

Close shuts down the manager and all pools

func (*QUICManager) CloseAllConnections added in v1.5.7 

func (m *QUICManager) CloseAllConnections()

CloseAllConnections closes all QUIC connections across all pools but keeps the pools usable with their session caches intact This is useful for testing session resumption

func (*QUICManager) CloseAllPools added in v1.5.8 

func (m *QUICManager) CloseAllPools()

CloseAllPools closes all pools and removes them entirely This is used when switching proxies - old connections/sessions are invalid for new proxy route

func (*QUICManager) GetConn 

func (m *QUICManager) GetConn(ctx context.Context, host, port string) (*QUICConn, error)

GetConn gets a QUIC connection to the specified host

func (*QUICManager) GetPool 

func (m *QUICManager) GetPool(host, port string) (*QUICHostPool, error)

GetPool returns a pool for the given host, creating one if needed

func (*QUICManager) SetConnectTo added in v1.5.2 

func (m *QUICManager) SetConnectTo(requestHost, connectHost string)

SetConnectTo sets a host mapping for domain fronting

func (*QUICManager) SetDisableECH added in v1.5.8 

func (m *QUICManager) SetDisableECH(disable bool)

SetDisableECH disables automatic ECH fetching Chrome doesn't always use ECH even when available from DNS

func (*QUICManager) SetECHConfig added in v1.5.2 

func (m *QUICManager) SetECHConfig(echConfig []byte)

SetECHConfig sets a custom ECH configuration

func (*QUICManager) SetECHConfigDomain added in v1.5.2 

func (m *QUICManager) SetECHConfigDomain(domain string)

SetECHConfigDomain sets a domain to fetch ECH config from

func (*QUICManager) SetInsecureSkipVerify added in v1.5.8 

func (m *QUICManager) SetInsecureSkipVerify(skip bool)

SetInsecureSkipVerify sets whether to skip TLS certificate verification

func (*QUICManager) SetMaxConnsPerHost 

func (m *QUICManager) SetMaxConnsPerHost(max int)

SetMaxConnsPerHost sets the max connections per host for new pools (0 = unlimited)

func (*QUICManager) Stats 

func (m *QUICManager) Stats() map[string]struct {
	Total    int
	Healthy  int
	Requests int64
}

Stats returns overall manager statistics

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.