gentle

package

Go to main page

Versions in this module

v3

v3.0.8

Oct 24, 2017

v3.0.7

Oct 19, 2017

Changes in this version

+ type BulkheadHandler struct

+ func (r *BulkheadHandler) Handle(ctx context.Context, msg Message) (Message, error)

+ type BulkheadStream struct

+ func (r *BulkheadStream) Get(ctx context.Context) (Message, error)

+ type CircuitHandler struct

+ func (r *CircuitHandler) GetCircuitName() string

+ func (r *CircuitHandler) Handle(ctx context.Context, msg Message) (Message, error)

type CircuitHandlerOpts

+ CircuitConf CircuitConf

+ type CircuitStream struct

+ func (r *CircuitStream) Get(ctx context.Context) (Message, error)

+ func (r *CircuitStream) GetCircuitName() string

type CircuitStreamOpts

+ CircuitConf CircuitConf

+ type HandlerOpts struct

+ Log Logger

+ Name string

+ Namespace string

+ Tracer opentracing.Tracer

+ TracingRef TracingRef

+ type RateLimitedHandler struct

+ func (r *RateLimitedHandler) Handle(ctx context.Context, msg Message) (Message, error)

+ type RateLimitedStream struct

+ func (r *RateLimitedStream) Get(ctx context.Context) (Message, error)

+ type RetryHandler struct

+ func (r *RetryHandler) Handle(ctx context.Context, msg Message) (Message, error)

+ type RetryStream struct

+ func (r *RetryStream) Get(ctx context.Context) (Message, error)

+ type StreamOpts struct

+ Log Logger

+ Name string

+ Namespace string

+ Tracer opentracing.Tracer

+ TracingRef TracingRef

type TracingRef

+ const TracingDisabled

v3.0.6

Aug 27, 2017

v3.0.5

Aug 27, 2017

Changes in this version

+ type ConstBackOffFactory struct

+ func NewConstBackOffFactory(opts *ConstBackOffFactoryOpts) *ConstBackOffFactory

+ func (f *ConstBackOffFactory) NewBackOff() BackOff

+ type ConstBackOffFactoryOpts struct

+ Clock clock.Clock

+ Interval time.Duration

+ MaxElapsedTime time.Duration

+ MaxNumBackOffs int64

+ func NewConstBackOffFactoryOpts(interval time.Duration, maxElapsedTime time.Duration) *ConstBackOffFactoryOpts

+ type ExpBackOffFactory struct

+ func NewExpBackOffFactory(opts *ExpBackOffFactoryOpts) *ExpBackOffFactory

+ func (f *ExpBackOffFactory) NewBackOff() BackOff

+ type ExpBackOffFactoryOpts struct

+ Clock clock.Clock

+ InitialInterval time.Duration

+ MaxElapsedTime time.Duration

+ MaxInterval time.Duration

+ MaxNumBackOffs int64

+ Multiplier float64

+ RandomizationFactor float64

+ func NewExpBackOffFactoryOpts(initInterval time.Duration, multiplier float64, maxInterval time.Duration, ...) *ExpBackOffFactoryOpts

v3.0.4

Aug 24, 2017

v3.0.3

Aug 22, 2017

Changes in this version

type Logger

+ New func(fields ...interface{}) Logger

v3.0.2

Aug 21, 2017

Changes in this version

+ const DefaultCbErrPercentThreshold

+ const DefaultCbMaxConcurrent

+ const DefaultCbSleepWindow

+ const DefaultCbTimeout

+ const DefaultCbVolumeThreshold

+ const DefaultMaxNumBackOffs

+ const DefaultRandomizationFactor

+ const HandlerCircuit

+ const StreamCircuit

+ func CircuitReset()

+ type CircuitConf struct

+ ErrorPercentThreshold int

+ MaxConcurrent int

+ SleepWindow time.Duration

+ Timeout time.Duration

+ VolumeThreshold int

+ func NewDefaultCircuitConf() *CircuitConf

+ func (c *CircuitConf) RegisterFor(circuit string)

+ type CircuitHandlerOpts struct

+ CbMetric CbMetric

