proxy

package

v1.4.0 Latest Latest Go to latest Published: Mar 3, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Package proxy provides proxy IP pool management and online filtering.

View Source

const (
	CONN_TIMEOUT = 4 //4s
	DAIL_TIMEOUT = 4 //4s
	TRY_TIMES    = 3
	// Max concurrency for IP speed testing
	MAX_THREAD_NUM = 1000
)

This section is empty.

This section is empty.

type Proxy struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Proxy manages a pool of proxy IPs with online filtering and per-host sorting.

func New() *Proxy

New creates and starts a Proxy that loads and filters proxy IPs from config.

func (p *Proxy) Count() int32

Count returns the number of online proxy IPs.

func (p *Proxy) GetOne(u string) option.Option[string]

GetOne returns an unused proxy IP for this cycle and its response time.

func (p *Proxy) SetSurfForTest(s surfer.Surfer)

SetSurfForTest injects a Surfer for testing.

func (p *Proxy) Update() result.VoidResult

Update refreshes the proxy IP list.

func (p *Proxy) UpdateTicker(tickMinute int64)

UpdateTicker updates the ticker.

type ProxyForHost struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ProxyForHost manages proxy IPs for a host, sorted by response time.

func (ph *ProxyForHost) Len() int

Len implements sort.Interface.

func (ph *ProxyForHost) Less(i, j int) bool

func (ph *ProxyForHost) Swap(i, j int)