bulkhead

type Bulkhead interface {
	Name() string
	Metrics() Metrics
	EventListener() EventListener
	Acquire() error
	Release()
}

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

type ConfigBuilder func(*Config)

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

type EventListener interface {
	OnPermittedFunc(func(PermittedEvent)) EventListener
	OnRejectedFunc(func(RejectedEvent)) EventListener
	OnFinishedFunc(func(FinishedEvent)) EventListener
	DismissPermittedFunc(func(PermittedEvent)) EventListener
	DismissRejectedFunc(func(RejectedEvent)) EventListener
	DismissFinishedFunc(func(FinishedEvent)) EventListener

	OnPermitted(fn.Consumer[PermittedEvent]) EventListener
	OnRejected(fn.Consumer[RejectedEvent]) EventListener
	OnFinished(fn.Consumer[FinishedEvent]) EventListener
	DismissPermitted(fn.Consumer[PermittedEvent]) EventListener
	DismissRejected(fn.Consumer[RejectedEvent]) EventListener
	DismissFinished(fn.Consumer[FinishedEvent]) EventListener
}

type EventType string

type FinishedEvent interface {
	Event
}

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

type Metrics interface {
	MaxAllowedConcurrentCalls() int64
	AvailableConcurrentCalls() int64
}

type PermittedEvent interface {
	Event
}

type RejectedEvent interface {
	Event
}