package pool

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/pool"

Index ¶

• type Pool
• func New[T any]( limit int, createItem func(ctx context.Context, onClose func(item *T)) (*T, error), deleteItem func(ctx context.Context, item *T) error, checkErr func(err error) bool, opts ...option[T], ) *Pool[T]
• func (p *Pool[T]) Close(ctx context.Context) (err error)
• func (p *Pool[T]) With(ctx context.Context, f func(ctx context.Context, item *T) error, opts ...retry.Option) error

Types ¶

type Pool ¶

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

func New ¶

func New[T any](
	limit int,
	createItem func(ctx context.Context, onClose func(item *T)) (*T, error),
	deleteItem func(ctx context.Context, item *T) error,
	checkErr func(err error) bool,
	opts ...option[T],
) *Pool[T]

func (*Pool[T]) Close ¶

func (p *Pool[T]) Close(ctx context.Context) (err error)

Close deletes all stored items inside Pool. It also stops all underlying timers and goroutines. It returns first error occurred during stale items' deletion. Note that even on error it calls Close() on each item.

func (*Pool[T]) With ¶

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

Source Files ¶

errors.go pool.go