pool

Documentation

Index

• Variables
• type Card
• type Pool
  • func NewPool(history *history.History) *Pool
  • func (pool *Pool) Add(ctx context.Context, proxy pmux.Proxy, speed time.Duration)
  • func (pool *Pool) HttpGet(r *http.Request) (interface{}, 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, *http.Client) 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 Card

type Card struct {
	Name  string
	Value interface{}
}

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) *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) (interface{}, 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, *http.Client) 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 []entry
}