work

type Pool[T any] struct {
	// Name is what the pool is called in log lines.
	Name string

	// Limit is the most items this replica runs at once. At least one.
	Limit int

	// LimitFunc, when set, is read instead of Limit every time the pool looks
	// for work, so the limit can change while the pool runs (issue #93). A
	// lower limit takes effect as running items finish: nothing is stopped.
	LimitFunc func(ctx context.Context) int

	// Poll is how often the pool looks for work when it was not told there is
	// some (Kick). Work queued on another replica is found this way. Two
	// seconds when zero.
	Poll time.Duration

	// Claim takes up to n items for this replica.
	Claim func(ctx context.Context, n int) ([]T, error)

	// Run runs one item to completion. Its context ends when the pool stops,
	// and Run must return soon after: a deploy's adapters honor cancellation.
	Run func(ctx context.Context, item T)

	// Release puts back items whose Run was still going when the pool
	// stopped, so another replica takes them at once rather than after this
	// one is taken for dead. An item that finished in the meantime must be
	// left alone; the stores' Release only touches work still in flight.
	Release func(ctx context.Context, items []T)

	// Drain is how long a stopping pool waits for its items to return before
	// releasing them anyway. Ten seconds when zero.
	Drain time.Duration

	Logger *zap.Logger
	// contains filtered or unexported fields
}