pooly

type Computer interface {
	Compute(float64) float64
}

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

type Driver interface {
	// Dial is a function that given an address, establishes a connection with a remote host.
	// It returns the connection created or an error on failure.
	Dial(string) (*Conn, error)

	// Close closes the given connection.
	Close(*Conn)

	// TestOnBorrow is a function that, given a connection, tests it and returns an error on failure.
	TestOnBorrow(*Conn) error

	// Temporary determines whether the error is temporary or fatal for the connection.
	// On fatal error, the connection will be garbage collected.
	Temporary(error) bool
}

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

type Host struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

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

type PoolConfig struct {
	// Connection driver (TCP NetDriver by default).
	Driver Driver

	// Close connections after remaining idle for this duration.
	// If the value is zero (default), then idle connections are not closed.
	ConnIdleTimeout time.Duration

	// Defines the duration during which Get operations will try to return a connection from the pool.
	// If the value is zero (default), then Get should wait forever.
	WaitTimeout time.Duration

	// Maximum number of connections allowed in the pool (DefaultMaxConns by default).
	MaxConns int32

	// Number of connection retry (DefaultConnRetries by default).
	ConnRetries int

	// Time interval between connection retry (DefaultRetryDelay by default).
	RetryDelay time.Duration
}

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

type Selecter interface {
	Select(map[string]*Host) *Host
}

type Service struct {
	*ServiceConfig

	sync.RWMutex
	// contains filtered or unexported fields
}

type ServiceConfig struct {
	PoolConfig

	// Number of connections to prespawn on hosts additions (DefaultPrespawnConns by default).
	PrespawnConns uint

	// Number of attempts to get a connection from the service before giving up (DefaultGetAttempts by default).
	GetAttempts uint

	// Deadline after which pools are forced closed (see Pool.ForceClose) (DefaultCloseDeadline by default).
	CloseDeadline time.Duration

	// Defines the time interval taken into account when scores are computed (DefaultDecayDuration by default).
	// Scores are calculated using a weighted average over the course of this duration (recent feedbacks get higher weight).
	DecayDuration time.Duration

	// Time interval between two successive hosts scores computations.
	// Each score is calculated and cached for this duration (DefaultMemoizeScoreDuration by default).
	MemoizeScoreDuration time.Duration

	// Optional score calculator (none by default).
	ScoreCalculator Computer

	// Multi-armed bandit strategy used for host selection (RoundRobin by default).
	// The tradeoff faced by the service at each GetConn is between "exploitation" (choose hosts having the highest score)
	// and "exploration" (find about the expected score of other hosts).
	// The key here is to find the right balance between "exploration" and "exploitation" of hosts given their respective score.
	// Some strategies will favor fairness while others will prefer to pick hosts based on how well they perform.
	BanditStrategy Selecter

	// Address and port of a statsd server to collect and aggregate pooly service metrics (none by default).
	StatsdAddr string
}

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