boomerang

type Backoff interface {
	NextInterval(retry int) time.Duration
}

type BackoffFunc func(retry int) time.Duration

type CheckRetry func(resp *http.Response, err error) (bool, error)

type Client interface {
	Get(url string) (*http.Response, error)
	Head(url string) (*http.Response, error)
	Post(url string, contentType string, body io.ReadSeeker) (*http.Response, error)
	PostForm(url string, data url.Values) (*http.Response, error)
	Do(req *http.Request) (*http.Response, error)
}

type ClientConfig struct {
	RecordMetrics   bool
	MetricNamespace string
	Timeout         time.Duration
	Transport       *http.Transport
	Backoff         Backoff
	RetryFunc       CheckRetry
	MaxRetries      int
}

type HttpClient struct {
	Logger *log.Logger // Customer logger instance.

	Backoff Backoff
	// CheckRetry specifies the policy for handling retries, and is called
	// after each request. The default policy is DefaultRetryPolicy.
	CheckRetry CheckRetry
	MaxRetries int
	// To explicitly state if no metrics are to be recorded for this client
	RecordMetrics bool
	MetricsCtx    Metrics
	// contains filtered or unexported fields
}

type HystrixClient struct {
	Logger *log.Logger // Customer logger instance.

	Backoff Backoff

	// CheckRetry specifies the policy for handling retries, and is called
	// after each request. The default policy is DefaultRetryPolicy.
	CheckRetry CheckRetry
	MaxRetries int
	// contains filtered or unexported fields
}

type HystrixCommandConfig struct {
	Timeout                int `json:"timeout"`
	MaxConcurrentRequests  int `json:"max_concurrent_requests"`
	RequestVolumeThreshold int `json:"request_volume_threshold"`
	SleepWindow            int `json:"sleep_window"`
	ErrorPercentThreshold  int `json:"error_percent_threshold"`
	CommandName            string
	Transport              *http.Transport
}

type LenReader interface {
	Len() int
}

type Metrics interface {
	Record(time.Time, int, error)
}