Documentation ¶ Overview ¶ Package bulkhead runs a slice of work with bounded parallelism. Index ¶ func Do[T any](ctx context.Context, maxParallelism int, input []T, f func(e T, i int) error) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func Do ¶ func Do[T any](ctx context.Context, maxParallelism int, input []T, f func(e T, i int) error) error Do calls f for each element of input, running at most maxParallelism goroutines concurrently. f receives the element and its original index. The first error returned by any f cancels remaining work and is returned. Types ¶ This section is empty. Source Files ¶ View all Source files work.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files