pool

package

v1.0.0 Latest Latest Go to latest Published: Dec 1, 2020 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var (
	// ErrZeroItems is returned when an empty slice is provided to Start
	ErrZeroItems = errors.New("zero items provided")
)

This section is empty.

type Handler func(ctx context.Context, db string) error

Handler handles

type Pooler interface {
	Start(context.Context, []string, Handler) error
}

Pooler interface abstracts a Pool instance

type SizablePool struct {
	Size int
}

SizablePool is a pool with a size!

func (p SizablePool) Start(ctx context.Context, items []string, h Handler) error

Start kicks handling of items in a pool