circuit

Aug 16, 2014

Changes in this version

type Panel

+ Circuits map[string]Breaker

Aug 16, 2014

Changes in this version

+ var ErrBreakerOpen = errors.New("breaker open")

+ var ErrBreakerTimeout = errors.New("breaker time out")

+ type Breaker interface

+ Break func()

+ Call func(func() error) error

+ Fail func()

+ Failures func() int64

+ Ready func() bool

+ Reset func()

+ Subscribe func() <-chan BreakerEvent

+ Trip func()

+ Tripped func() bool

+ func NoOp() Breaker

+ type BreakerEvent int

+ const BreakerFail

+ const BreakerReady

+ const BreakerReset

+ const BreakerTripped

+ type FrequencyBreaker struct

+ Duration time.Duration

+ Threshold int64

+ func NewFrequencyBreaker(duration time.Duration, threshold int64) *FrequencyBreaker

+ func (cb *FrequencyBreaker) Call(circuit func() error) error

+ func (cb *FrequencyBreaker) Fail()

+ func (cb *FrequencyBreaker) Failures() int64

+ type HTTPClient struct

+ BreakerLookup func(*HTTPClient, interface{}) Breaker

+ BreakerReset func()

+ BreakerTripped func()

+ Client *http.Client

+ Panel *Panel

+ func NewHTTPClient(timeout time.Duration, threshold int64, client *http.Client) *HTTPClient

+ func NewHTTPClientWithBreaker(breaker Breaker, client *http.Client) *HTTPClient

+ func NewHostBasedHTTPClient(timeout time.Duration, threshold int64, client *http.Client) *HTTPClient

+ func (c *HTTPClient) Do(req *http.Request) (*http.Response, error)

+ func (c *HTTPClient) Get(url string) (*http.Response, error)

+ func (c *HTTPClient) Head(url string) (*http.Response, error)

+ func (c *HTTPClient) Post(url string, bodyType string, body io.Reader) (*http.Response, error)

+ func (c *HTTPClient) PostForm(url string, data url.Values) (*http.Response, error)

+ type Panel struct

+ StatsPrefixf string

+ Statter Statter

+ func NewPanel() *Panel

+ func (p *Panel) Add(name string, cb Breaker)

+ func (p *Panel) Get(name string) (Breaker, bool)

+ func (p *Panel) Subscribe() <-chan PanelEvent

+ type PanelEvent struct

+ Event BreakerEvent

+ Name string

+ type Statter interface

+ Counter func(sampleRate float32, bucket string, n ...int)

+ Gauge func(sampleRate float32, bucket string, value ...string)

+ Timing func(sampleRate float32, bucket string, d ...time.Duration)

+ type ThresholdBreaker struct

+ func NewThresholdBreaker(threshold int64) *ThresholdBreaker

+ type TimeoutBreaker struct

+ Timeout time.Duration

+ func NewTimeoutBreaker(timeout time.Duration, threshold int64) *TimeoutBreaker

+ func (cb *TimeoutBreaker) Call(circuit func() error) error

+ func (cb *TimeoutBreaker) Fail()

+ type TrippableBreaker struct

+ ResetTimeout time.Duration

+ func NewTrippableBreaker(resetTimeout time.Duration) *TrippableBreaker

+ func (cb *TrippableBreaker) Break()

+ func (cb *TrippableBreaker) Call(circuit func() error) error

+ func (cb *TrippableBreaker) Fail()

+ func (cb *TrippableBreaker) Failures() int64

+ func (cb *TrippableBreaker) Ready() bool

+ func (cb *TrippableBreaker) Reset()

+ func (cb *TrippableBreaker) Subscribe() <-chan BreakerEvent

+ func (cb *TrippableBreaker) Trip()

+ func (cb *TrippableBreaker) Tripped() bool