timelimiter

Dec 19, 2023

Changes in this version

type EventListener

+ DismissPanic func(ge.Action[PanicEvent]) EventListener

+ DismissPanicFunc func(func(PanicEvent)) EventListener

+ DismissSuccess func(ge.Action[SuccessEvent]) EventListener

+ DismissSuccessFunc func(func(SuccessEvent)) EventListener

+ DismissTimeout func(ge.Action[TimeoutEvent]) EventListener

+ DismissTimeoutFunc func(func(TimeoutEvent)) EventListener

+ OnPanicFunc func(func(PanicEvent)) EventListener

+ OnSuccessFunc func(func(SuccessEvent)) EventListener

+ OnTimeoutFunc func(func(TimeoutEvent)) EventListener

type TimeLimiter

+ Execute func(func() (any, error)) (any, error)

Nov 16, 2023

Changes in this version

type EventListener

+ OnPanic func(func(PanicEvent)) EventListener

type EventType

+ const PANIC

type Metrics

+ PanicCount func() int64

+ type PanicEvent interface

+ Panic func() any

+ type SuccessEvent interface

+ type TimeoutEvent interface

Nov 9, 2023

Changes in this version

+ const DefaultTimeoutDuration

+ func DecorateConsumer[T any](limiter TimeLimiter, fn consumer.Consumer[T]) consumer.Consumer[T]

+ func DecorateFunction[T any, R any](limiter TimeLimiter, fn function.Function[T, R]) function.Function[T, R]

+ func DecorateRunnable(limiter TimeLimiter, fn runnable.Runnable) runnable.Runnable

+ func DecorateSupplier[T any](limiter TimeLimiter, fn supplier.Supplier[T]) supplier.Supplier[T]

+ type Config struct

+ func (config *Config) String() string

+ type ConfigBuilder func(*Config)

+ func WithTimeoutDuration(timeoutDuration time.Duration) ConfigBuilder

+ type Event interface

+ CreationTime func() time.Time

+ EventType func() EventType

+ TimeLimiterName func() string

+ type EventConsumer func(Event)

+ type EventListener interface

+ Dismiss func(EventConsumer) EventListener

+ HasConsumer func() bool

+ OnFailure func(EventConsumer) EventListener

+ OnSuccess func(EventConsumer) EventListener

+ OnTimeout func(EventConsumer) EventListener

+ type EventType string

+ const FAILURE

+ const SUCCESS

+ const TIMEOUT

+ type Metrics interface

+ FailureCount func() int64

+ SuccessCount func() int64

+ TimeoutCount func() int64

+ type TimeLimiter interface

+ EventListener func() EventListener

+ Metrics func() Metrics

+ Name func() string

+ func NewTimeLimiter(name string, configs ...ConfigBuilder) TimeLimiter

+ type TimeoutError struct

+ func (e *TimeoutError) Error() string