pool

Documentation

Index

• Constants
• func WithClock[PT Item[T], T any](clock clockwork.Clock) option[PT, T]
• func WithCloseItemTimeout[PT Item[T], T any](t time.Duration) option[PT, T]
• func WithCreateItemFunc[PT Item[T], T any](f func(ctx context.Context) (PT, error)) option[PT, T]
• func WithCreateItemTimeout[PT Item[T], T any](t time.Duration) option[PT, T]
• func WithIdleThreshold[PT Item[T], T any](idleThreshold time.Duration) option[PT, T]
• func WithLimit[PT Item[T], T any](size int) option[PT, T]
• func WithTrace[PT Item[T], T any](t *Trace) option[PT, T]
• type Config
• type Item
• type Pool
  • func New[PT Item[T], T any](ctx context.Context, opts ...option[PT, T]) *Pool[PT, T]
  • func (p *Pool[PT, T]) Close(ctx context.Context) (finalErr error)
  • func (p *Pool[PT, T]) Stats() Stats
  • func (p *Pool[PT, T]) With(ctx context.Context, f func(ctx context.Context, item PT) error, ...) (finalErr error)
• type Stats
• type Trace

Constants

const (
	DefaultLimit = 50
)

Functions

func WithClock

func WithClock[PT Item[T], T any](clock clockwork.Clock) option[PT, T]

func WithCloseItemTimeout

func WithCloseItemTimeout[PT Item[T], T any](t time.Duration) option[PT, T]

func WithCreateItemFunc

func WithCreateItemFunc[PT Item[T], T any](f func(ctx context.Context) (PT, error)) option[PT, T]

func WithCreateItemTimeout

func WithCreateItemTimeout[PT Item[T], T any](t time.Duration) option[PT, T]

func WithIdleThreshold

func WithIdleThreshold[PT Item[T], T any](idleThreshold time.Duration) option[PT, T]

func WithLimit

func WithLimit[PT Item[T], T any](size int) option[PT, T]

func WithTrace

func WithTrace[PT Item[T], T any](t *Trace) option[PT, T]

Types

type Config

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

type Item

type Item[T any] interface {
	*T
	IsAlive() bool
	Close(ctx context.Context) error
}

type Pool

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

func New

func New[PT Item[T], T any](
	ctx context.Context,
	opts ...option[PT, T],
) *Pool[PT, T]

func (*Pool[PT, T]) Close

func (p *Pool[PT, T]) Close(ctx context.Context) (finalErr error)

func (*Pool[PT, T]) Stats

func (p *Pool[PT, T]) Stats() Stats

func (*Pool[PT, T]) With

func (p *Pool[PT, T]) With(
	ctx context.Context,
	f func(ctx context.Context, item PT) error,
	opts ...retry.Option,
) (finalErr error)

type Stats

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

type Trace

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
}