transport

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

type Config struct {
	Servers            []string
	Username           string
	Password           string
	MaxRetries         int
	Transport          http.RoundTripper
	ConnectionPoolFunc func([]*Connection, Selector) ConnectionPool
	// contains filtered or unexported fields
}

type Connection struct {
	sync.Mutex

	URL       *url.URL
	IsDead    bool
	DeadSince time.Time
	Failures  int

	ID         string
	Name       string
	Roles      []string
	Attributes map[string]interface{}
}

type ConnectionPool interface {
	Next() (*Connection, error)  // Next returns the next available connection.
	OnSuccess(*Connection) error // OnSuccess reports that the connection was successful.
	OnFailure(*Connection) error // OnFailure reports that the connection failed.
	URLs() []*url.URL            // URLs returns the list of URLs of available connections.
}

type Interface interface {
	Perform(*http.Request) (*http.Response, error)
}

type Selector interface {
	Select([]*Connection) (*Connection, error)
}