pool

type Config[PT ItemConstraint[T], T any] struct {
	// contains filtered or unexported fields
}

type Item interface {
	closer.Closer
	node.ID

	IsAlive() bool
}

type ItemConstraint[T any] interface {
	*T
	Item
}

type Option[PT ItemConstraint[T], T any] func(c *Config[PT, T])

type Pool[PT ItemConstraint[T], T any] struct {
	// contains filtered or unexported fields
}

type Stats struct {
	Limit            int
	Index            int
	Idle             int
	Wait             int
	CreateInProgress int
}

type Trace struct {
	OnNew   func(ctx *context.Context, call stack.Caller) func(limit int)
	OnClose func(ctx *context.Context, call stack.Caller) func(err error)
	OnTry   func(ctx *context.Context, call stack.Caller) func(err error)
	OnWith  func(ctx *context.Context, call stack.Caller) func(attempts int, err error)
	OnPut   func(ctx *context.Context, call stack.Caller, item any) func(err error)
	OnGet   func(ctx *context.Context, call stack.Caller) func(item any, attempts int, err error)

	OnChange func(Stats)
	// contains filtered or unexported fields
}