+ Circuit string

+ func NewCircuitHandlerOpts(namespace, name, circuit string) *CircuitHandlerOpts

+ type CircuitStreamOpts struct

+ CbMetric CbMetric

+ Circuit string

+ func NewCircuitStreamOpts(namespace, name, circuit string) *CircuitStreamOpts

type Handler

+ func NewCircuitHandler(opts *CircuitHandlerOpts, handler Handler) Handler

+ type SimpleMessage string

+ func (m SimpleMessage) ID() string

type Stream

+ func NewCircuitStream(opts *CircuitStreamOpts, stream Stream) Stream

v3.0.1

Aug 18, 2017

v3.0.0

Aug 17, 2017

Changes in this version

+ const BackOffStop

+ const HandlerBulkhead

+ const HandlerCircuitBreaker

+ const HandlerRateLimited

+ const HandlerRetry

+ const StreamBulkhead

+ const StreamCircuitBreaker

+ const StreamRateLimited

+ const StreamRetry

+ var ErrCbMaxConcurrency = errors.New(hystrix.ErrMaxConcurrency.Error())

+ var ErrCbOpen = errors.New(hystrix.ErrCircuitOpen.Error())

+ var ErrCbTimeout = errors.New(hystrix.ErrTimeout.Error())

+ var ErrMaxConcurrency = errors.New("Reached Max Concurrency")

+ var Log = log15.New()

+ type BackOff interface

+ Next func() time.Duration

+ type BackOffFactory interface

+ NewBackOff func() BackOff

+ type BulkheadHandlerOpts struct

+ MaxConcurrency int

+ Metric Metric

+ func NewBulkheadHandlerOpts(namespace, name string, maxConcurrency int) *BulkheadHandlerOpts

+ type BulkheadStreamOpts struct

+ MaxConcurrency int

+ Metric Metric

+ func NewBulkheadStreamOpts(namespace, name string, maxConcurrency int) *BulkheadStreamOpts

+ type CbMetric interface

+ ObserveErr func(value float64, err error)

+ ObserveOk func(value float64)

+ type CircuitBreakerConf struct

+ ErrorPercentThreshold int

+ MaxConcurrent int

+ SleepWindow time.Duration

+ Timeout time.Duration

+ VolumeThreshold int

+ func NewDefaultCircuitBreakerConf() *CircuitBreakerConf

+ func (c *CircuitBreakerConf) RegisterFor(circuit string)

+ type CircuitBreakerHandlerOpts struct

+ CbMetric CbMetric

+ Circuit string

+ func NewCircuitBreakerHandlerOpts(namespace, name, circuit string) *CircuitBreakerHandlerOpts

+ type CircuitBreakerStreamOpts struct

+ CbMetric CbMetric

+ Circuit string

+ func NewCircuitBreakerStreamOpts(namespace, name, circuit string) *CircuitBreakerStreamOpts

+ type Clock interface

+ Now func() time.Time

+ Sleep func(d time.Duration)

+ type ConstantBackOffFactory struct

+ func NewConstantBackOffFactory(opts *ConstantBackOffFactoryOpts) *ConstantBackOffFactory

+ func (f *ConstantBackOffFactory) NewBackOff() BackOff

+ type ConstantBackOffFactoryOpts struct

+ Clock Clock

+ Interval time.Duration

+ MaxElapsedTime time.Duration

+ MaxNumBackOffs int64

+ func NewConstantBackOffFactoryOpts(interval time.Duration, maxElapsedTime time.Duration) *ConstantBackOffFactoryOpts

+ type ExponentialBackOffFactory struct

+ func NewExponentialBackOffFactory(opts *ExponentialBackOffFactoryOpts) *ExponentialBackOffFactory

+ func (f *ExponentialBackOffFactory) NewBackOff() BackOff

+ type ExponentialBackOffFactoryOpts struct

+ Clock Clock

+ InitialInterval time.Duration

+ MaxElapsedTime time.Duration

+ MaxInterval time.Duration

+ MaxNumBackOffs int64

+ Multiplier float64

+ RandomizationFactor float64

