ratelimiter

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

type ConfigBuilder func(*Config)

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

type EventListener interface {
	OnSuccessFunc(func(SuccessEvent)) EventListener
	OnFailureFunc(func(FailureEvent)) EventListener
	DismissSuccessFunc(func(SuccessEvent)) EventListener
	DismissFailureFunc(func(FailureEvent)) EventListener

	OnSuccess(fn.Consumer[SuccessEvent]) EventListener
	OnFailure(fn.Consumer[FailureEvent]) EventListener
	DismissSuccess(fn.Consumer[SuccessEvent]) EventListener
	DismissFailure(fn.Consumer[FailureEvent]) EventListener
}

type EventType string

type FailureEvent interface {
	Event
}

type Metrics interface {
	NumberOfWaitingThreads() int64
	AvailablePermissions() int64
}

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

type RateLimiter interface {
	Name() string
	Metrics() Metrics
	EventListener() EventListener
	AcquirePermission() error
}

type SuccessEvent interface {
	Event
}