pool

Documentation

Index

• Variables
• type ApiEntry
• type Card
• type Pool
  • func NewPool(history *history.History, ipLookup ipinfo.IpInfoGetter) *Pool
  • func (pool *Pool) Add(ctx context.Context, proxy pmux.Proxy, speed time.Duration)
  • func (pool *Pool) HttpGet(r *http.Request) (any, error)
  • func (pool *Pool) Len() (res int)
  • func (pool *Pool) MarshalBinary() ([]byte, error)
  • func (pool *Pool) RandomFast(ctx context.Context) context.Context
  • func (pool *Pool) Remove(proxy pmux.Proxy) bool
  • func (pool *Pool) RoundTrip(req *http.Request) (res *http.Response, err error)
  • func (pool *Pool) Session(ctx context.Context, fn func(context.Context, httpClient) error) error
  • func (pool *Pool) Start(ctx app.Context)
  • func (pool *Pool) UnmarshalBinary(data []byte) error
• type PoolStats

Variables

var ErrNoProxiesLeft = fmt.Errorf("no proxies left")

Types

type ApiEntry

type ApiEntry struct {
	Proxy          pmux.Proxy
	FirstSeen      int64
	LastSeen       int64
	ReanimateAfter time.Time
	Ok             bool
	Speed          time.Duration
	Seen           int
	Timeouts       int
	Offered        int
	Reanimated     int
	Succeed        int
	HourOffered    [24]int
	HourSucceed    [24]int
	Country        string
	Provider       string
	ASN            uint16
}

type Card

type Card struct {
	Name  string
	Value any
}

TODO: think of rather type Facet struct { Name, Field string; Values []string }

type Pool

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

func NewPool

func NewPool(history *history.History, ipLookup ipinfo.IpInfoGetter) *Pool

func (*Pool) Add

func (pool *Pool) Add(ctx context.Context, proxy pmux.Proxy, speed time.Duration)

func (*Pool) HttpGet

func (pool *Pool) HttpGet(r *http.Request) (any, error)

func (*Pool) Len

func (pool *Pool) Len() (res int)

func (*Pool) MarshalBinary

func (pool *Pool) MarshalBinary() ([]byte, error)

func (*Pool) RandomFast

func (pool *Pool) RandomFast(ctx context.Context) context.Context

func (*Pool) Remove

func (pool *Pool) Remove(proxy pmux.Proxy) bool

func (*Pool) RoundTrip

func (pool *Pool) RoundTrip(req *http.Request) (res *http.Response, err error)

func (*Pool) Session

func (pool *Pool) Session(ctx context.Context, fn func(context.Context, httpClient) error) error

Session rotates a random proxy per entire fn(ctx, client) call

func (*Pool) Start

func (pool *Pool) Start(ctx app.Context)

func (*Pool) UnmarshalBinary

func (pool *Pool) UnmarshalBinary(data []byte) error

type PoolStats

type PoolStats struct {
	Total   int
	Cards   []Card
	Entries []ApiEntry
}