+ func NewExponentialBackOffFactoryOpts(initInterval time.Duration, multiplier float64, maxInterval time.Duration, ...) *ExponentialBackOffFactoryOpts

+ type Handler interface

+ Handle func(context.Context, Message) (Message, error)

+ func AppendFallbacksHandler(handler Handler, fallbacks ...HandlerFallback) Handler

+ func AppendHandlersHandler(handler Handler, handlers ...Handler) Handler

+ func NewBulkheadHandler(opts *BulkheadHandlerOpts, handler Handler) Handler

+ func NewCircuitBreakerHandler(opts *CircuitBreakerHandlerOpts, handler Handler) Handler

+ func NewRateLimitedHandler(opts *RateLimitedHandlerOpts, handler Handler) Handler

+ func NewRetryHandler(opts *RetryHandlerOpts, handler Handler) Handler

+ type HandlerFallback func(context.Context, Message, error) (Message, error)

+ type Identity interface

+ GetNames func() *Names

+ type Logger interface

+ Crit func(msg string, fields ...interface{})

+ Debug func(msg string, fields ...interface{})

+ Error func(msg string, fields ...interface{})

+ Info func(msg string, fields ...interface{})

+ Warn func(msg string, fields ...interface{})

+ type Message interface

+ ID func() string

+ type Metric interface

+ ObserveErr func(value float64)

+ ObserveOk func(value float64)

+ type Names struct

+ Name string

+ Namespace string

+ Resilience string

+ type RateLimit interface

+ Wait func(count int, timeout time.Duration) bool

+ type RateLimitedHandlerOpts struct

+ Limiter RateLimit

+ Metric Metric

+ func NewRateLimitedHandlerOpts(namespace, name string, limiter RateLimit) *RateLimitedHandlerOpts

+ type RateLimitedStreamOpts struct

+ Limiter RateLimit

+ Metric Metric

+ func NewRateLimitedStreamOpts(namespace, name string, limiter RateLimit) *RateLimitedStreamOpts

+ type RetryHandlerOpts struct

+ BackOffFactory BackOffFactory

+ Clock clock.Clock

+ RetryMetric RetryMetric

+ func NewRetryHandlerOpts(namespace, name string, backOffFactory BackOffFactory) *RetryHandlerOpts

+ type RetryMetric interface

+ ObserveErr func(value float64, retry int)

+ ObserveOk func(value float64, retry int)

+ type RetryStreamOpts struct

+ BackOffFactory BackOffFactory

+ Clock clock.Clock

+ RetryMetric RetryMetric

+ func NewRetryStreamOpts(namespace, name string, backOffFactory BackOffFactory) *RetryStreamOpts

+ type SimpleHandler func(context.Context, Message) (Message, error)

+ func (r SimpleHandler) Handle(ctx context.Context, msg Message) (Message, error)

+ type SimpleStream func(context.Context) (Message, error)

+ func (r SimpleStream) Get(ctx context.Context) (Message, error)

+ type Stream interface

+ Get func(context.Context) (Message, error)

+ func AppendFallbacksStream(stream Stream, fallbacks ...StreamFallback) Stream

+ func AppendHandlersStream(stream Stream, handlers ...Handler) Stream

+ func NewBulkheadStream(opts *BulkheadStreamOpts, upstream Stream) Stream

+ func NewCircuitBreakerStream(opts *CircuitBreakerStreamOpts, stream Stream) Stream

+ func NewRateLimitedStream(opts *RateLimitedStreamOpts, upstream Stream) Stream

+ func NewRetryStream(opts *RetryStreamOpts, upstream Stream) Stream

+ type StreamFallback func(context.Context, error) (Message, error)

+ type TokenBucketRateLimit struct

+ func NewTokenBucketRateLimit(requestsInterval time.Duration, maxRequestBurst int) *TokenBucketRateLimit

+ func (rl *TokenBucketRateLimit) Wait(count int, timeout time.Duration) bool

+ type TracingRef int

+ const TracingChildOf

+ const TracingFollowsFrom

Other modules containing this package

gopkg.in/cfchou/go-gentle.v1

gopkg.in/cfchou/go-gentle.v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL