timelimiter

type Config struct {
	// contains filtered or unexported fields
}

type ConfigBuilder func(*Config)

type Event interface {
	fmt.Stringer
	TimeLimiterName() string
	CreationTime() time.Time
	EventType() EventType
}

type EventListener interface {
	OnSuccessFunc(func(SuccessEvent)) EventListener
	OnTimeoutFunc(func(TimeoutEvent)) EventListener
	OnPanicFunc(func(PanicEvent)) EventListener
	DismissSuccessFunc(func(SuccessEvent)) EventListener
	DismissTimeoutFunc(func(TimeoutEvent)) EventListener
	DismissPanicFunc(func(PanicEvent)) EventListener

	OnSuccess(fn.Consumer[SuccessEvent]) EventListener
	OnTimeout(fn.Consumer[TimeoutEvent]) EventListener
	OnPanic(fn.Consumer[PanicEvent]) EventListener
	DismissSuccess(fn.Consumer[SuccessEvent]) EventListener
	DismissTimeout(fn.Consumer[TimeoutEvent]) EventListener
	DismissPanic(fn.Consumer[PanicEvent]) EventListener
}

type EventType string

type Metrics interface {
	SuccessCount() uint64
	TimeoutCount() uint64
	PanicCount() uint64
}

type PanicEvent interface {
	Event
	Panic() any
}

type SuccessEvent interface {
	Event
}

type TimeLimiter interface {
	Name() string
	Metrics() Metrics
	EventListener() EventListener
	Execute(func() (any, error)) (any, error)
}

type TimeoutError struct {
	// contains filtered or unexported fields
}

type TimeoutEvent interface {
	Event
}